Documentation
¶
Overview ¶
Package mock_core is a generated GoMock package.
Index ¶
- type MockAgentClient
- type MockAgentClientMockRecorder
- type MockAgentSecureClient
- func (m *MockAgentSecureClient) AutodiscoveryStreamConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[core.AutodiscoveryStreamResponse], error)
- func (m *MockAgentSecureClient) ClientGetConfigs(ctx context.Context, in *core.ClientGetConfigsRequest, opts ...grpc.CallOption) (*core.ClientGetConfigsResponse, error)
- func (m *MockAgentSecureClient) ClientGetConfigsHA(ctx context.Context, in *core.ClientGetConfigsRequest, opts ...grpc.CallOption) (*core.ClientGetConfigsResponse, error)
- func (m *MockAgentSecureClient) CreateConfigSubscription(ctx context.Context, opts ...grpc.CallOption) (...)
- func (m *MockAgentSecureClient) DogstatsdCaptureTrigger(ctx context.Context, in *core.CaptureTriggerRequest, opts ...grpc.CallOption) (*core.CaptureTriggerResponse, error)
- func (m *MockAgentSecureClient) DogstatsdSetTaggerState(ctx context.Context, in *core.TaggerState, opts ...grpc.CallOption) (*core.TaggerStateResponse, error)
- func (m *MockAgentSecureClient) EXPECT() *MockAgentSecureClientMockRecorder
- func (m *MockAgentSecureClient) GetConfigState(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*core.GetStateConfigResponse, error)
- func (m *MockAgentSecureClient) GetConfigStateHA(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*core.GetStateConfigResponse, error)
- func (m *MockAgentSecureClient) GetHostTags(ctx context.Context, in *core.HostTagRequest, opts ...grpc.CallOption) (*core.HostTagReply, error)
- func (m *MockAgentSecureClient) RefreshRemoteAgent(ctx context.Context, in *core.RefreshRemoteAgentRequest, ...) (*core.RefreshRemoteAgentResponse, error)
- func (m *MockAgentSecureClient) RegisterRemoteAgent(ctx context.Context, in *core.RegisterRemoteAgentRequest, ...) (*core.RegisterRemoteAgentResponse, error)
- func (m *MockAgentSecureClient) ResetConfigState(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*core.ResetStateConfigResponse, error)
- func (m *MockAgentSecureClient) StreamConfigEvents(ctx context.Context, in *core.ConfigStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[core.ConfigEvent], error)
- func (m *MockAgentSecureClient) StreamKubeMetadata(ctx context.Context, in *core.KubeMetadataStreamRequest, ...) (grpc.ServerStreamingClient[core.KubeMetadataStreamResponse], error)
- func (m *MockAgentSecureClient) TaggerFetchEntity(ctx context.Context, in *core.FetchEntityRequest, opts ...grpc.CallOption) (*core.FetchEntityResponse, error)
- func (m *MockAgentSecureClient) TaggerGenerateContainerIDFromOriginInfo(ctx context.Context, in *core.GenerateContainerIDFromOriginInfoRequest, ...) (*core.GenerateContainerIDFromOriginInfoResponse, error)
- func (m *MockAgentSecureClient) TaggerStreamEntities(ctx context.Context, in *core.StreamTagsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[core.StreamTagsResponse], error)
- func (m *MockAgentSecureClient) WorkloadFilterEvaluate(ctx context.Context, in *core.WorkloadFilterEvaluateRequest, ...) (*core.WorkloadFilterEvaluateResponse, error)
- func (m *MockAgentSecureClient) WorkloadmetaStreamEntities(ctx context.Context, in *core.WorkloadmetaStreamRequest, ...) (grpc.ServerStreamingClient[core.WorkloadmetaStreamResponse], error)
- type MockAgentSecureClientMockRecorder
- func (mr *MockAgentSecureClientMockRecorder) AutodiscoveryStreamConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) ClientGetConfigs(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) ClientGetConfigsHA(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) CreateConfigSubscription(ctx interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) DogstatsdCaptureTrigger(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) DogstatsdSetTaggerState(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) GetConfigState(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) GetConfigStateHA(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) GetHostTags(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) RefreshRemoteAgent(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) RegisterRemoteAgent(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) ResetConfigState(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) StreamConfigEvents(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) StreamKubeMetadata(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) TaggerFetchEntity(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) TaggerGenerateContainerIDFromOriginInfo(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) TaggerStreamEntities(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) WorkloadFilterEvaluate(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentSecureClientMockRecorder) WorkloadmetaStreamEntities(ctx, in interface{}, opts ...interface{}) *gomock.Call
- type MockAgentSecureServer
- func (m *MockAgentSecureServer) AutodiscoveryStreamConfig(arg0 *emptypb.Empty, ...) error
- func (m *MockAgentSecureServer) ClientGetConfigs(arg0 context.Context, arg1 *core.ClientGetConfigsRequest) (*core.ClientGetConfigsResponse, error)
- func (m *MockAgentSecureServer) ClientGetConfigsHA(arg0 context.Context, arg1 *core.ClientGetConfigsRequest) (*core.ClientGetConfigsResponse, error)
- func (m *MockAgentSecureServer) CreateConfigSubscription(...) error
- func (m *MockAgentSecureServer) DogstatsdCaptureTrigger(arg0 context.Context, arg1 *core.CaptureTriggerRequest) (*core.CaptureTriggerResponse, error)
- func (m *MockAgentSecureServer) DogstatsdSetTaggerState(arg0 context.Context, arg1 *core.TaggerState) (*core.TaggerStateResponse, error)
- func (m *MockAgentSecureServer) EXPECT() *MockAgentSecureServerMockRecorder
- func (m *MockAgentSecureServer) GetConfigState(arg0 context.Context, arg1 *emptypb.Empty) (*core.GetStateConfigResponse, error)
- func (m *MockAgentSecureServer) GetConfigStateHA(arg0 context.Context, arg1 *emptypb.Empty) (*core.GetStateConfigResponse, error)
- func (m *MockAgentSecureServer) GetHostTags(arg0 context.Context, arg1 *core.HostTagRequest) (*core.HostTagReply, error)
- func (m *MockAgentSecureServer) RefreshRemoteAgent(arg0 context.Context, arg1 *core.RefreshRemoteAgentRequest) (*core.RefreshRemoteAgentResponse, error)
- func (m *MockAgentSecureServer) RegisterRemoteAgent(arg0 context.Context, arg1 *core.RegisterRemoteAgentRequest) (*core.RegisterRemoteAgentResponse, error)
- func (m *MockAgentSecureServer) ResetConfigState(arg0 context.Context, arg1 *emptypb.Empty) (*core.ResetStateConfigResponse, error)
- func (m *MockAgentSecureServer) StreamConfigEvents(arg0 *core.ConfigStreamRequest, ...) error
- func (m *MockAgentSecureServer) StreamKubeMetadata(arg0 *core.KubeMetadataStreamRequest, ...) error
- func (m *MockAgentSecureServer) TaggerFetchEntity(arg0 context.Context, arg1 *core.FetchEntityRequest) (*core.FetchEntityResponse, error)
- func (m *MockAgentSecureServer) TaggerGenerateContainerIDFromOriginInfo(arg0 context.Context, arg1 *core.GenerateContainerIDFromOriginInfoRequest) (*core.GenerateContainerIDFromOriginInfoResponse, error)
- func (m *MockAgentSecureServer) TaggerStreamEntities(arg0 *core.StreamTagsRequest, ...) error
- func (m *MockAgentSecureServer) WorkloadFilterEvaluate(arg0 context.Context, arg1 *core.WorkloadFilterEvaluateRequest) (*core.WorkloadFilterEvaluateResponse, error)
- func (m *MockAgentSecureServer) WorkloadmetaStreamEntities(arg0 *core.WorkloadmetaStreamRequest, ...) error
- type MockAgentSecureServerMockRecorder
- func (mr *MockAgentSecureServerMockRecorder) AutodiscoveryStreamConfig(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) ClientGetConfigs(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) ClientGetConfigsHA(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) CreateConfigSubscription(arg0 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) DogstatsdCaptureTrigger(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) DogstatsdSetTaggerState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) GetConfigState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) GetConfigStateHA(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) GetHostTags(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) RefreshRemoteAgent(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) RegisterRemoteAgent(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) ResetConfigState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) StreamConfigEvents(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) StreamKubeMetadata(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) TaggerFetchEntity(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) TaggerGenerateContainerIDFromOriginInfo(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) TaggerStreamEntities(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) WorkloadFilterEvaluate(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentSecureServerMockRecorder) WorkloadmetaStreamEntities(arg0, arg1 interface{}) *gomock.Call
- type MockAgentServer
- type MockAgentServerMockRecorder
- type MockUnsafeAgentSecureServer
- type MockUnsafeAgentSecureServerMockRecorder
- type MockUnsafeAgentServer
- type MockUnsafeAgentServerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAgentClient ¶
type MockAgentClient struct {
// contains filtered or unexported fields
}
MockAgentClient is a mock of AgentClient interface.
func NewMockAgentClient ¶
func NewMockAgentClient(ctrl *gomock.Controller) *MockAgentClient
NewMockAgentClient creates a new mock instance.
func (*MockAgentClient) EXPECT ¶
func (m *MockAgentClient) EXPECT() *MockAgentClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAgentClient) GetHostname ¶
func (m *MockAgentClient) GetHostname(ctx context.Context, in *core.HostnameRequest, opts ...grpc.CallOption) (*core.HostnameReply, error)
GetHostname mocks base method.
type MockAgentClientMockRecorder ¶
type MockAgentClientMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentClientMockRecorder is the mock recorder for MockAgentClient.
func (*MockAgentClientMockRecorder) GetHostname ¶
func (mr *MockAgentClientMockRecorder) GetHostname(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetHostname indicates an expected call of GetHostname.
type MockAgentSecureClient ¶
type MockAgentSecureClient struct {
// contains filtered or unexported fields
}
MockAgentSecureClient is a mock of AgentSecureClient interface.
func NewMockAgentSecureClient ¶
func NewMockAgentSecureClient(ctrl *gomock.Controller) *MockAgentSecureClient
NewMockAgentSecureClient creates a new mock instance.
func (*MockAgentSecureClient) AutodiscoveryStreamConfig ¶ added in v0.62.0
func (m *MockAgentSecureClient) AutodiscoveryStreamConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[core.AutodiscoveryStreamResponse], error)
AutodiscoveryStreamConfig mocks base method.
func (*MockAgentSecureClient) ClientGetConfigs ¶
func (m *MockAgentSecureClient) ClientGetConfigs(ctx context.Context, in *core.ClientGetConfigsRequest, opts ...grpc.CallOption) (*core.ClientGetConfigsResponse, error)
ClientGetConfigs mocks base method.
func (*MockAgentSecureClient) ClientGetConfigsHA ¶ added in v0.52.0
func (m *MockAgentSecureClient) ClientGetConfigsHA(ctx context.Context, in *core.ClientGetConfigsRequest, opts ...grpc.CallOption) (*core.ClientGetConfigsResponse, error)
ClientGetConfigsHA mocks base method.
func (*MockAgentSecureClient) CreateConfigSubscription ¶ added in v0.73.0
func (m *MockAgentSecureClient) CreateConfigSubscription(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[core.ConfigSubscriptionRequest, core.ConfigSubscriptionResponse], error)
CreateConfigSubscription mocks base method.
func (*MockAgentSecureClient) DogstatsdCaptureTrigger ¶
func (m *MockAgentSecureClient) DogstatsdCaptureTrigger(ctx context.Context, in *core.CaptureTriggerRequest, opts ...grpc.CallOption) (*core.CaptureTriggerResponse, error)
DogstatsdCaptureTrigger mocks base method.
func (*MockAgentSecureClient) DogstatsdSetTaggerState ¶
func (m *MockAgentSecureClient) DogstatsdSetTaggerState(ctx context.Context, in *core.TaggerState, opts ...grpc.CallOption) (*core.TaggerStateResponse, error)
DogstatsdSetTaggerState mocks base method.
func (*MockAgentSecureClient) EXPECT ¶
func (m *MockAgentSecureClient) EXPECT() *MockAgentSecureClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAgentSecureClient) GetConfigState ¶
func (m *MockAgentSecureClient) GetConfigState(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*core.GetStateConfigResponse, error)
GetConfigState mocks base method.
func (*MockAgentSecureClient) GetConfigStateHA ¶ added in v0.52.0
func (m *MockAgentSecureClient) GetConfigStateHA(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*core.GetStateConfigResponse, error)
GetConfigStateHA mocks base method.
func (*MockAgentSecureClient) GetHostTags ¶ added in v0.63.0
func (m *MockAgentSecureClient) GetHostTags(ctx context.Context, in *core.HostTagRequest, opts ...grpc.CallOption) (*core.HostTagReply, error)
GetHostTags mocks base method.
func (*MockAgentSecureClient) RefreshRemoteAgent ¶ added in v0.73.0
func (m *MockAgentSecureClient) RefreshRemoteAgent(ctx context.Context, in *core.RefreshRemoteAgentRequest, opts ...grpc.CallOption) (*core.RefreshRemoteAgentResponse, error)
RefreshRemoteAgent mocks base method.
func (*MockAgentSecureClient) RegisterRemoteAgent ¶ added in v0.61.0
func (m *MockAgentSecureClient) RegisterRemoteAgent(ctx context.Context, in *core.RegisterRemoteAgentRequest, opts ...grpc.CallOption) (*core.RegisterRemoteAgentResponse, error)
RegisterRemoteAgent mocks base method.
func (*MockAgentSecureClient) ResetConfigState ¶ added in v0.70.0
func (m *MockAgentSecureClient) ResetConfigState(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*core.ResetStateConfigResponse, error)
ResetConfigState mocks base method.
func (*MockAgentSecureClient) StreamConfigEvents ¶ added in v0.71.0
func (m *MockAgentSecureClient) StreamConfigEvents(ctx context.Context, in *core.ConfigStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[core.ConfigEvent], error)
StreamConfigEvents mocks base method.
func (*MockAgentSecureClient) StreamKubeMetadata ¶ added in v0.78.0
func (m *MockAgentSecureClient) StreamKubeMetadata(ctx context.Context, in *core.KubeMetadataStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[core.KubeMetadataStreamResponse], error)
StreamKubeMetadata mocks base method.
func (*MockAgentSecureClient) TaggerFetchEntity ¶
func (m *MockAgentSecureClient) TaggerFetchEntity(ctx context.Context, in *core.FetchEntityRequest, opts ...grpc.CallOption) (*core.FetchEntityResponse, error)
TaggerFetchEntity mocks base method.
func (*MockAgentSecureClient) TaggerGenerateContainerIDFromOriginInfo ¶ added in v0.62.0
func (m *MockAgentSecureClient) TaggerGenerateContainerIDFromOriginInfo(ctx context.Context, in *core.GenerateContainerIDFromOriginInfoRequest, opts ...grpc.CallOption) (*core.GenerateContainerIDFromOriginInfoResponse, error)
TaggerGenerateContainerIDFromOriginInfo mocks base method.
func (*MockAgentSecureClient) TaggerStreamEntities ¶
func (m *MockAgentSecureClient) TaggerStreamEntities(ctx context.Context, in *core.StreamTagsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[core.StreamTagsResponse], error)
TaggerStreamEntities mocks base method.
func (*MockAgentSecureClient) WorkloadFilterEvaluate ¶ added in v0.75.0
func (m *MockAgentSecureClient) WorkloadFilterEvaluate(ctx context.Context, in *core.WorkloadFilterEvaluateRequest, opts ...grpc.CallOption) (*core.WorkloadFilterEvaluateResponse, error)
WorkloadFilterEvaluate mocks base method.
func (*MockAgentSecureClient) WorkloadmetaStreamEntities ¶
func (m *MockAgentSecureClient) WorkloadmetaStreamEntities(ctx context.Context, in *core.WorkloadmetaStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[core.WorkloadmetaStreamResponse], error)
WorkloadmetaStreamEntities mocks base method.
type MockAgentSecureClientMockRecorder ¶
type MockAgentSecureClientMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentSecureClientMockRecorder is the mock recorder for MockAgentSecureClient.
func (*MockAgentSecureClientMockRecorder) AutodiscoveryStreamConfig ¶ added in v0.62.0
func (mr *MockAgentSecureClientMockRecorder) AutodiscoveryStreamConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call
AutodiscoveryStreamConfig indicates an expected call of AutodiscoveryStreamConfig.
func (*MockAgentSecureClientMockRecorder) ClientGetConfigs ¶
func (mr *MockAgentSecureClientMockRecorder) ClientGetConfigs(ctx, in interface{}, opts ...interface{}) *gomock.Call
ClientGetConfigs indicates an expected call of ClientGetConfigs.
func (*MockAgentSecureClientMockRecorder) ClientGetConfigsHA ¶ added in v0.52.0
func (mr *MockAgentSecureClientMockRecorder) ClientGetConfigsHA(ctx, in interface{}, opts ...interface{}) *gomock.Call
ClientGetConfigsHA indicates an expected call of ClientGetConfigsHA.
func (*MockAgentSecureClientMockRecorder) CreateConfigSubscription ¶ added in v0.73.0
func (mr *MockAgentSecureClientMockRecorder) CreateConfigSubscription(ctx interface{}, opts ...interface{}) *gomock.Call
CreateConfigSubscription indicates an expected call of CreateConfigSubscription.
func (*MockAgentSecureClientMockRecorder) DogstatsdCaptureTrigger ¶
func (mr *MockAgentSecureClientMockRecorder) DogstatsdCaptureTrigger(ctx, in interface{}, opts ...interface{}) *gomock.Call
DogstatsdCaptureTrigger indicates an expected call of DogstatsdCaptureTrigger.
func (*MockAgentSecureClientMockRecorder) DogstatsdSetTaggerState ¶
func (mr *MockAgentSecureClientMockRecorder) DogstatsdSetTaggerState(ctx, in interface{}, opts ...interface{}) *gomock.Call
DogstatsdSetTaggerState indicates an expected call of DogstatsdSetTaggerState.
func (*MockAgentSecureClientMockRecorder) GetConfigState ¶
func (mr *MockAgentSecureClientMockRecorder) GetConfigState(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetConfigState indicates an expected call of GetConfigState.
func (*MockAgentSecureClientMockRecorder) GetConfigStateHA ¶ added in v0.52.0
func (mr *MockAgentSecureClientMockRecorder) GetConfigStateHA(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetConfigStateHA indicates an expected call of GetConfigStateHA.
func (*MockAgentSecureClientMockRecorder) GetHostTags ¶ added in v0.63.0
func (mr *MockAgentSecureClientMockRecorder) GetHostTags(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetHostTags indicates an expected call of GetHostTags.
func (*MockAgentSecureClientMockRecorder) RefreshRemoteAgent ¶ added in v0.73.0
func (mr *MockAgentSecureClientMockRecorder) RefreshRemoteAgent(ctx, in interface{}, opts ...interface{}) *gomock.Call
RefreshRemoteAgent indicates an expected call of RefreshRemoteAgent.
func (*MockAgentSecureClientMockRecorder) RegisterRemoteAgent ¶ added in v0.61.0
func (mr *MockAgentSecureClientMockRecorder) RegisterRemoteAgent(ctx, in interface{}, opts ...interface{}) *gomock.Call
RegisterRemoteAgent indicates an expected call of RegisterRemoteAgent.
func (*MockAgentSecureClientMockRecorder) ResetConfigState ¶ added in v0.70.0
func (mr *MockAgentSecureClientMockRecorder) ResetConfigState(ctx, in interface{}, opts ...interface{}) *gomock.Call
ResetConfigState indicates an expected call of ResetConfigState.
func (*MockAgentSecureClientMockRecorder) StreamConfigEvents ¶ added in v0.71.0
func (mr *MockAgentSecureClientMockRecorder) StreamConfigEvents(ctx, in interface{}, opts ...interface{}) *gomock.Call
StreamConfigEvents indicates an expected call of StreamConfigEvents.
func (*MockAgentSecureClientMockRecorder) StreamKubeMetadata ¶ added in v0.78.0
func (mr *MockAgentSecureClientMockRecorder) StreamKubeMetadata(ctx, in interface{}, opts ...interface{}) *gomock.Call
StreamKubeMetadata indicates an expected call of StreamKubeMetadata.
func (*MockAgentSecureClientMockRecorder) TaggerFetchEntity ¶
func (mr *MockAgentSecureClientMockRecorder) TaggerFetchEntity(ctx, in interface{}, opts ...interface{}) *gomock.Call
TaggerFetchEntity indicates an expected call of TaggerFetchEntity.
func (*MockAgentSecureClientMockRecorder) TaggerGenerateContainerIDFromOriginInfo ¶ added in v0.62.0
func (mr *MockAgentSecureClientMockRecorder) TaggerGenerateContainerIDFromOriginInfo(ctx, in interface{}, opts ...interface{}) *gomock.Call
TaggerGenerateContainerIDFromOriginInfo indicates an expected call of TaggerGenerateContainerIDFromOriginInfo.
func (*MockAgentSecureClientMockRecorder) TaggerStreamEntities ¶
func (mr *MockAgentSecureClientMockRecorder) TaggerStreamEntities(ctx, in interface{}, opts ...interface{}) *gomock.Call
TaggerStreamEntities indicates an expected call of TaggerStreamEntities.
func (*MockAgentSecureClientMockRecorder) WorkloadFilterEvaluate ¶ added in v0.75.0
func (mr *MockAgentSecureClientMockRecorder) WorkloadFilterEvaluate(ctx, in interface{}, opts ...interface{}) *gomock.Call
WorkloadFilterEvaluate indicates an expected call of WorkloadFilterEvaluate.
func (*MockAgentSecureClientMockRecorder) WorkloadmetaStreamEntities ¶
func (mr *MockAgentSecureClientMockRecorder) WorkloadmetaStreamEntities(ctx, in interface{}, opts ...interface{}) *gomock.Call
WorkloadmetaStreamEntities indicates an expected call of WorkloadmetaStreamEntities.
type MockAgentSecureServer ¶
type MockAgentSecureServer struct {
// contains filtered or unexported fields
}
MockAgentSecureServer is a mock of AgentSecureServer interface.
func NewMockAgentSecureServer ¶
func NewMockAgentSecureServer(ctrl *gomock.Controller) *MockAgentSecureServer
NewMockAgentSecureServer creates a new mock instance.
func (*MockAgentSecureServer) AutodiscoveryStreamConfig ¶ added in v0.62.0
func (m *MockAgentSecureServer) AutodiscoveryStreamConfig(arg0 *emptypb.Empty, arg1 grpc.ServerStreamingServer[core.AutodiscoveryStreamResponse]) error
AutodiscoveryStreamConfig mocks base method.
func (*MockAgentSecureServer) ClientGetConfigs ¶
func (m *MockAgentSecureServer) ClientGetConfigs(arg0 context.Context, arg1 *core.ClientGetConfigsRequest) (*core.ClientGetConfigsResponse, error)
ClientGetConfigs mocks base method.
func (*MockAgentSecureServer) ClientGetConfigsHA ¶ added in v0.52.0
func (m *MockAgentSecureServer) ClientGetConfigsHA(arg0 context.Context, arg1 *core.ClientGetConfigsRequest) (*core.ClientGetConfigsResponse, error)
ClientGetConfigsHA mocks base method.
func (*MockAgentSecureServer) CreateConfigSubscription ¶ added in v0.73.0
func (m *MockAgentSecureServer) CreateConfigSubscription(arg0 grpc.BidiStreamingServer[core.ConfigSubscriptionRequest, core.ConfigSubscriptionResponse]) error
CreateConfigSubscription mocks base method.
func (*MockAgentSecureServer) DogstatsdCaptureTrigger ¶
func (m *MockAgentSecureServer) DogstatsdCaptureTrigger(arg0 context.Context, arg1 *core.CaptureTriggerRequest) (*core.CaptureTriggerResponse, error)
DogstatsdCaptureTrigger mocks base method.
func (*MockAgentSecureServer) DogstatsdSetTaggerState ¶
func (m *MockAgentSecureServer) DogstatsdSetTaggerState(arg0 context.Context, arg1 *core.TaggerState) (*core.TaggerStateResponse, error)
DogstatsdSetTaggerState mocks base method.
func (*MockAgentSecureServer) EXPECT ¶
func (m *MockAgentSecureServer) EXPECT() *MockAgentSecureServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAgentSecureServer) GetConfigState ¶
func (m *MockAgentSecureServer) GetConfigState(arg0 context.Context, arg1 *emptypb.Empty) (*core.GetStateConfigResponse, error)
GetConfigState mocks base method.
func (*MockAgentSecureServer) GetConfigStateHA ¶ added in v0.52.0
func (m *MockAgentSecureServer) GetConfigStateHA(arg0 context.Context, arg1 *emptypb.Empty) (*core.GetStateConfigResponse, error)
GetConfigStateHA mocks base method.
func (*MockAgentSecureServer) GetHostTags ¶ added in v0.63.0
func (m *MockAgentSecureServer) GetHostTags(arg0 context.Context, arg1 *core.HostTagRequest) (*core.HostTagReply, error)
GetHostTags mocks base method.
func (*MockAgentSecureServer) RefreshRemoteAgent ¶ added in v0.73.0
func (m *MockAgentSecureServer) RefreshRemoteAgent(arg0 context.Context, arg1 *core.RefreshRemoteAgentRequest) (*core.RefreshRemoteAgentResponse, error)
RefreshRemoteAgent mocks base method.
func (*MockAgentSecureServer) RegisterRemoteAgent ¶ added in v0.61.0
func (m *MockAgentSecureServer) RegisterRemoteAgent(arg0 context.Context, arg1 *core.RegisterRemoteAgentRequest) (*core.RegisterRemoteAgentResponse, error)
RegisterRemoteAgent mocks base method.
func (*MockAgentSecureServer) ResetConfigState ¶ added in v0.70.0
func (m *MockAgentSecureServer) ResetConfigState(arg0 context.Context, arg1 *emptypb.Empty) (*core.ResetStateConfigResponse, error)
ResetConfigState mocks base method.
func (*MockAgentSecureServer) StreamConfigEvents ¶ added in v0.71.0
func (m *MockAgentSecureServer) StreamConfigEvents(arg0 *core.ConfigStreamRequest, arg1 grpc.ServerStreamingServer[core.ConfigEvent]) error
StreamConfigEvents mocks base method.
func (*MockAgentSecureServer) StreamKubeMetadata ¶ added in v0.78.0
func (m *MockAgentSecureServer) StreamKubeMetadata(arg0 *core.KubeMetadataStreamRequest, arg1 grpc.ServerStreamingServer[core.KubeMetadataStreamResponse]) error
StreamKubeMetadata mocks base method.
func (*MockAgentSecureServer) TaggerFetchEntity ¶
func (m *MockAgentSecureServer) TaggerFetchEntity(arg0 context.Context, arg1 *core.FetchEntityRequest) (*core.FetchEntityResponse, error)
TaggerFetchEntity mocks base method.
func (*MockAgentSecureServer) TaggerGenerateContainerIDFromOriginInfo ¶ added in v0.62.0
func (m *MockAgentSecureServer) TaggerGenerateContainerIDFromOriginInfo(arg0 context.Context, arg1 *core.GenerateContainerIDFromOriginInfoRequest) (*core.GenerateContainerIDFromOriginInfoResponse, error)
TaggerGenerateContainerIDFromOriginInfo mocks base method.
func (*MockAgentSecureServer) TaggerStreamEntities ¶
func (m *MockAgentSecureServer) TaggerStreamEntities(arg0 *core.StreamTagsRequest, arg1 grpc.ServerStreamingServer[core.StreamTagsResponse]) error
TaggerStreamEntities mocks base method.
func (*MockAgentSecureServer) WorkloadFilterEvaluate ¶ added in v0.75.0
func (m *MockAgentSecureServer) WorkloadFilterEvaluate(arg0 context.Context, arg1 *core.WorkloadFilterEvaluateRequest) (*core.WorkloadFilterEvaluateResponse, error)
WorkloadFilterEvaluate mocks base method.
func (*MockAgentSecureServer) WorkloadmetaStreamEntities ¶
func (m *MockAgentSecureServer) WorkloadmetaStreamEntities(arg0 *core.WorkloadmetaStreamRequest, arg1 grpc.ServerStreamingServer[core.WorkloadmetaStreamResponse]) error
WorkloadmetaStreamEntities mocks base method.
type MockAgentSecureServerMockRecorder ¶
type MockAgentSecureServerMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentSecureServerMockRecorder is the mock recorder for MockAgentSecureServer.
func (*MockAgentSecureServerMockRecorder) AutodiscoveryStreamConfig ¶ added in v0.62.0
func (mr *MockAgentSecureServerMockRecorder) AutodiscoveryStreamConfig(arg0, arg1 interface{}) *gomock.Call
AutodiscoveryStreamConfig indicates an expected call of AutodiscoveryStreamConfig.
func (*MockAgentSecureServerMockRecorder) ClientGetConfigs ¶
func (mr *MockAgentSecureServerMockRecorder) ClientGetConfigs(arg0, arg1 interface{}) *gomock.Call
ClientGetConfigs indicates an expected call of ClientGetConfigs.
func (*MockAgentSecureServerMockRecorder) ClientGetConfigsHA ¶ added in v0.52.0
func (mr *MockAgentSecureServerMockRecorder) ClientGetConfigsHA(arg0, arg1 interface{}) *gomock.Call
ClientGetConfigsHA indicates an expected call of ClientGetConfigsHA.
func (*MockAgentSecureServerMockRecorder) CreateConfigSubscription ¶ added in v0.73.0
func (mr *MockAgentSecureServerMockRecorder) CreateConfigSubscription(arg0 interface{}) *gomock.Call
CreateConfigSubscription indicates an expected call of CreateConfigSubscription.
func (*MockAgentSecureServerMockRecorder) DogstatsdCaptureTrigger ¶
func (mr *MockAgentSecureServerMockRecorder) DogstatsdCaptureTrigger(arg0, arg1 interface{}) *gomock.Call
DogstatsdCaptureTrigger indicates an expected call of DogstatsdCaptureTrigger.
func (*MockAgentSecureServerMockRecorder) DogstatsdSetTaggerState ¶
func (mr *MockAgentSecureServerMockRecorder) DogstatsdSetTaggerState(arg0, arg1 interface{}) *gomock.Call
DogstatsdSetTaggerState indicates an expected call of DogstatsdSetTaggerState.
func (*MockAgentSecureServerMockRecorder) GetConfigState ¶
func (mr *MockAgentSecureServerMockRecorder) GetConfigState(arg0, arg1 interface{}) *gomock.Call
GetConfigState indicates an expected call of GetConfigState.
func (*MockAgentSecureServerMockRecorder) GetConfigStateHA ¶ added in v0.52.0
func (mr *MockAgentSecureServerMockRecorder) GetConfigStateHA(arg0, arg1 interface{}) *gomock.Call
GetConfigStateHA indicates an expected call of GetConfigStateHA.
func (*MockAgentSecureServerMockRecorder) GetHostTags ¶ added in v0.63.0
func (mr *MockAgentSecureServerMockRecorder) GetHostTags(arg0, arg1 interface{}) *gomock.Call
GetHostTags indicates an expected call of GetHostTags.
func (*MockAgentSecureServerMockRecorder) RefreshRemoteAgent ¶ added in v0.73.0
func (mr *MockAgentSecureServerMockRecorder) RefreshRemoteAgent(arg0, arg1 interface{}) *gomock.Call
RefreshRemoteAgent indicates an expected call of RefreshRemoteAgent.
func (*MockAgentSecureServerMockRecorder) RegisterRemoteAgent ¶ added in v0.61.0
func (mr *MockAgentSecureServerMockRecorder) RegisterRemoteAgent(arg0, arg1 interface{}) *gomock.Call
RegisterRemoteAgent indicates an expected call of RegisterRemoteAgent.
func (*MockAgentSecureServerMockRecorder) ResetConfigState ¶ added in v0.70.0
func (mr *MockAgentSecureServerMockRecorder) ResetConfigState(arg0, arg1 interface{}) *gomock.Call
ResetConfigState indicates an expected call of ResetConfigState.
func (*MockAgentSecureServerMockRecorder) StreamConfigEvents ¶ added in v0.71.0
func (mr *MockAgentSecureServerMockRecorder) StreamConfigEvents(arg0, arg1 interface{}) *gomock.Call
StreamConfigEvents indicates an expected call of StreamConfigEvents.
func (*MockAgentSecureServerMockRecorder) StreamKubeMetadata ¶ added in v0.78.0
func (mr *MockAgentSecureServerMockRecorder) StreamKubeMetadata(arg0, arg1 interface{}) *gomock.Call
StreamKubeMetadata indicates an expected call of StreamKubeMetadata.
func (*MockAgentSecureServerMockRecorder) TaggerFetchEntity ¶
func (mr *MockAgentSecureServerMockRecorder) TaggerFetchEntity(arg0, arg1 interface{}) *gomock.Call
TaggerFetchEntity indicates an expected call of TaggerFetchEntity.
func (*MockAgentSecureServerMockRecorder) TaggerGenerateContainerIDFromOriginInfo ¶ added in v0.62.0
func (mr *MockAgentSecureServerMockRecorder) TaggerGenerateContainerIDFromOriginInfo(arg0, arg1 interface{}) *gomock.Call
TaggerGenerateContainerIDFromOriginInfo indicates an expected call of TaggerGenerateContainerIDFromOriginInfo.
func (*MockAgentSecureServerMockRecorder) TaggerStreamEntities ¶
func (mr *MockAgentSecureServerMockRecorder) TaggerStreamEntities(arg0, arg1 interface{}) *gomock.Call
TaggerStreamEntities indicates an expected call of TaggerStreamEntities.
func (*MockAgentSecureServerMockRecorder) WorkloadFilterEvaluate ¶ added in v0.75.0
func (mr *MockAgentSecureServerMockRecorder) WorkloadFilterEvaluate(arg0, arg1 interface{}) *gomock.Call
WorkloadFilterEvaluate indicates an expected call of WorkloadFilterEvaluate.
func (*MockAgentSecureServerMockRecorder) WorkloadmetaStreamEntities ¶
func (mr *MockAgentSecureServerMockRecorder) WorkloadmetaStreamEntities(arg0, arg1 interface{}) *gomock.Call
WorkloadmetaStreamEntities indicates an expected call of WorkloadmetaStreamEntities.
type MockAgentServer ¶
type MockAgentServer struct {
// contains filtered or unexported fields
}
MockAgentServer is a mock of AgentServer interface.
func NewMockAgentServer ¶
func NewMockAgentServer(ctrl *gomock.Controller) *MockAgentServer
NewMockAgentServer creates a new mock instance.
func (*MockAgentServer) EXPECT ¶
func (m *MockAgentServer) EXPECT() *MockAgentServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAgentServer) GetHostname ¶
func (m *MockAgentServer) GetHostname(arg0 context.Context, arg1 *core.HostnameRequest) (*core.HostnameReply, error)
GetHostname mocks base method.
type MockAgentServerMockRecorder ¶
type MockAgentServerMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentServerMockRecorder is the mock recorder for MockAgentServer.
func (*MockAgentServerMockRecorder) GetHostname ¶
func (mr *MockAgentServerMockRecorder) GetHostname(arg0, arg1 interface{}) *gomock.Call
GetHostname indicates an expected call of GetHostname.
type MockUnsafeAgentSecureServer ¶ added in v0.76.0
type MockUnsafeAgentSecureServer struct {
// contains filtered or unexported fields
}
MockUnsafeAgentSecureServer is a mock of UnsafeAgentSecureServer interface.
func NewMockUnsafeAgentSecureServer ¶ added in v0.76.0
func NewMockUnsafeAgentSecureServer(ctrl *gomock.Controller) *MockUnsafeAgentSecureServer
NewMockUnsafeAgentSecureServer creates a new mock instance.
func (*MockUnsafeAgentSecureServer) EXPECT ¶ added in v0.76.0
func (m *MockUnsafeAgentSecureServer) EXPECT() *MockUnsafeAgentSecureServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockUnsafeAgentSecureServerMockRecorder ¶ added in v0.76.0
type MockUnsafeAgentSecureServerMockRecorder struct {
// contains filtered or unexported fields
}
MockUnsafeAgentSecureServerMockRecorder is the mock recorder for MockUnsafeAgentSecureServer.
type MockUnsafeAgentServer ¶ added in v0.76.0
type MockUnsafeAgentServer struct {
// contains filtered or unexported fields
}
MockUnsafeAgentServer is a mock of UnsafeAgentServer interface.
func NewMockUnsafeAgentServer ¶ added in v0.76.0
func NewMockUnsafeAgentServer(ctrl *gomock.Controller) *MockUnsafeAgentServer
NewMockUnsafeAgentServer creates a new mock instance.
func (*MockUnsafeAgentServer) EXPECT ¶ added in v0.76.0
func (m *MockUnsafeAgentServer) EXPECT() *MockUnsafeAgentServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockUnsafeAgentServerMockRecorder ¶ added in v0.76.0
type MockUnsafeAgentServerMockRecorder struct {
// contains filtered or unexported fields
}
MockUnsafeAgentServerMockRecorder is the mock recorder for MockUnsafeAgentServer.