Documentation ¶
Index ¶
- type CollectorClient
- func (_m *CollectorClient) Close(ctx context.Context) error
- func (_m *CollectorClient) ClusterInfo(ctx context.Context) (*config.ClusterInfo, error)
- func (_m *CollectorClient) ComputeMetadata(ctx context.Context, ingestor collector.MetadataIngestor) 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
- type CollectorClient_ClusterInfo_Call
- func (_c *CollectorClient_ClusterInfo_Call) Return(_a0 *config.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) (*config.ClusterInfo, error)) *CollectorClient_ClusterInfo_Call
- type CollectorClient_ComputeMetadata_Call
- func (_c *CollectorClient_ComputeMetadata_Call) Return(_a0 error) *CollectorClient_ComputeMetadata_Call
- func (_c *CollectorClient_ComputeMetadata_Call) Run(run func(ctx context.Context, ingestor collector.MetadataIngestor)) *CollectorClient_ComputeMetadata_Call
- func (_c *CollectorClient_ComputeMetadata_Call) RunAndReturn(run func(context.Context, collector.MetadataIngestor) error) *CollectorClient_ComputeMetadata_Call
- type CollectorClient_Expecter
- func (_e *CollectorClient_Expecter) Close(ctx interface{}) *CollectorClient_Close_Call
- func (_e *CollectorClient_Expecter) ClusterInfo(ctx interface{}) *CollectorClient_ClusterInfo_Call
- func (_e *CollectorClient_Expecter) ComputeMetadata(ctx interface{}, ingestor interface{}) *CollectorClient_ComputeMetadata_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
- 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
- type CollectorClient_StreamClusterRoleBindings_Call
- 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
- 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
- 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
- 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
- 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
- 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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CollectorClient ¶
CollectorClient is an autogenerated mock type for the CollectorClient type
func NewCollectorClient ¶
func NewCollectorClient(t mockConstructorTestingTNewCollectorClient) *CollectorClient
NewCollectorClient creates a new instance of CollectorClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*CollectorClient) Close ¶
func (_m *CollectorClient) Close(ctx context.Context) error
Close provides a mock function with given fields: ctx
func (*CollectorClient) ClusterInfo ¶ added in v1.2.0
func (_m *CollectorClient) ClusterInfo(ctx context.Context) (*config.ClusterInfo, error)
ClusterInfo provides a mock function with given fields: ctx
func (*CollectorClient) ComputeMetadata ¶ added in v1.5.0
func (_m *CollectorClient) ComputeMetadata(ctx context.Context, ingestor collector.MetadataIngestor) error
ComputeMetadata provides a mock function with given fields: ctx, ingestor
func (*CollectorClient) EXPECT ¶
func (_m *CollectorClient) EXPECT() *CollectorClient_Expecter
func (*CollectorClient) HealthCheck ¶
func (_m *CollectorClient) HealthCheck(ctx context.Context) (bool, error)
HealthCheck provides a mock function with given fields: ctx
func (*CollectorClient) Name ¶
func (_m *CollectorClient) Name() string
Name provides a mock function with given fields:
func (*CollectorClient) StreamClusterRoleBindings ¶
func (_m *CollectorClient) StreamClusterRoleBindings(ctx context.Context, ingestor collector.ClusterRoleBindingIngestor) error
StreamClusterRoleBindings provides a mock function with given fields: ctx, ingestor
func (*CollectorClient) StreamClusterRoles ¶
func (_m *CollectorClient) StreamClusterRoles(ctx context.Context, ingestor collector.ClusterRoleIngestor) error
StreamClusterRoles provides a mock function with given fields: ctx, ingestor
func (*CollectorClient) StreamEndpoints ¶
func (_m *CollectorClient) StreamEndpoints(ctx context.Context, ingestor collector.EndpointIngestor) error
StreamEndpoints provides a mock function with given fields: ctx, ingestor
func (*CollectorClient) StreamNodes ¶
func (_m *CollectorClient) StreamNodes(ctx context.Context, ingestor collector.NodeIngestor) error
StreamNodes provides a mock function with given fields: ctx, ingestor
func (*CollectorClient) StreamPods ¶
func (_m *CollectorClient) StreamPods(ctx context.Context, ingestor collector.PodIngestor) error
StreamPods provides a mock function with given fields: ctx, ingestor
func (*CollectorClient) StreamRoleBindings ¶
func (_m *CollectorClient) StreamRoleBindings(ctx context.Context, ingestor collector.RoleBindingIngestor) error
StreamRoleBindings provides a mock function with given fields: ctx, ingestor
func (*CollectorClient) StreamRoles ¶
func (_m *CollectorClient) StreamRoles(ctx context.Context, ingestor collector.RoleIngestor) error
StreamRoles provides a mock function with given fields: ctx, ingestor
type CollectorClient_Close_Call ¶
CollectorClient_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*CollectorClient_Close_Call) Return ¶
func (_c *CollectorClient_Close_Call) Return(_a0 error) *CollectorClient_Close_Call
func (*CollectorClient_Close_Call) Run ¶
func (_c *CollectorClient_Close_Call) Run(run func(ctx context.Context)) *CollectorClient_Close_Call
func (*CollectorClient_Close_Call) RunAndReturn ¶
func (_c *CollectorClient_Close_Call) RunAndReturn(run func(context.Context) error) *CollectorClient_Close_Call
type CollectorClient_ClusterInfo_Call ¶ added in v1.2.0
CollectorClient_ClusterInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClusterInfo'
func (*CollectorClient_ClusterInfo_Call) Return ¶ added in v1.2.0
func (_c *CollectorClient_ClusterInfo_Call) Return(_a0 *config.ClusterInfo, _a1 error) *CollectorClient_ClusterInfo_Call
func (*CollectorClient_ClusterInfo_Call) Run ¶ added in v1.2.0
func (_c *CollectorClient_ClusterInfo_Call) Run(run func(ctx context.Context)) *CollectorClient_ClusterInfo_Call
func (*CollectorClient_ClusterInfo_Call) RunAndReturn ¶ added in v1.2.0
func (_c *CollectorClient_ClusterInfo_Call) RunAndReturn(run func(context.Context) (*config.ClusterInfo, error)) *CollectorClient_ClusterInfo_Call
type CollectorClient_ComputeMetadata_Call ¶ added in v1.5.0
CollectorClient_ComputeMetadata_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ComputeMetadata'
func (*CollectorClient_ComputeMetadata_Call) Return ¶ added in v1.5.0
func (_c *CollectorClient_ComputeMetadata_Call) Return(_a0 error) *CollectorClient_ComputeMetadata_Call
func (*CollectorClient_ComputeMetadata_Call) Run ¶ added in v1.5.0
func (_c *CollectorClient_ComputeMetadata_Call) Run(run func(ctx context.Context, ingestor collector.MetadataIngestor)) *CollectorClient_ComputeMetadata_Call
func (*CollectorClient_ComputeMetadata_Call) RunAndReturn ¶ added in v1.5.0
func (_c *CollectorClient_ComputeMetadata_Call) RunAndReturn(run func(context.Context, collector.MetadataIngestor) error) *CollectorClient_ComputeMetadata_Call
type CollectorClient_Expecter ¶
type CollectorClient_Expecter struct {
// contains filtered or unexported fields
}
func (*CollectorClient_Expecter) Close ¶
func (_e *CollectorClient_Expecter) Close(ctx interface{}) *CollectorClient_Close_Call
Close is a helper method to define mock.On call
- ctx context.Context
func (*CollectorClient_Expecter) ClusterInfo ¶ added in v1.2.0
func (_e *CollectorClient_Expecter) ClusterInfo(ctx interface{}) *CollectorClient_ClusterInfo_Call
ClusterInfo is a helper method to define mock.On call
- ctx context.Context
func (*CollectorClient_Expecter) ComputeMetadata ¶ added in v1.5.0
func (_e *CollectorClient_Expecter) ComputeMetadata(ctx interface{}, ingestor interface{}) *CollectorClient_ComputeMetadata_Call
ComputeMetadata is a helper method to define mock.On call
- ctx context.Context
- ingestor collector.MetadataIngestor
func (*CollectorClient_Expecter) HealthCheck ¶
func (_e *CollectorClient_Expecter) HealthCheck(ctx interface{}) *CollectorClient_HealthCheck_Call
HealthCheck is a helper method to define mock.On call
- ctx context.Context
func (*CollectorClient_Expecter) Name ¶
func (_e *CollectorClient_Expecter) Name() *CollectorClient_Name_Call
Name is a helper method to define mock.On call
func (*CollectorClient_Expecter) StreamClusterRoleBindings ¶
func (_e *CollectorClient_Expecter) StreamClusterRoleBindings(ctx interface{}, ingestor interface{}) *CollectorClient_StreamClusterRoleBindings_Call
StreamClusterRoleBindings is a helper method to define mock.On call
- ctx context.Context
- ingestor collector.ClusterRoleBindingIngestor
func (*CollectorClient_Expecter) StreamClusterRoles ¶
func (_e *CollectorClient_Expecter) StreamClusterRoles(ctx interface{}, ingestor interface{}) *CollectorClient_StreamClusterRoles_Call
StreamClusterRoles is a helper method to define mock.On call
- ctx context.Context
- ingestor collector.ClusterRoleIngestor
func (*CollectorClient_Expecter) StreamEndpoints ¶
func (_e *CollectorClient_Expecter) StreamEndpoints(ctx interface{}, ingestor interface{}) *CollectorClient_StreamEndpoints_Call
StreamEndpoints is a helper method to define mock.On call
- ctx context.Context
- ingestor collector.EndpointIngestor
func (*CollectorClient_Expecter) StreamNodes ¶
func (_e *CollectorClient_Expecter) StreamNodes(ctx interface{}, ingestor interface{}) *CollectorClient_StreamNodes_Call
StreamNodes is a helper method to define mock.On call
- ctx context.Context
- ingestor collector.NodeIngestor
func (*CollectorClient_Expecter) StreamPods ¶
func (_e *CollectorClient_Expecter) StreamPods(ctx interface{}, ingestor interface{}) *CollectorClient_StreamPods_Call
StreamPods is a helper method to define mock.On call
- ctx context.Context
- ingestor collector.PodIngestor
func (*CollectorClient_Expecter) StreamRoleBindings ¶
func (_e *CollectorClient_Expecter) StreamRoleBindings(ctx interface{}, ingestor interface{}) *CollectorClient_StreamRoleBindings_Call
StreamRoleBindings is a helper method to define mock.On call
- ctx context.Context
- ingestor collector.RoleBindingIngestor
func (*CollectorClient_Expecter) StreamRoles ¶
func (_e *CollectorClient_Expecter) StreamRoles(ctx interface{}, ingestor interface{}) *CollectorClient_StreamRoles_Call
StreamRoles is a helper method to define mock.On call
- ctx context.Context
- ingestor collector.RoleIngestor
type CollectorClient_HealthCheck_Call ¶
CollectorClient_HealthCheck_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HealthCheck'
func (*CollectorClient_HealthCheck_Call) Return ¶
func (_c *CollectorClient_HealthCheck_Call) Return(_a0 bool, _a1 error) *CollectorClient_HealthCheck_Call
func (*CollectorClient_HealthCheck_Call) Run ¶
func (_c *CollectorClient_HealthCheck_Call) Run(run func(ctx context.Context)) *CollectorClient_HealthCheck_Call
func (*CollectorClient_HealthCheck_Call) RunAndReturn ¶
func (_c *CollectorClient_HealthCheck_Call) RunAndReturn(run func(context.Context) (bool, error)) *CollectorClient_HealthCheck_Call
type CollectorClient_Name_Call ¶
CollectorClient_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'
func (*CollectorClient_Name_Call) Return ¶
func (_c *CollectorClient_Name_Call) Return(_a0 string) *CollectorClient_Name_Call
func (*CollectorClient_Name_Call) Run ¶
func (_c *CollectorClient_Name_Call) Run(run func()) *CollectorClient_Name_Call
func (*CollectorClient_Name_Call) RunAndReturn ¶
func (_c *CollectorClient_Name_Call) RunAndReturn(run func() string) *CollectorClient_Name_Call
type CollectorClient_StreamClusterRoleBindings_Call ¶
CollectorClient_StreamClusterRoleBindings_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamClusterRoleBindings'
func (*CollectorClient_StreamClusterRoleBindings_Call) Return ¶
func (_c *CollectorClient_StreamClusterRoleBindings_Call) Return(_a0 error) *CollectorClient_StreamClusterRoleBindings_Call
func (*CollectorClient_StreamClusterRoleBindings_Call) Run ¶
func (_c *CollectorClient_StreamClusterRoleBindings_Call) Run(run func(ctx context.Context, ingestor collector.ClusterRoleBindingIngestor)) *CollectorClient_StreamClusterRoleBindings_Call
func (*CollectorClient_StreamClusterRoleBindings_Call) RunAndReturn ¶
func (_c *CollectorClient_StreamClusterRoleBindings_Call) RunAndReturn(run func(context.Context, collector.ClusterRoleBindingIngestor) error) *CollectorClient_StreamClusterRoleBindings_Call
type CollectorClient_StreamClusterRoles_Call ¶
CollectorClient_StreamClusterRoles_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamClusterRoles'
func (*CollectorClient_StreamClusterRoles_Call) Return ¶
func (_c *CollectorClient_StreamClusterRoles_Call) Return(_a0 error) *CollectorClient_StreamClusterRoles_Call
func (*CollectorClient_StreamClusterRoles_Call) Run ¶
func (_c *CollectorClient_StreamClusterRoles_Call) Run(run func(ctx context.Context, ingestor collector.ClusterRoleIngestor)) *CollectorClient_StreamClusterRoles_Call
func (*CollectorClient_StreamClusterRoles_Call) RunAndReturn ¶
func (_c *CollectorClient_StreamClusterRoles_Call) RunAndReturn(run func(context.Context, collector.ClusterRoleIngestor) error) *CollectorClient_StreamClusterRoles_Call
type CollectorClient_StreamEndpoints_Call ¶
CollectorClient_StreamEndpoints_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamEndpoints'
func (*CollectorClient_StreamEndpoints_Call) Return ¶
func (_c *CollectorClient_StreamEndpoints_Call) Return(_a0 error) *CollectorClient_StreamEndpoints_Call
func (*CollectorClient_StreamEndpoints_Call) Run ¶
func (_c *CollectorClient_StreamEndpoints_Call) Run(run func(ctx context.Context, ingestor collector.EndpointIngestor)) *CollectorClient_StreamEndpoints_Call
func (*CollectorClient_StreamEndpoints_Call) RunAndReturn ¶
func (_c *CollectorClient_StreamEndpoints_Call) RunAndReturn(run func(context.Context, collector.EndpointIngestor) error) *CollectorClient_StreamEndpoints_Call
type CollectorClient_StreamNodes_Call ¶
CollectorClient_StreamNodes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamNodes'
func (*CollectorClient_StreamNodes_Call) Return ¶
func (_c *CollectorClient_StreamNodes_Call) Return(_a0 error) *CollectorClient_StreamNodes_Call
func (*CollectorClient_StreamNodes_Call) Run ¶
func (_c *CollectorClient_StreamNodes_Call) Run(run func(ctx context.Context, ingestor collector.NodeIngestor)) *CollectorClient_StreamNodes_Call
func (*CollectorClient_StreamNodes_Call) RunAndReturn ¶
func (_c *CollectorClient_StreamNodes_Call) RunAndReturn(run func(context.Context, collector.NodeIngestor) error) *CollectorClient_StreamNodes_Call
type CollectorClient_StreamPods_Call ¶
CollectorClient_StreamPods_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamPods'
func (*CollectorClient_StreamPods_Call) Return ¶
func (_c *CollectorClient_StreamPods_Call) Return(_a0 error) *CollectorClient_StreamPods_Call
func (*CollectorClient_StreamPods_Call) Run ¶
func (_c *CollectorClient_StreamPods_Call) Run(run func(ctx context.Context, ingestor collector.PodIngestor)) *CollectorClient_StreamPods_Call
func (*CollectorClient_StreamPods_Call) RunAndReturn ¶
func (_c *CollectorClient_StreamPods_Call) RunAndReturn(run func(context.Context, collector.PodIngestor) error) *CollectorClient_StreamPods_Call
type CollectorClient_StreamRoleBindings_Call ¶
CollectorClient_StreamRoleBindings_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamRoleBindings'
func (*CollectorClient_StreamRoleBindings_Call) Return ¶
func (_c *CollectorClient_StreamRoleBindings_Call) Return(_a0 error) *CollectorClient_StreamRoleBindings_Call
func (*CollectorClient_StreamRoleBindings_Call) Run ¶
func (_c *CollectorClient_StreamRoleBindings_Call) Run(run func(ctx context.Context, ingestor collector.RoleBindingIngestor)) *CollectorClient_StreamRoleBindings_Call
func (*CollectorClient_StreamRoleBindings_Call) RunAndReturn ¶
func (_c *CollectorClient_StreamRoleBindings_Call) RunAndReturn(run func(context.Context, collector.RoleBindingIngestor) error) *CollectorClient_StreamRoleBindings_Call
type CollectorClient_StreamRoles_Call ¶
CollectorClient_StreamRoles_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamRoles'
func (*CollectorClient_StreamRoles_Call) Return ¶
func (_c *CollectorClient_StreamRoles_Call) Return(_a0 error) *CollectorClient_StreamRoles_Call
func (*CollectorClient_StreamRoles_Call) Run ¶
func (_c *CollectorClient_StreamRoles_Call) Run(run func(ctx context.Context, ingestor collector.RoleIngestor)) *CollectorClient_StreamRoles_Call
func (*CollectorClient_StreamRoles_Call) RunAndReturn ¶
func (_c *CollectorClient_StreamRoles_Call) RunAndReturn(run func(context.Context, collector.RoleIngestor) error) *CollectorClient_StreamRoles_Call