mocks

Nov 3, 2023

Changes in this version

type CollectorClient

+ func (_m *CollectorClient) ClusterInfo(ctx context.Context) (*collector.ClusterInfo, error)

+ type CollectorClient_ClusterInfo_Call struct

+ func (_c *CollectorClient_ClusterInfo_Call) Return(_a0 *collector.ClusterInfo, _a1 error) *CollectorClient_ClusterInfo_Call

+ func (_c *CollectorClient_ClusterInfo_Call) Run(run func(ctx context.Context)) *CollectorClient_ClusterInfo_Call

+ func (_c *CollectorClient_ClusterInfo_Call) RunAndReturn(run func(context.Context) (*collector.ClusterInfo, error)) *CollectorClient_ClusterInfo_Call

type CollectorClient_Expecter

+ func (_e *CollectorClient_Expecter) ClusterInfo(ctx interface{}) *CollectorClient_ClusterInfo_Call

Aug 11, 2023

Changes in this version

+ type CollectorClient struct

+ func NewCollectorClient(t mockConstructorTestingTNewCollectorClient) *CollectorClient

+ func (_m *CollectorClient) Close(ctx context.Context) error

+ func (_m *CollectorClient) EXPECT() *CollectorClient_Expecter

+ func (_m *CollectorClient) HealthCheck(ctx context.Context) (bool, error)

+ func (_m *CollectorClient) Name() string

+ func (_m *CollectorClient) StreamClusterRoleBindings(ctx context.Context, ingestor collector.ClusterRoleBindingIngestor) error

+ func (_m *CollectorClient) StreamClusterRoles(ctx context.Context, ingestor collector.ClusterRoleIngestor) error

+ func (_m *CollectorClient) StreamEndpoints(ctx context.Context, ingestor collector.EndpointIngestor) error

+ func (_m *CollectorClient) StreamNodes(ctx context.Context, ingestor collector.NodeIngestor) error

+ func (_m *CollectorClient) StreamPods(ctx context.Context, ingestor collector.PodIngestor) error

+ func (_m *CollectorClient) StreamRoleBindings(ctx context.Context, ingestor collector.RoleBindingIngestor) error

+ func (_m *CollectorClient) StreamRoles(ctx context.Context, ingestor collector.RoleIngestor) error

+ type CollectorClient_Close_Call struct

+ func (_c *CollectorClient_Close_Call) Return(_a0 error) *CollectorClient_Close_Call

+ func (_c *CollectorClient_Close_Call) Run(run func(ctx context.Context)) *CollectorClient_Close_Call

+ func (_c *CollectorClient_Close_Call) RunAndReturn(run func(context.Context) error) *CollectorClient_Close_Call

+ type CollectorClient_Expecter struct

+ func (_e *CollectorClient_Expecter) Close(ctx interface{}) *CollectorClient_Close_Call

+ func (_e *CollectorClient_Expecter) HealthCheck(ctx interface{}) *CollectorClient_HealthCheck_Call

+ func (_e *CollectorClient_Expecter) Name() *CollectorClient_Name_Call

+ func (_e *CollectorClient_Expecter) StreamClusterRoleBindings(ctx interface{}, ingestor interface{}) *CollectorClient_StreamClusterRoleBindings_Call

+ func (_e *CollectorClient_Expecter) StreamClusterRoles(ctx interface{}, ingestor interface{}) *CollectorClient_StreamClusterRoles_Call

+ func (_e *CollectorClient_Expecter) StreamEndpoints(ctx interface{}, ingestor interface{}) *CollectorClient_StreamEndpoints_Call

+ func (_e *CollectorClient_Expecter) StreamNodes(ctx interface{}, ingestor interface{}) *CollectorClient_StreamNodes_Call

+ func (_e *CollectorClient_Expecter) StreamPods(ctx interface{}, ingestor interface{}) *CollectorClient_StreamPods_Call

+ func (_e *CollectorClient_Expecter) StreamRoleBindings(ctx interface{}, ingestor interface{}) *CollectorClient_StreamRoleBindings_Call

+ func (_e *CollectorClient_Expecter) StreamRoles(ctx interface{}, ingestor interface{}) *CollectorClient_StreamRoles_Call

+ type CollectorClient_HealthCheck_Call struct

+ func (_c *CollectorClient_HealthCheck_Call) Return(_a0 bool, _a1 error) *CollectorClient_HealthCheck_Call

+ func (_c *CollectorClient_HealthCheck_Call) Run(run func(ctx context.Context)) *CollectorClient_HealthCheck_Call

+ func (_c *CollectorClient_HealthCheck_Call) RunAndReturn(run func(context.Context) (bool, error)) *CollectorClient_HealthCheck_Call

+ type CollectorClient_Name_Call struct

+ func (_c *CollectorClient_Name_Call) Return(_a0 string) *CollectorClient_Name_Call

+ func (_c *CollectorClient_Name_Call) Run(run func()) *CollectorClient_Name_Call

+ func (_c *CollectorClient_Name_Call) RunAndReturn(run func() string) *CollectorClient_Name_Call

+ type CollectorClient_StreamClusterRoleBindings_Call struct

+ func (_c *CollectorClient_StreamClusterRoleBindings_Call) Return(_a0 error) *CollectorClient_StreamClusterRoleBindings_Call

+ func (_c *CollectorClient_StreamClusterRoleBindings_Call) Run(run func(ctx context.Context, ingestor collector.ClusterRoleBindingIngestor)) *CollectorClient_StreamClusterRoleBindings_Call

+ func (_c *CollectorClient_StreamClusterRoleBindings_Call) RunAndReturn(run func(context.Context, collector.ClusterRoleBindingIngestor) error) *CollectorClient_StreamClusterRoleBindings_Call

+ type CollectorClient_StreamClusterRoles_Call struct

+ func (_c *CollectorClient_StreamClusterRoles_Call) Return(_a0 error) *CollectorClient_StreamClusterRoles_Call

+ func (_c *CollectorClient_StreamClusterRoles_Call) Run(run func(ctx context.Context, ingestor collector.ClusterRoleIngestor)) *CollectorClient_StreamClusterRoles_Call

+ func (_c *CollectorClient_StreamClusterRoles_Call) RunAndReturn(run func(context.Context, collector.ClusterRoleIngestor) error) *CollectorClient_StreamClusterRoles_Call

+ type CollectorClient_StreamEndpoints_Call struct

+ func (_c *CollectorClient_StreamEndpoints_Call) Return(_a0 error) *CollectorClient_StreamEndpoints_Call

+ func (_c *CollectorClient_StreamEndpoints_Call) Run(run func(ctx context.Context, ingestor collector.EndpointIngestor)) *CollectorClient_StreamEndpoints_Call

+ func (_c *CollectorClient_StreamEndpoints_Call) RunAndReturn(run func(context.Context, collector.EndpointIngestor) error) *CollectorClient_StreamEndpoints_Call

+ type CollectorClient_StreamNodes_Call struct

+ func (_c *CollectorClient_StreamNodes_Call) Return(_a0 error) *CollectorClient_StreamNodes_Call

+ func (_c *CollectorClient_StreamNodes_Call) Run(run func(ctx context.Context, ingestor collector.NodeIngestor)) *CollectorClient_StreamNodes_Call

+ func (_c *CollectorClient_StreamNodes_Call) RunAndReturn(run func(context.Context, collector.NodeIngestor) error) *CollectorClient_StreamNodes_Call

+ type CollectorClient_StreamPods_Call struct

+ func (_c *CollectorClient_StreamPods_Call) Return(_a0 error) *CollectorClient_StreamPods_Call

+ func (_c *CollectorClient_StreamPods_Call) Run(run func(ctx context.Context, ingestor collector.PodIngestor)) *CollectorClient_StreamPods_Call

+ func (_c *CollectorClient_StreamPods_Call) RunAndReturn(run func(context.Context, collector.PodIngestor) error) *CollectorClient_StreamPods_Call

+ type CollectorClient_StreamRoleBindings_Call struct

+ func (_c *CollectorClient_StreamRoleBindings_Call) Return(_a0 error) *CollectorClient_StreamRoleBindings_Call

+ func (_c *CollectorClient_StreamRoleBindings_Call) Run(run func(ctx context.Context, ingestor collector.RoleBindingIngestor)) *CollectorClient_StreamRoleBindings_Call

+ func (_c *CollectorClient_StreamRoleBindings_Call) RunAndReturn(run func(context.Context, collector.RoleBindingIngestor) error) *CollectorClient_StreamRoleBindings_Call

+ type CollectorClient_StreamRoles_Call struct

+ func (_c *CollectorClient_StreamRoles_Call) Return(_a0 error) *CollectorClient_StreamRoles_Call

+ func (_c *CollectorClient_StreamRoles_Call) Run(run func(ctx context.Context, ingestor collector.RoleIngestor)) *CollectorClient_StreamRoles_Call

+ func (_c *CollectorClient_StreamRoles_Call) RunAndReturn(run func(context.Context, collector.RoleIngestor) error) *CollectorClient_StreamRoles_Call