Documentation ¶
Overview ¶
Package mock_agent is a generated GoMock package.
Index ¶
- type MockCIDRInfoProvider
- type MockCIDRInfoProviderMockRecorder
- type MockManager
- func (m *MockManager) ApplyAgentUpdate(update *agent.Update) error
- func (m *MockManager) DeleteAgent(arg0 uuid.UUID) error
- func (m *MockManager) DeleteAgentUpdateCursor(cursorID uuid.UUID)
- func (m *MockManager) EXPECT() *MockManagerMockRecorder
- func (m *MockManager) GetActiveAgents() ([]*agentpb.Agent, error)
- func (m *MockManager) GetAgentIDForHostnamePair(hnPair *agent.HostnameIPPair) (string, error)
- func (m *MockManager) GetAgentUpdates(cursorID uuid.UUID) ([]*metadatapb0.AgentUpdate, *storepb.ComputedSchema, error)
- func (m *MockManager) GetComputedSchema() (*storepb.ComputedSchema, error)
- func (m *MockManager) GetPodCIDRs() []string
- func (m *MockManager) GetServiceCIDR() string
- func (m *MockManager) MessageActiveAgents(msg []byte) error
- func (m *MockManager) MessageAgents(agentIDs []uuid.UUID, msg []byte) error
- func (m *MockManager) NewAgentUpdateCursor() uuid.UUID
- func (m *MockManager) RegisterAgent(info *agentpb.Agent) (uint32, error)
- func (m *MockManager) UpdateConfig(arg0, arg1, arg2, arg3 string) error
- func (m *MockManager) UpdateHeartbeat(agentID uuid.UUID) error
- type MockManagerMockRecorder
- func (mr *MockManagerMockRecorder) ApplyAgentUpdate(update interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) DeleteAgent(arg0 interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) DeleteAgentUpdateCursor(cursorID interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) GetActiveAgents() *gomock.Call
- func (mr *MockManagerMockRecorder) GetAgentIDForHostnamePair(hnPair interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) GetAgentUpdates(cursorID interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) GetComputedSchema() *gomock.Call
- func (mr *MockManagerMockRecorder) GetPodCIDRs() *gomock.Call
- func (mr *MockManagerMockRecorder) GetServiceCIDR() *gomock.Call
- func (mr *MockManagerMockRecorder) MessageActiveAgents(msg interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) MessageAgents(agentIDs, msg interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) NewAgentUpdateCursor() *gomock.Call
- func (mr *MockManagerMockRecorder) RegisterAgent(info interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) UpdateConfig(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) UpdateHeartbeat(agentID interface{}) *gomock.Call
- type MockStore
- func (m *MockStore) CreateAgent(agentID uuid.UUID, a *agentpb.Agent) error
- func (m *MockStore) DeleteAgent(agentID uuid.UUID) error
- func (m *MockStore) EXPECT() *MockStoreMockRecorder
- func (m *MockStore) GetASID() (uint32, error)
- func (m *MockStore) GetAgent(agentID uuid.UUID) (*agentpb.Agent, error)
- func (m *MockStore) GetAgentIDForHostnamePair(hnPair *agent.HostnameIPPair) (string, error)
- func (m *MockStore) GetAgentIDFromPodName(podName string) (string, error)
- func (m *MockStore) GetAgents() ([]*agentpb.Agent, error)
- func (m *MockStore) GetAgentsDataInfo() (map[uuid.UUID]*messagespb.AgentDataInfo, error)
- func (m *MockStore) GetComputedSchema() (*storepb.ComputedSchema, error)
- func (m *MockStore) GetProcesses(upids []*gotypes.UInt128) ([]*metadatapb.ProcessInfo, error)
- func (m *MockStore) PruneComputedSchema() error
- func (m *MockStore) UpdateAgent(agentID uuid.UUID, a *agentpb.Agent) error
- func (m *MockStore) UpdateAgentDataInfo(agentID uuid.UUID, dataInfo *messagespb.AgentDataInfo) error
- func (m *MockStore) UpdateProcesses(processes []*metadatapb.ProcessInfo) error
- func (m *MockStore) UpdateSchemas(agentID uuid.UUID, schemas []*storepb.TableInfo) error
- type MockStoreMockRecorder
- func (mr *MockStoreMockRecorder) CreateAgent(agentID, a interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) DeleteAgent(agentID interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) GetASID() *gomock.Call
- func (mr *MockStoreMockRecorder) GetAgent(agentID interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) GetAgentIDForHostnamePair(hnPair interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) GetAgentIDFromPodName(podName interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) GetAgents() *gomock.Call
- func (mr *MockStoreMockRecorder) GetAgentsDataInfo() *gomock.Call
- func (mr *MockStoreMockRecorder) GetComputedSchema() *gomock.Call
- func (mr *MockStoreMockRecorder) GetProcesses(upids interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) PruneComputedSchema() *gomock.Call
- func (mr *MockStoreMockRecorder) UpdateAgent(agentID, a interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) UpdateAgentDataInfo(agentID, dataInfo interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) UpdateProcesses(processes interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) UpdateSchemas(agentID, schemas interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockCIDRInfoProvider ¶
type MockCIDRInfoProvider struct {
// contains filtered or unexported fields
}
MockCIDRInfoProvider is a mock of CIDRInfoProvider interface.
func NewMockCIDRInfoProvider ¶
func NewMockCIDRInfoProvider(ctrl *gomock.Controller) *MockCIDRInfoProvider
NewMockCIDRInfoProvider creates a new mock instance.
func (*MockCIDRInfoProvider) EXPECT ¶
func (m *MockCIDRInfoProvider) EXPECT() *MockCIDRInfoProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCIDRInfoProvider) GetPodCIDRs ¶
func (m *MockCIDRInfoProvider) GetPodCIDRs() []string
GetPodCIDRs mocks base method.
func (*MockCIDRInfoProvider) GetServiceCIDR ¶
func (m *MockCIDRInfoProvider) GetServiceCIDR() string
GetServiceCIDR mocks base method.
type MockCIDRInfoProviderMockRecorder ¶
type MockCIDRInfoProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockCIDRInfoProviderMockRecorder is the mock recorder for MockCIDRInfoProvider.
func (*MockCIDRInfoProviderMockRecorder) GetPodCIDRs ¶
func (mr *MockCIDRInfoProviderMockRecorder) GetPodCIDRs() *gomock.Call
GetPodCIDRs indicates an expected call of GetPodCIDRs.
func (*MockCIDRInfoProviderMockRecorder) GetServiceCIDR ¶
func (mr *MockCIDRInfoProviderMockRecorder) GetServiceCIDR() *gomock.Call
GetServiceCIDR indicates an expected call of GetServiceCIDR.
type MockManager ¶
type MockManager struct {
// contains filtered or unexported fields
}
MockManager is a mock of Manager interface.
func NewMockManager ¶
func NewMockManager(ctrl *gomock.Controller) *MockManager
NewMockManager creates a new mock instance.
func (*MockManager) ApplyAgentUpdate ¶
func (m *MockManager) ApplyAgentUpdate(update *agent.Update) error
ApplyAgentUpdate mocks base method.
func (*MockManager) DeleteAgent ¶
func (m *MockManager) DeleteAgent(arg0 uuid.UUID) error
DeleteAgent mocks base method.
func (*MockManager) DeleteAgentUpdateCursor ¶
func (m *MockManager) DeleteAgentUpdateCursor(cursorID uuid.UUID)
DeleteAgentUpdateCursor mocks base method.
func (*MockManager) EXPECT ¶
func (m *MockManager) EXPECT() *MockManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockManager) GetActiveAgents ¶
func (m *MockManager) GetActiveAgents() ([]*agentpb.Agent, error)
GetActiveAgents mocks base method.
func (*MockManager) GetAgentIDForHostnamePair ¶
func (m *MockManager) GetAgentIDForHostnamePair(hnPair *agent.HostnameIPPair) (string, error)
GetAgentIDForHostnamePair mocks base method.
func (*MockManager) GetAgentUpdates ¶
func (m *MockManager) GetAgentUpdates(cursorID uuid.UUID) ([]*metadatapb0.AgentUpdate, *storepb.ComputedSchema, error)
GetAgentUpdates mocks base method.
func (*MockManager) GetComputedSchema ¶
func (m *MockManager) GetComputedSchema() (*storepb.ComputedSchema, error)
GetComputedSchema mocks base method.
func (*MockManager) GetPodCIDRs ¶
func (m *MockManager) GetPodCIDRs() []string
GetPodCIDRs mocks base method.
func (*MockManager) GetServiceCIDR ¶
func (m *MockManager) GetServiceCIDR() string
GetServiceCIDR mocks base method.
func (*MockManager) MessageActiveAgents ¶
func (m *MockManager) MessageActiveAgents(msg []byte) error
MessageActiveAgents mocks base method.
func (*MockManager) MessageAgents ¶
func (m *MockManager) MessageAgents(agentIDs []uuid.UUID, msg []byte) error
MessageAgents mocks base method.
func (*MockManager) NewAgentUpdateCursor ¶
func (m *MockManager) NewAgentUpdateCursor() uuid.UUID
NewAgentUpdateCursor mocks base method.
func (*MockManager) RegisterAgent ¶
func (m *MockManager) RegisterAgent(info *agentpb.Agent) (uint32, error)
RegisterAgent mocks base method.
func (*MockManager) UpdateConfig ¶
func (m *MockManager) UpdateConfig(arg0, arg1, arg2, arg3 string) error
UpdateConfig mocks base method.
func (*MockManager) UpdateHeartbeat ¶
func (m *MockManager) UpdateHeartbeat(agentID uuid.UUID) error
UpdateHeartbeat mocks base method.
type MockManagerMockRecorder ¶
type MockManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockManagerMockRecorder is the mock recorder for MockManager.
func (*MockManagerMockRecorder) ApplyAgentUpdate ¶
func (mr *MockManagerMockRecorder) ApplyAgentUpdate(update interface{}) *gomock.Call
ApplyAgentUpdate indicates an expected call of ApplyAgentUpdate.
func (*MockManagerMockRecorder) DeleteAgent ¶
func (mr *MockManagerMockRecorder) DeleteAgent(arg0 interface{}) *gomock.Call
DeleteAgent indicates an expected call of DeleteAgent.
func (*MockManagerMockRecorder) DeleteAgentUpdateCursor ¶
func (mr *MockManagerMockRecorder) DeleteAgentUpdateCursor(cursorID interface{}) *gomock.Call
DeleteAgentUpdateCursor indicates an expected call of DeleteAgentUpdateCursor.
func (*MockManagerMockRecorder) GetActiveAgents ¶
func (mr *MockManagerMockRecorder) GetActiveAgents() *gomock.Call
GetActiveAgents indicates an expected call of GetActiveAgents.
func (*MockManagerMockRecorder) GetAgentIDForHostnamePair ¶
func (mr *MockManagerMockRecorder) GetAgentIDForHostnamePair(hnPair interface{}) *gomock.Call
GetAgentIDForHostnamePair indicates an expected call of GetAgentIDForHostnamePair.
func (*MockManagerMockRecorder) GetAgentUpdates ¶
func (mr *MockManagerMockRecorder) GetAgentUpdates(cursorID interface{}) *gomock.Call
GetAgentUpdates indicates an expected call of GetAgentUpdates.
func (*MockManagerMockRecorder) GetComputedSchema ¶
func (mr *MockManagerMockRecorder) GetComputedSchema() *gomock.Call
GetComputedSchema indicates an expected call of GetComputedSchema.
func (*MockManagerMockRecorder) GetPodCIDRs ¶
func (mr *MockManagerMockRecorder) GetPodCIDRs() *gomock.Call
GetPodCIDRs indicates an expected call of GetPodCIDRs.
func (*MockManagerMockRecorder) GetServiceCIDR ¶
func (mr *MockManagerMockRecorder) GetServiceCIDR() *gomock.Call
GetServiceCIDR indicates an expected call of GetServiceCIDR.
func (*MockManagerMockRecorder) MessageActiveAgents ¶
func (mr *MockManagerMockRecorder) MessageActiveAgents(msg interface{}) *gomock.Call
MessageActiveAgents indicates an expected call of MessageActiveAgents.
func (*MockManagerMockRecorder) MessageAgents ¶
func (mr *MockManagerMockRecorder) MessageAgents(agentIDs, msg interface{}) *gomock.Call
MessageAgents indicates an expected call of MessageAgents.
func (*MockManagerMockRecorder) NewAgentUpdateCursor ¶
func (mr *MockManagerMockRecorder) NewAgentUpdateCursor() *gomock.Call
NewAgentUpdateCursor indicates an expected call of NewAgentUpdateCursor.
func (*MockManagerMockRecorder) RegisterAgent ¶
func (mr *MockManagerMockRecorder) RegisterAgent(info interface{}) *gomock.Call
RegisterAgent indicates an expected call of RegisterAgent.
func (*MockManagerMockRecorder) UpdateConfig ¶
func (mr *MockManagerMockRecorder) UpdateConfig(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
UpdateConfig indicates an expected call of UpdateConfig.
func (*MockManagerMockRecorder) UpdateHeartbeat ¶
func (mr *MockManagerMockRecorder) UpdateHeartbeat(agentID interface{}) *gomock.Call
UpdateHeartbeat indicates an expected call of UpdateHeartbeat.
type MockStore ¶
type MockStore struct {
// contains filtered or unexported fields
}
MockStore is a mock of Store interface.
func NewMockStore ¶
func NewMockStore(ctrl *gomock.Controller) *MockStore
NewMockStore creates a new mock instance.
func (*MockStore) CreateAgent ¶
CreateAgent mocks base method.
func (*MockStore) DeleteAgent ¶
DeleteAgent mocks base method.
func (*MockStore) EXPECT ¶
func (m *MockStore) EXPECT() *MockStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStore) GetAgentIDForHostnamePair ¶
func (m *MockStore) GetAgentIDForHostnamePair(hnPair *agent.HostnameIPPair) (string, error)
GetAgentIDForHostnamePair mocks base method.
func (*MockStore) GetAgentIDFromPodName ¶
GetAgentIDFromPodName mocks base method.
func (*MockStore) GetAgentsDataInfo ¶
func (m *MockStore) GetAgentsDataInfo() (map[uuid.UUID]*messagespb.AgentDataInfo, error)
GetAgentsDataInfo mocks base method.
func (*MockStore) GetComputedSchema ¶
func (m *MockStore) GetComputedSchema() (*storepb.ComputedSchema, error)
GetComputedSchema mocks base method.
func (*MockStore) GetProcesses ¶
func (m *MockStore) GetProcesses(upids []*gotypes.UInt128) ([]*metadatapb.ProcessInfo, error)
GetProcesses mocks base method.
func (*MockStore) PruneComputedSchema ¶
PruneComputedSchema mocks base method.
func (*MockStore) UpdateAgent ¶
UpdateAgent mocks base method.
func (*MockStore) UpdateAgentDataInfo ¶
func (m *MockStore) UpdateAgentDataInfo(agentID uuid.UUID, dataInfo *messagespb.AgentDataInfo) error
UpdateAgentDataInfo mocks base method.
func (*MockStore) UpdateProcesses ¶
func (m *MockStore) UpdateProcesses(processes []*metadatapb.ProcessInfo) error
UpdateProcesses mocks base method.
type MockStoreMockRecorder ¶
type MockStoreMockRecorder struct {
// contains filtered or unexported fields
}
MockStoreMockRecorder is the mock recorder for MockStore.
func (*MockStoreMockRecorder) CreateAgent ¶
func (mr *MockStoreMockRecorder) CreateAgent(agentID, a interface{}) *gomock.Call
CreateAgent indicates an expected call of CreateAgent.
func (*MockStoreMockRecorder) DeleteAgent ¶
func (mr *MockStoreMockRecorder) DeleteAgent(agentID interface{}) *gomock.Call
DeleteAgent indicates an expected call of DeleteAgent.
func (*MockStoreMockRecorder) GetASID ¶
func (mr *MockStoreMockRecorder) GetASID() *gomock.Call
GetASID indicates an expected call of GetASID.
func (*MockStoreMockRecorder) GetAgent ¶
func (mr *MockStoreMockRecorder) GetAgent(agentID interface{}) *gomock.Call
GetAgent indicates an expected call of GetAgent.
func (*MockStoreMockRecorder) GetAgentIDForHostnamePair ¶
func (mr *MockStoreMockRecorder) GetAgentIDForHostnamePair(hnPair interface{}) *gomock.Call
GetAgentIDForHostnamePair indicates an expected call of GetAgentIDForHostnamePair.
func (*MockStoreMockRecorder) GetAgentIDFromPodName ¶
func (mr *MockStoreMockRecorder) GetAgentIDFromPodName(podName interface{}) *gomock.Call
GetAgentIDFromPodName indicates an expected call of GetAgentIDFromPodName.
func (*MockStoreMockRecorder) GetAgents ¶
func (mr *MockStoreMockRecorder) GetAgents() *gomock.Call
GetAgents indicates an expected call of GetAgents.
func (*MockStoreMockRecorder) GetAgentsDataInfo ¶
func (mr *MockStoreMockRecorder) GetAgentsDataInfo() *gomock.Call
GetAgentsDataInfo indicates an expected call of GetAgentsDataInfo.
func (*MockStoreMockRecorder) GetComputedSchema ¶
func (mr *MockStoreMockRecorder) GetComputedSchema() *gomock.Call
GetComputedSchema indicates an expected call of GetComputedSchema.
func (*MockStoreMockRecorder) GetProcesses ¶
func (mr *MockStoreMockRecorder) GetProcesses(upids interface{}) *gomock.Call
GetProcesses indicates an expected call of GetProcesses.
func (*MockStoreMockRecorder) PruneComputedSchema ¶
func (mr *MockStoreMockRecorder) PruneComputedSchema() *gomock.Call
PruneComputedSchema indicates an expected call of PruneComputedSchema.
func (*MockStoreMockRecorder) UpdateAgent ¶
func (mr *MockStoreMockRecorder) UpdateAgent(agentID, a interface{}) *gomock.Call
UpdateAgent indicates an expected call of UpdateAgent.
func (*MockStoreMockRecorder) UpdateAgentDataInfo ¶
func (mr *MockStoreMockRecorder) UpdateAgentDataInfo(agentID, dataInfo interface{}) *gomock.Call
UpdateAgentDataInfo indicates an expected call of UpdateAgentDataInfo.
func (*MockStoreMockRecorder) UpdateProcesses ¶
func (mr *MockStoreMockRecorder) UpdateProcesses(processes interface{}) *gomock.Call
UpdateProcesses indicates an expected call of UpdateProcesses.
func (*MockStoreMockRecorder) UpdateSchemas ¶
func (mr *MockStoreMockRecorder) UpdateSchemas(agentID, schemas interface{}) *gomock.Call
UpdateSchemas indicates an expected call of UpdateSchemas.