Documentation ¶
Index ¶
- type MockArchiveStore
- type MockStore
- func (_m *MockStore) Agent(ctx context.Context, id string) (*model.Agent, error)
- func (_m *MockStore) AgentConfiguration(ctx context.Context, agent *model.Agent) (*model.Configuration, error)
- func (_m *MockStore) AgentIndex(ctx context.Context) search.Index
- func (_m *MockStore) AgentRolloutUpdates(ctx context.Context) eventbus.Source[store.RolloutEventUpdates]
- func (_m *MockStore) AgentVersion(ctx context.Context, name string) (*model.AgentVersion, error)
- func (_m *MockStore) AgentVersions(ctx context.Context) ([]*model.AgentVersion, error)
- func (_m *MockStore) Agents(ctx context.Context, options ...store.QueryOption) ([]*model.Agent, error)
- func (_m *MockStore) AgentsCount(_a0 context.Context, _a1 ...store.QueryOption) (int, error)
- func (_m *MockStore) AgentsIDsMatchingConfiguration(ctx context.Context, conf *model.Configuration) ([]string, error)
- func (_m *MockStore) ApplyResources(ctx context.Context, resources []model.Resource) ([]model.ResourceStatus, error)
- func (_m *MockStore) CleanupDisconnectedAgents(ctx context.Context, since time.Time) error
- func (_m *MockStore) Clear()
- func (_m *MockStore) Close() error
- func (_m *MockStore) Configuration(ctx context.Context, name string) (*model.Configuration, error)
- func (_m *MockStore) ConfigurationIndex(ctx context.Context) search.Index
- func (_m *MockStore) Configurations(ctx context.Context, options ...store.QueryOption) ([]*model.Configuration, error)
- func (_m *MockStore) DeleteAgentVersion(ctx context.Context, name string) (*model.AgentVersion, error)
- func (_m *MockStore) DeleteAgents(ctx context.Context, agentIDs []string) ([]*model.Agent, error)
- func (_m *MockStore) DeleteConfiguration(ctx context.Context, name string) (*model.Configuration, error)
- func (_m *MockStore) DeleteDestination(ctx context.Context, name string) (*model.Destination, error)
- func (_m *MockStore) DeleteDestinationType(ctx context.Context, name string) (*model.DestinationType, error)
- func (_m *MockStore) DeleteProcessor(ctx context.Context, name string) (*model.Processor, error)
- func (_m *MockStore) DeleteProcessorType(ctx context.Context, name string) (*model.ProcessorType, error)
- func (_m *MockStore) DeleteResources(ctx context.Context, resources []model.Resource) ([]model.ResourceStatus, error)
- func (_m *MockStore) DeleteSource(ctx context.Context, name string) (*model.Source, error)
- func (_m *MockStore) DeleteSourceType(ctx context.Context, name string) (*model.SourceType, error)
- func (_m *MockStore) Destination(ctx context.Context, name string) (*model.Destination, error)
- func (_m *MockStore) DestinationType(ctx context.Context, name string) (*model.DestinationType, error)
- func (_m *MockStore) DestinationTypes(ctx context.Context) ([]*model.DestinationType, error)
- func (_m *MockStore) Destinations(ctx context.Context) ([]*model.Destination, error)
- func (_m *MockStore) DisconnectUnreportedAgents(ctx context.Context, since time.Time) error
- func (_m *MockStore) EXPECT() *MockStore_Expecter
- func (_m *MockStore) Measurements() stats.Measurements
- func (_m *MockStore) PauseRollout(ctx context.Context, configurationName string) (*model.Configuration, error)
- func (_m *MockStore) Processor(ctx context.Context, name string) (*model.Processor, error)
- func (_m *MockStore) ProcessorType(ctx context.Context, name string) (*model.ProcessorType, error)
- func (_m *MockStore) ProcessorTypes(ctx context.Context) ([]*model.ProcessorType, error)
- func (_m *MockStore) Processors(ctx context.Context) ([]*model.Processor, error)
- func (_m *MockStore) ReportConnectedAgents(ctx context.Context, agentIDs []string, _a2 time.Time) error
- func (_m *MockStore) ResourceHistory(ctx context.Context, resourceKind model.Kind, resourceName string) ([]*model.AnyResource, error)
- func (_m *MockStore) ResumeRollout(ctx context.Context, configurationName string) (*model.Configuration, error)
- func (_m *MockStore) Source(ctx context.Context, name string) (*model.Source, error)
- func (_m *MockStore) SourceType(ctx context.Context, name string) (*model.SourceType, error)
- func (_m *MockStore) SourceTypes(ctx context.Context) ([]*model.SourceType, error)
- func (_m *MockStore) Sources(ctx context.Context) ([]*model.Source, error)
- func (_m *MockStore) StartRollout(ctx context.Context, configurationName string, options *model.RolloutOptions) (*model.Configuration, error)
- func (_m *MockStore) UpdateAgent(ctx context.Context, agentID string, updater store.AgentUpdater) (*model.Agent, error)
- func (_m *MockStore) UpdateAgents(ctx context.Context, agentIDs []string, updater store.AgentUpdater) ([]*model.Agent, error)
- func (_m *MockStore) UpdateAllRollouts(ctx context.Context) error
- func (_m *MockStore) UpdateConfiguration(ctx context.Context, name string, updater store.ConfigurationUpdater) (*model.Configuration, model.UpdateStatus, error)
- func (_m *MockStore) UpdateRollout(ctx context.Context, configurationName string) (*model.Configuration, error)
- func (_m *MockStore) UpdateRollouts(ctx context.Context) ([]*model.Configuration, error)
- func (_m *MockStore) Updates(ctx context.Context) eventbus.Source[store.BasicEventUpdates]
- func (_m *MockStore) UpsertAgent(ctx context.Context, agentID string, updater store.AgentUpdater) (*model.Agent, error)
- func (_m *MockStore) UpsertAgents(ctx context.Context, agentIDs []string, updater store.AgentUpdater) ([]*model.Agent, error)
- func (_m *MockStore) UserSessions() sessions.Store
- type MockStore_AgentConfiguration_Call
- func (_c *MockStore_AgentConfiguration_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_AgentConfiguration_Call
- func (_c *MockStore_AgentConfiguration_Call) Run(run func(ctx context.Context, agent *model.Agent)) *MockStore_AgentConfiguration_Call
- func (_c *MockStore_AgentConfiguration_Call) RunAndReturn(run func(context.Context, *model.Agent) (*model.Configuration, error)) *MockStore_AgentConfiguration_Call
- type MockStore_AgentIndex_Call
- func (_c *MockStore_AgentIndex_Call) Return(_a0 search.Index) *MockStore_AgentIndex_Call
- func (_c *MockStore_AgentIndex_Call) Run(run func(ctx context.Context)) *MockStore_AgentIndex_Call
- func (_c *MockStore_AgentIndex_Call) RunAndReturn(run func(context.Context) search.Index) *MockStore_AgentIndex_Call
- type MockStore_AgentRolloutUpdates_Call
- func (_c *MockStore_AgentRolloutUpdates_Call) Return(_a0 eventbus.Source[store.RolloutEventUpdates]) *MockStore_AgentRolloutUpdates_Call
- func (_c *MockStore_AgentRolloutUpdates_Call) Run(run func(ctx context.Context)) *MockStore_AgentRolloutUpdates_Call
- func (_c *MockStore_AgentRolloutUpdates_Call) RunAndReturn(run func(context.Context) eventbus.Source[store.RolloutEventUpdates]) *MockStore_AgentRolloutUpdates_Call
- type MockStore_AgentVersion_Call
- func (_c *MockStore_AgentVersion_Call) Return(_a0 *model.AgentVersion, _a1 error) *MockStore_AgentVersion_Call
- func (_c *MockStore_AgentVersion_Call) Run(run func(ctx context.Context, name string)) *MockStore_AgentVersion_Call
- func (_c *MockStore_AgentVersion_Call) RunAndReturn(run func(context.Context, string) (*model.AgentVersion, error)) *MockStore_AgentVersion_Call
- type MockStore_AgentVersions_Call
- func (_c *MockStore_AgentVersions_Call) Return(_a0 []*model.AgentVersion, _a1 error) *MockStore_AgentVersions_Call
- func (_c *MockStore_AgentVersions_Call) Run(run func(ctx context.Context)) *MockStore_AgentVersions_Call
- func (_c *MockStore_AgentVersions_Call) RunAndReturn(run func(context.Context) ([]*model.AgentVersion, error)) *MockStore_AgentVersions_Call
- type MockStore_Agent_Call
- func (_c *MockStore_Agent_Call) Return(_a0 *model.Agent, _a1 error) *MockStore_Agent_Call
- func (_c *MockStore_Agent_Call) Run(run func(ctx context.Context, id string)) *MockStore_Agent_Call
- func (_c *MockStore_Agent_Call) RunAndReturn(run func(context.Context, string) (*model.Agent, error)) *MockStore_Agent_Call
- type MockStore_AgentsCount_Call
- func (_c *MockStore_AgentsCount_Call) Return(_a0 int, _a1 error) *MockStore_AgentsCount_Call
- func (_c *MockStore_AgentsCount_Call) Run(run func(_a0 context.Context, _a1 ...store.QueryOption)) *MockStore_AgentsCount_Call
- func (_c *MockStore_AgentsCount_Call) RunAndReturn(run func(context.Context, ...store.QueryOption) (int, error)) *MockStore_AgentsCount_Call
- type MockStore_AgentsIDsMatchingConfiguration_Call
- func (_c *MockStore_AgentsIDsMatchingConfiguration_Call) Return(_a0 []string, _a1 error) *MockStore_AgentsIDsMatchingConfiguration_Call
- func (_c *MockStore_AgentsIDsMatchingConfiguration_Call) Run(run func(ctx context.Context, conf *model.Configuration)) *MockStore_AgentsIDsMatchingConfiguration_Call
- func (_c *MockStore_AgentsIDsMatchingConfiguration_Call) RunAndReturn(run func(context.Context, *model.Configuration) ([]string, error)) *MockStore_AgentsIDsMatchingConfiguration_Call
- type MockStore_Agents_Call
- func (_c *MockStore_Agents_Call) Return(_a0 []*model.Agent, _a1 error) *MockStore_Agents_Call
- func (_c *MockStore_Agents_Call) Run(run func(ctx context.Context, options ...store.QueryOption)) *MockStore_Agents_Call
- func (_c *MockStore_Agents_Call) RunAndReturn(run func(context.Context, ...store.QueryOption) ([]*model.Agent, error)) *MockStore_Agents_Call
- type MockStore_ApplyResources_Call
- func (_c *MockStore_ApplyResources_Call) Return(_a0 []model.ResourceStatus, _a1 error) *MockStore_ApplyResources_Call
- func (_c *MockStore_ApplyResources_Call) Run(run func(ctx context.Context, resources []model.Resource)) *MockStore_ApplyResources_Call
- func (_c *MockStore_ApplyResources_Call) RunAndReturn(run func(context.Context, []model.Resource) ([]model.ResourceStatus, error)) *MockStore_ApplyResources_Call
- type MockStore_CleanupDisconnectedAgents_Call
- func (_c *MockStore_CleanupDisconnectedAgents_Call) Return(_a0 error) *MockStore_CleanupDisconnectedAgents_Call
- func (_c *MockStore_CleanupDisconnectedAgents_Call) Run(run func(ctx context.Context, since time.Time)) *MockStore_CleanupDisconnectedAgents_Call
- func (_c *MockStore_CleanupDisconnectedAgents_Call) RunAndReturn(run func(context.Context, time.Time) error) *MockStore_CleanupDisconnectedAgents_Call
- type MockStore_Clear_Call
- type MockStore_Close_Call
- type MockStore_ConfigurationIndex_Call
- func (_c *MockStore_ConfigurationIndex_Call) Return(_a0 search.Index) *MockStore_ConfigurationIndex_Call
- func (_c *MockStore_ConfigurationIndex_Call) Run(run func(ctx context.Context)) *MockStore_ConfigurationIndex_Call
- func (_c *MockStore_ConfigurationIndex_Call) RunAndReturn(run func(context.Context) search.Index) *MockStore_ConfigurationIndex_Call
- type MockStore_Configuration_Call
- func (_c *MockStore_Configuration_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_Configuration_Call
- func (_c *MockStore_Configuration_Call) Run(run func(ctx context.Context, name string)) *MockStore_Configuration_Call
- func (_c *MockStore_Configuration_Call) RunAndReturn(run func(context.Context, string) (*model.Configuration, error)) *MockStore_Configuration_Call
- type MockStore_Configurations_Call
- func (_c *MockStore_Configurations_Call) Return(_a0 []*model.Configuration, _a1 error) *MockStore_Configurations_Call
- func (_c *MockStore_Configurations_Call) Run(run func(ctx context.Context, options ...store.QueryOption)) *MockStore_Configurations_Call
- func (_c *MockStore_Configurations_Call) RunAndReturn(...) *MockStore_Configurations_Call
- type MockStore_DeleteAgentVersion_Call
- func (_c *MockStore_DeleteAgentVersion_Call) Return(_a0 *model.AgentVersion, _a1 error) *MockStore_DeleteAgentVersion_Call
- func (_c *MockStore_DeleteAgentVersion_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteAgentVersion_Call
- func (_c *MockStore_DeleteAgentVersion_Call) RunAndReturn(run func(context.Context, string) (*model.AgentVersion, error)) *MockStore_DeleteAgentVersion_Call
- type MockStore_DeleteAgents_Call
- func (_c *MockStore_DeleteAgents_Call) Return(_a0 []*model.Agent, _a1 error) *MockStore_DeleteAgents_Call
- func (_c *MockStore_DeleteAgents_Call) Run(run func(ctx context.Context, agentIDs []string)) *MockStore_DeleteAgents_Call
- func (_c *MockStore_DeleteAgents_Call) RunAndReturn(run func(context.Context, []string) ([]*model.Agent, error)) *MockStore_DeleteAgents_Call
- type MockStore_DeleteConfiguration_Call
- func (_c *MockStore_DeleteConfiguration_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_DeleteConfiguration_Call
- func (_c *MockStore_DeleteConfiguration_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteConfiguration_Call
- func (_c *MockStore_DeleteConfiguration_Call) RunAndReturn(run func(context.Context, string) (*model.Configuration, error)) *MockStore_DeleteConfiguration_Call
- type MockStore_DeleteDestinationType_Call
- func (_c *MockStore_DeleteDestinationType_Call) Return(_a0 *model.DestinationType, _a1 error) *MockStore_DeleteDestinationType_Call
- func (_c *MockStore_DeleteDestinationType_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteDestinationType_Call
- func (_c *MockStore_DeleteDestinationType_Call) RunAndReturn(run func(context.Context, string) (*model.DestinationType, error)) *MockStore_DeleteDestinationType_Call
- type MockStore_DeleteDestination_Call
- func (_c *MockStore_DeleteDestination_Call) Return(_a0 *model.Destination, _a1 error) *MockStore_DeleteDestination_Call
- func (_c *MockStore_DeleteDestination_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteDestination_Call
- func (_c *MockStore_DeleteDestination_Call) RunAndReturn(run func(context.Context, string) (*model.Destination, error)) *MockStore_DeleteDestination_Call
- type MockStore_DeleteProcessorType_Call
- func (_c *MockStore_DeleteProcessorType_Call) Return(_a0 *model.ProcessorType, _a1 error) *MockStore_DeleteProcessorType_Call
- func (_c *MockStore_DeleteProcessorType_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteProcessorType_Call
- func (_c *MockStore_DeleteProcessorType_Call) RunAndReturn(run func(context.Context, string) (*model.ProcessorType, error)) *MockStore_DeleteProcessorType_Call
- type MockStore_DeleteProcessor_Call
- func (_c *MockStore_DeleteProcessor_Call) Return(_a0 *model.Processor, _a1 error) *MockStore_DeleteProcessor_Call
- func (_c *MockStore_DeleteProcessor_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteProcessor_Call
- func (_c *MockStore_DeleteProcessor_Call) RunAndReturn(run func(context.Context, string) (*model.Processor, error)) *MockStore_DeleteProcessor_Call
- type MockStore_DeleteResources_Call
- func (_c *MockStore_DeleteResources_Call) Return(_a0 []model.ResourceStatus, _a1 error) *MockStore_DeleteResources_Call
- func (_c *MockStore_DeleteResources_Call) Run(run func(ctx context.Context, resources []model.Resource)) *MockStore_DeleteResources_Call
- func (_c *MockStore_DeleteResources_Call) RunAndReturn(run func(context.Context, []model.Resource) ([]model.ResourceStatus, error)) *MockStore_DeleteResources_Call
- type MockStore_DeleteSourceType_Call
- func (_c *MockStore_DeleteSourceType_Call) Return(_a0 *model.SourceType, _a1 error) *MockStore_DeleteSourceType_Call
- func (_c *MockStore_DeleteSourceType_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteSourceType_Call
- func (_c *MockStore_DeleteSourceType_Call) RunAndReturn(run func(context.Context, string) (*model.SourceType, error)) *MockStore_DeleteSourceType_Call
- type MockStore_DeleteSource_Call
- func (_c *MockStore_DeleteSource_Call) Return(_a0 *model.Source, _a1 error) *MockStore_DeleteSource_Call
- func (_c *MockStore_DeleteSource_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteSource_Call
- func (_c *MockStore_DeleteSource_Call) RunAndReturn(run func(context.Context, string) (*model.Source, error)) *MockStore_DeleteSource_Call
- type MockStore_DestinationType_Call
- func (_c *MockStore_DestinationType_Call) Return(_a0 *model.DestinationType, _a1 error) *MockStore_DestinationType_Call
- func (_c *MockStore_DestinationType_Call) Run(run func(ctx context.Context, name string)) *MockStore_DestinationType_Call
- func (_c *MockStore_DestinationType_Call) RunAndReturn(run func(context.Context, string) (*model.DestinationType, error)) *MockStore_DestinationType_Call
- type MockStore_DestinationTypes_Call
- func (_c *MockStore_DestinationTypes_Call) Return(_a0 []*model.DestinationType, _a1 error) *MockStore_DestinationTypes_Call
- func (_c *MockStore_DestinationTypes_Call) Run(run func(ctx context.Context)) *MockStore_DestinationTypes_Call
- func (_c *MockStore_DestinationTypes_Call) RunAndReturn(run func(context.Context) ([]*model.DestinationType, error)) *MockStore_DestinationTypes_Call
- type MockStore_Destination_Call
- func (_c *MockStore_Destination_Call) Return(_a0 *model.Destination, _a1 error) *MockStore_Destination_Call
- func (_c *MockStore_Destination_Call) Run(run func(ctx context.Context, name string)) *MockStore_Destination_Call
- func (_c *MockStore_Destination_Call) RunAndReturn(run func(context.Context, string) (*model.Destination, error)) *MockStore_Destination_Call
- type MockStore_Destinations_Call
- func (_c *MockStore_Destinations_Call) Return(_a0 []*model.Destination, _a1 error) *MockStore_Destinations_Call
- func (_c *MockStore_Destinations_Call) Run(run func(ctx context.Context)) *MockStore_Destinations_Call
- func (_c *MockStore_Destinations_Call) RunAndReturn(run func(context.Context) ([]*model.Destination, error)) *MockStore_Destinations_Call
- type MockStore_DisconnectUnreportedAgents_Call
- func (_c *MockStore_DisconnectUnreportedAgents_Call) Return(_a0 error) *MockStore_DisconnectUnreportedAgents_Call
- func (_c *MockStore_DisconnectUnreportedAgents_Call) Run(run func(ctx context.Context, since time.Time)) *MockStore_DisconnectUnreportedAgents_Call
- func (_c *MockStore_DisconnectUnreportedAgents_Call) RunAndReturn(run func(context.Context, time.Time) error) *MockStore_DisconnectUnreportedAgents_Call
- type MockStore_Expecter
- func (_e *MockStore_Expecter) Agent(ctx interface{}, id interface{}) *MockStore_Agent_Call
- func (_e *MockStore_Expecter) AgentConfiguration(ctx interface{}, agent interface{}) *MockStore_AgentConfiguration_Call
- func (_e *MockStore_Expecter) AgentIndex(ctx interface{}) *MockStore_AgentIndex_Call
- func (_e *MockStore_Expecter) AgentRolloutUpdates(ctx interface{}) *MockStore_AgentRolloutUpdates_Call
- func (_e *MockStore_Expecter) AgentVersion(ctx interface{}, name interface{}) *MockStore_AgentVersion_Call
- func (_e *MockStore_Expecter) AgentVersions(ctx interface{}) *MockStore_AgentVersions_Call
- func (_e *MockStore_Expecter) Agents(ctx interface{}, options ...interface{}) *MockStore_Agents_Call
- func (_e *MockStore_Expecter) AgentsCount(_a0 interface{}, _a1 ...interface{}) *MockStore_AgentsCount_Call
- func (_e *MockStore_Expecter) AgentsIDsMatchingConfiguration(ctx interface{}, conf interface{}) *MockStore_AgentsIDsMatchingConfiguration_Call
- func (_e *MockStore_Expecter) ApplyResources(ctx interface{}, resources interface{}) *MockStore_ApplyResources_Call
- func (_e *MockStore_Expecter) CleanupDisconnectedAgents(ctx interface{}, since interface{}) *MockStore_CleanupDisconnectedAgents_Call
- func (_e *MockStore_Expecter) Clear() *MockStore_Clear_Call
- func (_e *MockStore_Expecter) Close() *MockStore_Close_Call
- func (_e *MockStore_Expecter) Configuration(ctx interface{}, name interface{}) *MockStore_Configuration_Call
- func (_e *MockStore_Expecter) ConfigurationIndex(ctx interface{}) *MockStore_ConfigurationIndex_Call
- func (_e *MockStore_Expecter) Configurations(ctx interface{}, options ...interface{}) *MockStore_Configurations_Call
- func (_e *MockStore_Expecter) DeleteAgentVersion(ctx interface{}, name interface{}) *MockStore_DeleteAgentVersion_Call
- func (_e *MockStore_Expecter) DeleteAgents(ctx interface{}, agentIDs interface{}) *MockStore_DeleteAgents_Call
- func (_e *MockStore_Expecter) DeleteConfiguration(ctx interface{}, name interface{}) *MockStore_DeleteConfiguration_Call
- func (_e *MockStore_Expecter) DeleteDestination(ctx interface{}, name interface{}) *MockStore_DeleteDestination_Call
- func (_e *MockStore_Expecter) DeleteDestinationType(ctx interface{}, name interface{}) *MockStore_DeleteDestinationType_Call
- func (_e *MockStore_Expecter) DeleteProcessor(ctx interface{}, name interface{}) *MockStore_DeleteProcessor_Call
- func (_e *MockStore_Expecter) DeleteProcessorType(ctx interface{}, name interface{}) *MockStore_DeleteProcessorType_Call
- func (_e *MockStore_Expecter) DeleteResources(ctx interface{}, resources interface{}) *MockStore_DeleteResources_Call
- func (_e *MockStore_Expecter) DeleteSource(ctx interface{}, name interface{}) *MockStore_DeleteSource_Call
- func (_e *MockStore_Expecter) DeleteSourceType(ctx interface{}, name interface{}) *MockStore_DeleteSourceType_Call
- func (_e *MockStore_Expecter) Destination(ctx interface{}, name interface{}) *MockStore_Destination_Call
- func (_e *MockStore_Expecter) DestinationType(ctx interface{}, name interface{}) *MockStore_DestinationType_Call
- func (_e *MockStore_Expecter) DestinationTypes(ctx interface{}) *MockStore_DestinationTypes_Call
- func (_e *MockStore_Expecter) Destinations(ctx interface{}) *MockStore_Destinations_Call
- func (_e *MockStore_Expecter) DisconnectUnreportedAgents(ctx interface{}, since interface{}) *MockStore_DisconnectUnreportedAgents_Call
- func (_e *MockStore_Expecter) Measurements() *MockStore_Measurements_Call
- func (_e *MockStore_Expecter) PauseRollout(ctx interface{}, configurationName interface{}) *MockStore_PauseRollout_Call
- func (_e *MockStore_Expecter) Processor(ctx interface{}, name interface{}) *MockStore_Processor_Call
- func (_e *MockStore_Expecter) ProcessorType(ctx interface{}, name interface{}) *MockStore_ProcessorType_Call
- func (_e *MockStore_Expecter) ProcessorTypes(ctx interface{}) *MockStore_ProcessorTypes_Call
- func (_e *MockStore_Expecter) Processors(ctx interface{}) *MockStore_Processors_Call
- func (_e *MockStore_Expecter) ReportConnectedAgents(ctx interface{}, agentIDs interface{}, _a2 interface{}) *MockStore_ReportConnectedAgents_Call
- func (_e *MockStore_Expecter) ResourceHistory(ctx interface{}, resourceKind interface{}, resourceName interface{}) *MockStore_ResourceHistory_Call
- func (_e *MockStore_Expecter) ResumeRollout(ctx interface{}, configurationName interface{}) *MockStore_ResumeRollout_Call
- func (_e *MockStore_Expecter) Source(ctx interface{}, name interface{}) *MockStore_Source_Call
- func (_e *MockStore_Expecter) SourceType(ctx interface{}, name interface{}) *MockStore_SourceType_Call
- func (_e *MockStore_Expecter) SourceTypes(ctx interface{}) *MockStore_SourceTypes_Call
- func (_e *MockStore_Expecter) Sources(ctx interface{}) *MockStore_Sources_Call
- func (_e *MockStore_Expecter) StartRollout(ctx interface{}, configurationName interface{}, options interface{}) *MockStore_StartRollout_Call
- func (_e *MockStore_Expecter) UpdateAgent(ctx interface{}, agentID interface{}, updater interface{}) *MockStore_UpdateAgent_Call
- func (_e *MockStore_Expecter) UpdateAgents(ctx interface{}, agentIDs interface{}, updater interface{}) *MockStore_UpdateAgents_Call
- func (_e *MockStore_Expecter) UpdateAllRollouts(ctx interface{}) *MockStore_UpdateAllRollouts_Call
- func (_e *MockStore_Expecter) UpdateConfiguration(ctx interface{}, name interface{}, updater interface{}) *MockStore_UpdateConfiguration_Call
- func (_e *MockStore_Expecter) UpdateRollout(ctx interface{}, configurationName interface{}) *MockStore_UpdateRollout_Call
- func (_e *MockStore_Expecter) UpdateRollouts(ctx interface{}) *MockStore_UpdateRollouts_Call
- func (_e *MockStore_Expecter) Updates(ctx interface{}) *MockStore_Updates_Call
- func (_e *MockStore_Expecter) UpsertAgent(ctx interface{}, agentID interface{}, updater interface{}) *MockStore_UpsertAgent_Call
- func (_e *MockStore_Expecter) UpsertAgents(ctx interface{}, agentIDs interface{}, updater interface{}) *MockStore_UpsertAgents_Call
- func (_e *MockStore_Expecter) UserSessions() *MockStore_UserSessions_Call
- type MockStore_Measurements_Call
- type MockStore_PauseRollout_Call
- func (_c *MockStore_PauseRollout_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_PauseRollout_Call
- func (_c *MockStore_PauseRollout_Call) Run(run func(ctx context.Context, configurationName string)) *MockStore_PauseRollout_Call
- func (_c *MockStore_PauseRollout_Call) RunAndReturn(run func(context.Context, string) (*model.Configuration, error)) *MockStore_PauseRollout_Call
- type MockStore_ProcessorType_Call
- func (_c *MockStore_ProcessorType_Call) Return(_a0 *model.ProcessorType, _a1 error) *MockStore_ProcessorType_Call
- func (_c *MockStore_ProcessorType_Call) Run(run func(ctx context.Context, name string)) *MockStore_ProcessorType_Call
- func (_c *MockStore_ProcessorType_Call) RunAndReturn(run func(context.Context, string) (*model.ProcessorType, error)) *MockStore_ProcessorType_Call
- type MockStore_ProcessorTypes_Call
- func (_c *MockStore_ProcessorTypes_Call) Return(_a0 []*model.ProcessorType, _a1 error) *MockStore_ProcessorTypes_Call
- func (_c *MockStore_ProcessorTypes_Call) Run(run func(ctx context.Context)) *MockStore_ProcessorTypes_Call
- func (_c *MockStore_ProcessorTypes_Call) RunAndReturn(run func(context.Context) ([]*model.ProcessorType, error)) *MockStore_ProcessorTypes_Call
- type MockStore_Processor_Call
- func (_c *MockStore_Processor_Call) Return(_a0 *model.Processor, _a1 error) *MockStore_Processor_Call
- func (_c *MockStore_Processor_Call) Run(run func(ctx context.Context, name string)) *MockStore_Processor_Call
- func (_c *MockStore_Processor_Call) RunAndReturn(run func(context.Context, string) (*model.Processor, error)) *MockStore_Processor_Call
- type MockStore_Processors_Call
- func (_c *MockStore_Processors_Call) Return(_a0 []*model.Processor, _a1 error) *MockStore_Processors_Call
- func (_c *MockStore_Processors_Call) Run(run func(ctx context.Context)) *MockStore_Processors_Call
- func (_c *MockStore_Processors_Call) RunAndReturn(run func(context.Context) ([]*model.Processor, error)) *MockStore_Processors_Call
- type MockStore_ReportConnectedAgents_Call
- func (_c *MockStore_ReportConnectedAgents_Call) Return(_a0 error) *MockStore_ReportConnectedAgents_Call
- func (_c *MockStore_ReportConnectedAgents_Call) Run(run func(ctx context.Context, agentIDs []string, _a2 time.Time)) *MockStore_ReportConnectedAgents_Call
- func (_c *MockStore_ReportConnectedAgents_Call) RunAndReturn(run func(context.Context, []string, time.Time) error) *MockStore_ReportConnectedAgents_Call
- type MockStore_ResourceHistory_Call
- func (_c *MockStore_ResourceHistory_Call) Return(_a0 []*model.AnyResource, _a1 error) *MockStore_ResourceHistory_Call
- func (_c *MockStore_ResourceHistory_Call) Run(run func(ctx context.Context, resourceKind model.Kind, resourceName string)) *MockStore_ResourceHistory_Call
- func (_c *MockStore_ResourceHistory_Call) RunAndReturn(run func(context.Context, model.Kind, string) ([]*model.AnyResource, error)) *MockStore_ResourceHistory_Call
- type MockStore_ResumeRollout_Call
- func (_c *MockStore_ResumeRollout_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_ResumeRollout_Call
- func (_c *MockStore_ResumeRollout_Call) Run(run func(ctx context.Context, configurationName string)) *MockStore_ResumeRollout_Call
- func (_c *MockStore_ResumeRollout_Call) RunAndReturn(run func(context.Context, string) (*model.Configuration, error)) *MockStore_ResumeRollout_Call
- type MockStore_SourceType_Call
- func (_c *MockStore_SourceType_Call) Return(_a0 *model.SourceType, _a1 error) *MockStore_SourceType_Call
- func (_c *MockStore_SourceType_Call) Run(run func(ctx context.Context, name string)) *MockStore_SourceType_Call
- func (_c *MockStore_SourceType_Call) RunAndReturn(run func(context.Context, string) (*model.SourceType, error)) *MockStore_SourceType_Call
- type MockStore_SourceTypes_Call
- func (_c *MockStore_SourceTypes_Call) Return(_a0 []*model.SourceType, _a1 error) *MockStore_SourceTypes_Call
- func (_c *MockStore_SourceTypes_Call) Run(run func(ctx context.Context)) *MockStore_SourceTypes_Call
- func (_c *MockStore_SourceTypes_Call) RunAndReturn(run func(context.Context) ([]*model.SourceType, error)) *MockStore_SourceTypes_Call
- type MockStore_Source_Call
- func (_c *MockStore_Source_Call) Return(_a0 *model.Source, _a1 error) *MockStore_Source_Call
- func (_c *MockStore_Source_Call) Run(run func(ctx context.Context, name string)) *MockStore_Source_Call
- func (_c *MockStore_Source_Call) RunAndReturn(run func(context.Context, string) (*model.Source, error)) *MockStore_Source_Call
- type MockStore_Sources_Call
- func (_c *MockStore_Sources_Call) Return(_a0 []*model.Source, _a1 error) *MockStore_Sources_Call
- func (_c *MockStore_Sources_Call) Run(run func(ctx context.Context)) *MockStore_Sources_Call
- func (_c *MockStore_Sources_Call) RunAndReturn(run func(context.Context) ([]*model.Source, error)) *MockStore_Sources_Call
- type MockStore_StartRollout_Call
- type MockStore_UpdateAgent_Call
- func (_c *MockStore_UpdateAgent_Call) Return(_a0 *model.Agent, _a1 error) *MockStore_UpdateAgent_Call
- func (_c *MockStore_UpdateAgent_Call) Run(run func(ctx context.Context, agentID string, updater store.AgentUpdater)) *MockStore_UpdateAgent_Call
- func (_c *MockStore_UpdateAgent_Call) RunAndReturn(run func(context.Context, string, store.AgentUpdater) (*model.Agent, error)) *MockStore_UpdateAgent_Call
- type MockStore_UpdateAgents_Call
- func (_c *MockStore_UpdateAgents_Call) Return(_a0 []*model.Agent, _a1 error) *MockStore_UpdateAgents_Call
- func (_c *MockStore_UpdateAgents_Call) Run(run func(ctx context.Context, agentIDs []string, updater store.AgentUpdater)) *MockStore_UpdateAgents_Call
- func (_c *MockStore_UpdateAgents_Call) RunAndReturn(...) *MockStore_UpdateAgents_Call
- type MockStore_UpdateAllRollouts_Call
- func (_c *MockStore_UpdateAllRollouts_Call) Return(_a0 error) *MockStore_UpdateAllRollouts_Call
- func (_c *MockStore_UpdateAllRollouts_Call) Run(run func(ctx context.Context)) *MockStore_UpdateAllRollouts_Call
- func (_c *MockStore_UpdateAllRollouts_Call) RunAndReturn(run func(context.Context) error) *MockStore_UpdateAllRollouts_Call
- type MockStore_UpdateConfiguration_Call
- func (_c *MockStore_UpdateConfiguration_Call) Return(config *model.Configuration, status model.UpdateStatus, err error) *MockStore_UpdateConfiguration_Call
- func (_c *MockStore_UpdateConfiguration_Call) Run(run func(ctx context.Context, name string, updater store.ConfigurationUpdater)) *MockStore_UpdateConfiguration_Call
- func (_c *MockStore_UpdateConfiguration_Call) RunAndReturn(...) *MockStore_UpdateConfiguration_Call
- type MockStore_UpdateRollout_Call
- func (_c *MockStore_UpdateRollout_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_UpdateRollout_Call
- func (_c *MockStore_UpdateRollout_Call) Run(run func(ctx context.Context, configurationName string)) *MockStore_UpdateRollout_Call
- func (_c *MockStore_UpdateRollout_Call) RunAndReturn(run func(context.Context, string) (*model.Configuration, error)) *MockStore_UpdateRollout_Call
- type MockStore_UpdateRollouts_Call
- func (_c *MockStore_UpdateRollouts_Call) Return(_a0 []*model.Configuration, _a1 error) *MockStore_UpdateRollouts_Call
- func (_c *MockStore_UpdateRollouts_Call) Run(run func(ctx context.Context)) *MockStore_UpdateRollouts_Call
- func (_c *MockStore_UpdateRollouts_Call) RunAndReturn(run func(context.Context) ([]*model.Configuration, error)) *MockStore_UpdateRollouts_Call
- type MockStore_Updates_Call
- func (_c *MockStore_Updates_Call) Return(_a0 eventbus.Source[store.BasicEventUpdates]) *MockStore_Updates_Call
- func (_c *MockStore_Updates_Call) Run(run func(ctx context.Context)) *MockStore_Updates_Call
- func (_c *MockStore_Updates_Call) RunAndReturn(run func(context.Context) eventbus.Source[store.BasicEventUpdates]) *MockStore_Updates_Call
- type MockStore_UpsertAgent_Call
- func (_c *MockStore_UpsertAgent_Call) Return(_a0 *model.Agent, _a1 error) *MockStore_UpsertAgent_Call
- func (_c *MockStore_UpsertAgent_Call) Run(run func(ctx context.Context, agentID string, updater store.AgentUpdater)) *MockStore_UpsertAgent_Call
- func (_c *MockStore_UpsertAgent_Call) RunAndReturn(run func(context.Context, string, store.AgentUpdater) (*model.Agent, error)) *MockStore_UpsertAgent_Call
- type MockStore_UpsertAgents_Call
- func (_c *MockStore_UpsertAgents_Call) Return(_a0 []*model.Agent, _a1 error) *MockStore_UpsertAgents_Call
- func (_c *MockStore_UpsertAgents_Call) Run(run func(ctx context.Context, agentIDs []string, updater store.AgentUpdater)) *MockStore_UpsertAgents_Call
- func (_c *MockStore_UpsertAgents_Call) RunAndReturn(...) *MockStore_UpsertAgents_Call
- type MockStore_UserSessions_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockArchiveStore ¶
MockArchiveStore is an autogenerated mock type for the ArchiveStore type
func NewMockArchiveStore ¶
func NewMockArchiveStore(t interface { mock.TestingT Cleanup(func()) }) *MockArchiveStore
NewMockArchiveStore creates a new instance of MockArchiveStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockArchiveStore) ResourceHistory ¶
func (_m *MockArchiveStore) ResourceHistory(ctx context.Context, resourceKind model.Kind, resourceName string) ([]*model.AnyResource, error)
ResourceHistory provides a mock function with given fields: ctx, resourceKind, resourceName
type MockStore ¶
MockStore is an autogenerated mock type for the Store type
func NewMockStore ¶
NewMockStore creates a new instance of MockStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockStore) AgentConfiguration ¶
func (_m *MockStore) AgentConfiguration(ctx context.Context, agent *model.Agent) (*model.Configuration, error)
AgentConfiguration provides a mock function with given fields: ctx, agent
func (*MockStore) AgentIndex ¶
AgentIndex provides a mock function with given fields: ctx
func (*MockStore) AgentRolloutUpdates ¶
func (_m *MockStore) AgentRolloutUpdates(ctx context.Context) eventbus.Source[store.RolloutEventUpdates]
AgentRolloutUpdates provides a mock function with given fields: ctx
func (*MockStore) AgentVersion ¶
AgentVersion provides a mock function with given fields: ctx, name
func (*MockStore) AgentVersions ¶
AgentVersions provides a mock function with given fields: ctx
func (*MockStore) Agents ¶
func (_m *MockStore) Agents(ctx context.Context, options ...store.QueryOption) ([]*model.Agent, error)
Agents provides a mock function with given fields: ctx, options
func (*MockStore) AgentsCount ¶
AgentsCount provides a mock function with given fields: _a0, _a1
func (*MockStore) AgentsIDsMatchingConfiguration ¶
func (_m *MockStore) AgentsIDsMatchingConfiguration(ctx context.Context, conf *model.Configuration) ([]string, error)
AgentsIDsMatchingConfiguration provides a mock function with given fields: ctx, conf
func (*MockStore) ApplyResources ¶
func (_m *MockStore) ApplyResources(ctx context.Context, resources []model.Resource) ([]model.ResourceStatus, error)
ApplyResources provides a mock function with given fields: ctx, resources
func (*MockStore) CleanupDisconnectedAgents ¶
CleanupDisconnectedAgents provides a mock function with given fields: ctx, since
func (*MockStore) Clear ¶
func (_m *MockStore) Clear()
Clear provides a mock function with given fields:
func (*MockStore) Configuration ¶
Configuration provides a mock function with given fields: ctx, name
func (*MockStore) ConfigurationIndex ¶
ConfigurationIndex provides a mock function with given fields: ctx
func (*MockStore) Configurations ¶
func (_m *MockStore) Configurations(ctx context.Context, options ...store.QueryOption) ([]*model.Configuration, error)
Configurations provides a mock function with given fields: ctx, options
func (*MockStore) DeleteAgentVersion ¶
func (_m *MockStore) DeleteAgentVersion(ctx context.Context, name string) (*model.AgentVersion, error)
DeleteAgentVersion provides a mock function with given fields: ctx, name
func (*MockStore) DeleteAgents ¶
DeleteAgents provides a mock function with given fields: ctx, agentIDs
func (*MockStore) DeleteConfiguration ¶
func (_m *MockStore) DeleteConfiguration(ctx context.Context, name string) (*model.Configuration, error)
DeleteConfiguration provides a mock function with given fields: ctx, name
func (*MockStore) DeleteDestination ¶
func (_m *MockStore) DeleteDestination(ctx context.Context, name string) (*model.Destination, error)
DeleteDestination provides a mock function with given fields: ctx, name
func (*MockStore) DeleteDestinationType ¶
func (_m *MockStore) DeleteDestinationType(ctx context.Context, name string) (*model.DestinationType, error)
DeleteDestinationType provides a mock function with given fields: ctx, name
func (*MockStore) DeleteProcessor ¶
DeleteProcessor provides a mock function with given fields: ctx, name
func (*MockStore) DeleteProcessorType ¶
func (_m *MockStore) DeleteProcessorType(ctx context.Context, name string) (*model.ProcessorType, error)
DeleteProcessorType provides a mock function with given fields: ctx, name
func (*MockStore) DeleteResources ¶
func (_m *MockStore) DeleteResources(ctx context.Context, resources []model.Resource) ([]model.ResourceStatus, error)
DeleteResources provides a mock function with given fields: ctx, resources
func (*MockStore) DeleteSource ¶
DeleteSource provides a mock function with given fields: ctx, name
func (*MockStore) DeleteSourceType ¶
DeleteSourceType provides a mock function with given fields: ctx, name
func (*MockStore) Destination ¶
Destination provides a mock function with given fields: ctx, name
func (*MockStore) DestinationType ¶
func (_m *MockStore) DestinationType(ctx context.Context, name string) (*model.DestinationType, error)
DestinationType provides a mock function with given fields: ctx, name
func (*MockStore) DestinationTypes ¶
DestinationTypes provides a mock function with given fields: ctx
func (*MockStore) Destinations ¶
Destinations provides a mock function with given fields: ctx
func (*MockStore) DisconnectUnreportedAgents ¶ added in v1.23.0
DisconnectUnreportedAgents provides a mock function with given fields: ctx, since
func (*MockStore) EXPECT ¶ added in v1.22.0
func (_m *MockStore) EXPECT() *MockStore_Expecter
func (*MockStore) Measurements ¶
func (_m *MockStore) Measurements() stats.Measurements
Measurements provides a mock function with given fields:
func (*MockStore) PauseRollout ¶
func (_m *MockStore) PauseRollout(ctx context.Context, configurationName string) (*model.Configuration, error)
PauseRollout provides a mock function with given fields: ctx, configurationName
func (*MockStore) ProcessorType ¶
ProcessorType provides a mock function with given fields: ctx, name
func (*MockStore) ProcessorTypes ¶
ProcessorTypes provides a mock function with given fields: ctx
func (*MockStore) Processors ¶
Processors provides a mock function with given fields: ctx
func (*MockStore) ReportConnectedAgents ¶ added in v1.23.0
func (_m *MockStore) ReportConnectedAgents(ctx context.Context, agentIDs []string, _a2 time.Time) error
ReportConnectedAgents provides a mock function with given fields: ctx, agentIDs, _a2
func (*MockStore) ResourceHistory ¶ added in v1.21.1
func (_m *MockStore) ResourceHistory(ctx context.Context, resourceKind model.Kind, resourceName string) ([]*model.AnyResource, error)
ResourceHistory provides a mock function with given fields: ctx, resourceKind, resourceName
func (*MockStore) ResumeRollout ¶
func (_m *MockStore) ResumeRollout(ctx context.Context, configurationName string) (*model.Configuration, error)
ResumeRollout provides a mock function with given fields: ctx, configurationName
func (*MockStore) SourceType ¶
SourceType provides a mock function with given fields: ctx, name
func (*MockStore) SourceTypes ¶
SourceTypes provides a mock function with given fields: ctx
func (*MockStore) StartRollout ¶
func (_m *MockStore) StartRollout(ctx context.Context, configurationName string, options *model.RolloutOptions) (*model.Configuration, error)
StartRollout provides a mock function with given fields: ctx, configurationName, options
func (*MockStore) UpdateAgent ¶ added in v1.24.0
func (_m *MockStore) UpdateAgent(ctx context.Context, agentID string, updater store.AgentUpdater) (*model.Agent, error)
UpdateAgent provides a mock function with given fields: ctx, agentID, updater
func (*MockStore) UpdateAgents ¶ added in v1.24.0
func (_m *MockStore) UpdateAgents(ctx context.Context, agentIDs []string, updater store.AgentUpdater) ([]*model.Agent, error)
UpdateAgents provides a mock function with given fields: ctx, agentIDs, updater
func (*MockStore) UpdateAllRollouts ¶
UpdateAllRollouts provides a mock function with given fields: ctx
func (*MockStore) UpdateConfiguration ¶
func (_m *MockStore) UpdateConfiguration(ctx context.Context, name string, updater store.ConfigurationUpdater) (*model.Configuration, model.UpdateStatus, error)
UpdateConfiguration provides a mock function with given fields: ctx, name, updater
func (*MockStore) UpdateRollout ¶
func (_m *MockStore) UpdateRollout(ctx context.Context, configurationName string) (*model.Configuration, error)
UpdateRollout provides a mock function with given fields: ctx, configurationName
func (*MockStore) UpdateRollouts ¶
UpdateRollouts provides a mock function with given fields: ctx
func (*MockStore) UpsertAgent ¶
func (_m *MockStore) UpsertAgent(ctx context.Context, agentID string, updater store.AgentUpdater) (*model.Agent, error)
UpsertAgent provides a mock function with given fields: ctx, agentID, updater
func (*MockStore) UpsertAgents ¶
func (_m *MockStore) UpsertAgents(ctx context.Context, agentIDs []string, updater store.AgentUpdater) ([]*model.Agent, error)
UpsertAgents provides a mock function with given fields: ctx, agentIDs, updater
func (*MockStore) UserSessions ¶
UserSessions provides a mock function with given fields:
type MockStore_AgentConfiguration_Call ¶ added in v1.22.0
MockStore_AgentConfiguration_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AgentConfiguration'
func (*MockStore_AgentConfiguration_Call) Return ¶ added in v1.22.0
func (_c *MockStore_AgentConfiguration_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_AgentConfiguration_Call
func (*MockStore_AgentConfiguration_Call) Run ¶ added in v1.22.0
func (_c *MockStore_AgentConfiguration_Call) Run(run func(ctx context.Context, agent *model.Agent)) *MockStore_AgentConfiguration_Call
func (*MockStore_AgentConfiguration_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_AgentConfiguration_Call) RunAndReturn(run func(context.Context, *model.Agent) (*model.Configuration, error)) *MockStore_AgentConfiguration_Call
type MockStore_AgentIndex_Call ¶ added in v1.22.0
MockStore_AgentIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AgentIndex'
func (*MockStore_AgentIndex_Call) Return ¶ added in v1.22.0
func (_c *MockStore_AgentIndex_Call) Return(_a0 search.Index) *MockStore_AgentIndex_Call
func (*MockStore_AgentIndex_Call) Run ¶ added in v1.22.0
func (_c *MockStore_AgentIndex_Call) Run(run func(ctx context.Context)) *MockStore_AgentIndex_Call
func (*MockStore_AgentIndex_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_AgentIndex_Call) RunAndReturn(run func(context.Context) search.Index) *MockStore_AgentIndex_Call
type MockStore_AgentRolloutUpdates_Call ¶ added in v1.22.0
MockStore_AgentRolloutUpdates_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AgentRolloutUpdates'
func (*MockStore_AgentRolloutUpdates_Call) Return ¶ added in v1.22.0
func (_c *MockStore_AgentRolloutUpdates_Call) Return(_a0 eventbus.Source[store.RolloutEventUpdates]) *MockStore_AgentRolloutUpdates_Call
func (*MockStore_AgentRolloutUpdates_Call) Run ¶ added in v1.22.0
func (_c *MockStore_AgentRolloutUpdates_Call) Run(run func(ctx context.Context)) *MockStore_AgentRolloutUpdates_Call
func (*MockStore_AgentRolloutUpdates_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_AgentRolloutUpdates_Call) RunAndReturn(run func(context.Context) eventbus.Source[store.RolloutEventUpdates]) *MockStore_AgentRolloutUpdates_Call
type MockStore_AgentVersion_Call ¶ added in v1.22.0
MockStore_AgentVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AgentVersion'
func (*MockStore_AgentVersion_Call) Return ¶ added in v1.22.0
func (_c *MockStore_AgentVersion_Call) Return(_a0 *model.AgentVersion, _a1 error) *MockStore_AgentVersion_Call
func (*MockStore_AgentVersion_Call) Run ¶ added in v1.22.0
func (_c *MockStore_AgentVersion_Call) Run(run func(ctx context.Context, name string)) *MockStore_AgentVersion_Call
func (*MockStore_AgentVersion_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_AgentVersion_Call) RunAndReturn(run func(context.Context, string) (*model.AgentVersion, error)) *MockStore_AgentVersion_Call
type MockStore_AgentVersions_Call ¶ added in v1.22.0
MockStore_AgentVersions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AgentVersions'
func (*MockStore_AgentVersions_Call) Return ¶ added in v1.22.0
func (_c *MockStore_AgentVersions_Call) Return(_a0 []*model.AgentVersion, _a1 error) *MockStore_AgentVersions_Call
func (*MockStore_AgentVersions_Call) Run ¶ added in v1.22.0
func (_c *MockStore_AgentVersions_Call) Run(run func(ctx context.Context)) *MockStore_AgentVersions_Call
func (*MockStore_AgentVersions_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_AgentVersions_Call) RunAndReturn(run func(context.Context) ([]*model.AgentVersion, error)) *MockStore_AgentVersions_Call
type MockStore_Agent_Call ¶ added in v1.22.0
MockStore_Agent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Agent'
func (*MockStore_Agent_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Agent_Call) Return(_a0 *model.Agent, _a1 error) *MockStore_Agent_Call
func (*MockStore_Agent_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Agent_Call) Run(run func(ctx context.Context, id string)) *MockStore_Agent_Call
func (*MockStore_Agent_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Agent_Call) RunAndReturn(run func(context.Context, string) (*model.Agent, error)) *MockStore_Agent_Call
type MockStore_AgentsCount_Call ¶ added in v1.22.0
MockStore_AgentsCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AgentsCount'
func (*MockStore_AgentsCount_Call) Return ¶ added in v1.22.0
func (_c *MockStore_AgentsCount_Call) Return(_a0 int, _a1 error) *MockStore_AgentsCount_Call
func (*MockStore_AgentsCount_Call) Run ¶ added in v1.22.0
func (_c *MockStore_AgentsCount_Call) Run(run func(_a0 context.Context, _a1 ...store.QueryOption)) *MockStore_AgentsCount_Call
func (*MockStore_AgentsCount_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_AgentsCount_Call) RunAndReturn(run func(context.Context, ...store.QueryOption) (int, error)) *MockStore_AgentsCount_Call
type MockStore_AgentsIDsMatchingConfiguration_Call ¶ added in v1.22.0
MockStore_AgentsIDsMatchingConfiguration_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AgentsIDsMatchingConfiguration'
func (*MockStore_AgentsIDsMatchingConfiguration_Call) Return ¶ added in v1.22.0
func (_c *MockStore_AgentsIDsMatchingConfiguration_Call) Return(_a0 []string, _a1 error) *MockStore_AgentsIDsMatchingConfiguration_Call
func (*MockStore_AgentsIDsMatchingConfiguration_Call) Run ¶ added in v1.22.0
func (_c *MockStore_AgentsIDsMatchingConfiguration_Call) Run(run func(ctx context.Context, conf *model.Configuration)) *MockStore_AgentsIDsMatchingConfiguration_Call
func (*MockStore_AgentsIDsMatchingConfiguration_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_AgentsIDsMatchingConfiguration_Call) RunAndReturn(run func(context.Context, *model.Configuration) ([]string, error)) *MockStore_AgentsIDsMatchingConfiguration_Call
type MockStore_Agents_Call ¶ added in v1.22.0
MockStore_Agents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Agents'
func (*MockStore_Agents_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Agents_Call) Return(_a0 []*model.Agent, _a1 error) *MockStore_Agents_Call
func (*MockStore_Agents_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Agents_Call) Run(run func(ctx context.Context, options ...store.QueryOption)) *MockStore_Agents_Call
func (*MockStore_Agents_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Agents_Call) RunAndReturn(run func(context.Context, ...store.QueryOption) ([]*model.Agent, error)) *MockStore_Agents_Call
type MockStore_ApplyResources_Call ¶ added in v1.22.0
MockStore_ApplyResources_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ApplyResources'
func (*MockStore_ApplyResources_Call) Return ¶ added in v1.22.0
func (_c *MockStore_ApplyResources_Call) Return(_a0 []model.ResourceStatus, _a1 error) *MockStore_ApplyResources_Call
func (*MockStore_ApplyResources_Call) Run ¶ added in v1.22.0
func (_c *MockStore_ApplyResources_Call) Run(run func(ctx context.Context, resources []model.Resource)) *MockStore_ApplyResources_Call
func (*MockStore_ApplyResources_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_ApplyResources_Call) RunAndReturn(run func(context.Context, []model.Resource) ([]model.ResourceStatus, error)) *MockStore_ApplyResources_Call
type MockStore_CleanupDisconnectedAgents_Call ¶ added in v1.22.0
MockStore_CleanupDisconnectedAgents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CleanupDisconnectedAgents'
func (*MockStore_CleanupDisconnectedAgents_Call) Return ¶ added in v1.22.0
func (_c *MockStore_CleanupDisconnectedAgents_Call) Return(_a0 error) *MockStore_CleanupDisconnectedAgents_Call
func (*MockStore_CleanupDisconnectedAgents_Call) Run ¶ added in v1.22.0
func (_c *MockStore_CleanupDisconnectedAgents_Call) Run(run func(ctx context.Context, since time.Time)) *MockStore_CleanupDisconnectedAgents_Call
func (*MockStore_CleanupDisconnectedAgents_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_CleanupDisconnectedAgents_Call) RunAndReturn(run func(context.Context, time.Time) error) *MockStore_CleanupDisconnectedAgents_Call
type MockStore_Clear_Call ¶ added in v1.22.0
MockStore_Clear_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Clear'
func (*MockStore_Clear_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Clear_Call) Return() *MockStore_Clear_Call
func (*MockStore_Clear_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Clear_Call) Run(run func()) *MockStore_Clear_Call
func (*MockStore_Clear_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Clear_Call) RunAndReturn(run func()) *MockStore_Clear_Call
type MockStore_Close_Call ¶ added in v1.22.0
MockStore_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*MockStore_Close_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Close_Call) Return(_a0 error) *MockStore_Close_Call
func (*MockStore_Close_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Close_Call) Run(run func()) *MockStore_Close_Call
func (*MockStore_Close_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Close_Call) RunAndReturn(run func() error) *MockStore_Close_Call
type MockStore_ConfigurationIndex_Call ¶ added in v1.22.0
MockStore_ConfigurationIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConfigurationIndex'
func (*MockStore_ConfigurationIndex_Call) Return ¶ added in v1.22.0
func (_c *MockStore_ConfigurationIndex_Call) Return(_a0 search.Index) *MockStore_ConfigurationIndex_Call
func (*MockStore_ConfigurationIndex_Call) Run ¶ added in v1.22.0
func (_c *MockStore_ConfigurationIndex_Call) Run(run func(ctx context.Context)) *MockStore_ConfigurationIndex_Call
func (*MockStore_ConfigurationIndex_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_ConfigurationIndex_Call) RunAndReturn(run func(context.Context) search.Index) *MockStore_ConfigurationIndex_Call
type MockStore_Configuration_Call ¶ added in v1.22.0
MockStore_Configuration_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Configuration'
func (*MockStore_Configuration_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Configuration_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_Configuration_Call
func (*MockStore_Configuration_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Configuration_Call) Run(run func(ctx context.Context, name string)) *MockStore_Configuration_Call
func (*MockStore_Configuration_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Configuration_Call) RunAndReturn(run func(context.Context, string) (*model.Configuration, error)) *MockStore_Configuration_Call
type MockStore_Configurations_Call ¶ added in v1.22.0
MockStore_Configurations_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Configurations'
func (*MockStore_Configurations_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Configurations_Call) Return(_a0 []*model.Configuration, _a1 error) *MockStore_Configurations_Call
func (*MockStore_Configurations_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Configurations_Call) Run(run func(ctx context.Context, options ...store.QueryOption)) *MockStore_Configurations_Call
func (*MockStore_Configurations_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Configurations_Call) RunAndReturn(run func(context.Context, ...store.QueryOption) ([]*model.Configuration, error)) *MockStore_Configurations_Call
type MockStore_DeleteAgentVersion_Call ¶ added in v1.22.0
MockStore_DeleteAgentVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteAgentVersion'
func (*MockStore_DeleteAgentVersion_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DeleteAgentVersion_Call) Return(_a0 *model.AgentVersion, _a1 error) *MockStore_DeleteAgentVersion_Call
func (*MockStore_DeleteAgentVersion_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DeleteAgentVersion_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteAgentVersion_Call
func (*MockStore_DeleteAgentVersion_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DeleteAgentVersion_Call) RunAndReturn(run func(context.Context, string) (*model.AgentVersion, error)) *MockStore_DeleteAgentVersion_Call
type MockStore_DeleteAgents_Call ¶ added in v1.22.0
MockStore_DeleteAgents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteAgents'
func (*MockStore_DeleteAgents_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DeleteAgents_Call) Return(_a0 []*model.Agent, _a1 error) *MockStore_DeleteAgents_Call
func (*MockStore_DeleteAgents_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DeleteAgents_Call) Run(run func(ctx context.Context, agentIDs []string)) *MockStore_DeleteAgents_Call
func (*MockStore_DeleteAgents_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DeleteAgents_Call) RunAndReturn(run func(context.Context, []string) ([]*model.Agent, error)) *MockStore_DeleteAgents_Call
type MockStore_DeleteConfiguration_Call ¶ added in v1.22.0
MockStore_DeleteConfiguration_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteConfiguration'
func (*MockStore_DeleteConfiguration_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DeleteConfiguration_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_DeleteConfiguration_Call
func (*MockStore_DeleteConfiguration_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DeleteConfiguration_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteConfiguration_Call
func (*MockStore_DeleteConfiguration_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DeleteConfiguration_Call) RunAndReturn(run func(context.Context, string) (*model.Configuration, error)) *MockStore_DeleteConfiguration_Call
type MockStore_DeleteDestinationType_Call ¶ added in v1.22.0
MockStore_DeleteDestinationType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteDestinationType'
func (*MockStore_DeleteDestinationType_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DeleteDestinationType_Call) Return(_a0 *model.DestinationType, _a1 error) *MockStore_DeleteDestinationType_Call
func (*MockStore_DeleteDestinationType_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DeleteDestinationType_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteDestinationType_Call
func (*MockStore_DeleteDestinationType_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DeleteDestinationType_Call) RunAndReturn(run func(context.Context, string) (*model.DestinationType, error)) *MockStore_DeleteDestinationType_Call
type MockStore_DeleteDestination_Call ¶ added in v1.22.0
MockStore_DeleteDestination_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteDestination'
func (*MockStore_DeleteDestination_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DeleteDestination_Call) Return(_a0 *model.Destination, _a1 error) *MockStore_DeleteDestination_Call
func (*MockStore_DeleteDestination_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DeleteDestination_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteDestination_Call
func (*MockStore_DeleteDestination_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DeleteDestination_Call) RunAndReturn(run func(context.Context, string) (*model.Destination, error)) *MockStore_DeleteDestination_Call
type MockStore_DeleteProcessorType_Call ¶ added in v1.22.0
MockStore_DeleteProcessorType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteProcessorType'
func (*MockStore_DeleteProcessorType_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DeleteProcessorType_Call) Return(_a0 *model.ProcessorType, _a1 error) *MockStore_DeleteProcessorType_Call
func (*MockStore_DeleteProcessorType_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DeleteProcessorType_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteProcessorType_Call
func (*MockStore_DeleteProcessorType_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DeleteProcessorType_Call) RunAndReturn(run func(context.Context, string) (*model.ProcessorType, error)) *MockStore_DeleteProcessorType_Call
type MockStore_DeleteProcessor_Call ¶ added in v1.22.0
MockStore_DeleteProcessor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteProcessor'
func (*MockStore_DeleteProcessor_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DeleteProcessor_Call) Return(_a0 *model.Processor, _a1 error) *MockStore_DeleteProcessor_Call
func (*MockStore_DeleteProcessor_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DeleteProcessor_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteProcessor_Call
func (*MockStore_DeleteProcessor_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DeleteProcessor_Call) RunAndReturn(run func(context.Context, string) (*model.Processor, error)) *MockStore_DeleteProcessor_Call
type MockStore_DeleteResources_Call ¶ added in v1.22.0
MockStore_DeleteResources_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteResources'
func (*MockStore_DeleteResources_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DeleteResources_Call) Return(_a0 []model.ResourceStatus, _a1 error) *MockStore_DeleteResources_Call
func (*MockStore_DeleteResources_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DeleteResources_Call) Run(run func(ctx context.Context, resources []model.Resource)) *MockStore_DeleteResources_Call
func (*MockStore_DeleteResources_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DeleteResources_Call) RunAndReturn(run func(context.Context, []model.Resource) ([]model.ResourceStatus, error)) *MockStore_DeleteResources_Call
type MockStore_DeleteSourceType_Call ¶ added in v1.22.0
MockStore_DeleteSourceType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteSourceType'
func (*MockStore_DeleteSourceType_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DeleteSourceType_Call) Return(_a0 *model.SourceType, _a1 error) *MockStore_DeleteSourceType_Call
func (*MockStore_DeleteSourceType_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DeleteSourceType_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteSourceType_Call
func (*MockStore_DeleteSourceType_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DeleteSourceType_Call) RunAndReturn(run func(context.Context, string) (*model.SourceType, error)) *MockStore_DeleteSourceType_Call
type MockStore_DeleteSource_Call ¶ added in v1.22.0
MockStore_DeleteSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteSource'
func (*MockStore_DeleteSource_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DeleteSource_Call) Return(_a0 *model.Source, _a1 error) *MockStore_DeleteSource_Call
func (*MockStore_DeleteSource_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DeleteSource_Call) Run(run func(ctx context.Context, name string)) *MockStore_DeleteSource_Call
func (*MockStore_DeleteSource_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DeleteSource_Call) RunAndReturn(run func(context.Context, string) (*model.Source, error)) *MockStore_DeleteSource_Call
type MockStore_DestinationType_Call ¶ added in v1.22.0
MockStore_DestinationType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DestinationType'
func (*MockStore_DestinationType_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DestinationType_Call) Return(_a0 *model.DestinationType, _a1 error) *MockStore_DestinationType_Call
func (*MockStore_DestinationType_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DestinationType_Call) Run(run func(ctx context.Context, name string)) *MockStore_DestinationType_Call
func (*MockStore_DestinationType_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DestinationType_Call) RunAndReturn(run func(context.Context, string) (*model.DestinationType, error)) *MockStore_DestinationType_Call
type MockStore_DestinationTypes_Call ¶ added in v1.22.0
MockStore_DestinationTypes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DestinationTypes'
func (*MockStore_DestinationTypes_Call) Return ¶ added in v1.22.0
func (_c *MockStore_DestinationTypes_Call) Return(_a0 []*model.DestinationType, _a1 error) *MockStore_DestinationTypes_Call
func (*MockStore_DestinationTypes_Call) Run ¶ added in v1.22.0
func (_c *MockStore_DestinationTypes_Call) Run(run func(ctx context.Context)) *MockStore_DestinationTypes_Call
func (*MockStore_DestinationTypes_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_DestinationTypes_Call) RunAndReturn(run func(context.Context) ([]*model.DestinationType, error)) *MockStore_DestinationTypes_Call
type MockStore_Destination_Call ¶ added in v1.22.0
MockStore_Destination_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Destination'
func (*MockStore_Destination_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Destination_Call) Return(_a0 *model.Destination, _a1 error) *MockStore_Destination_Call
func (*MockStore_Destination_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Destination_Call) Run(run func(ctx context.Context, name string)) *MockStore_Destination_Call
func (*MockStore_Destination_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Destination_Call) RunAndReturn(run func(context.Context, string) (*model.Destination, error)) *MockStore_Destination_Call
type MockStore_Destinations_Call ¶ added in v1.22.0
MockStore_Destinations_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Destinations'
func (*MockStore_Destinations_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Destinations_Call) Return(_a0 []*model.Destination, _a1 error) *MockStore_Destinations_Call
func (*MockStore_Destinations_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Destinations_Call) Run(run func(ctx context.Context)) *MockStore_Destinations_Call
func (*MockStore_Destinations_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Destinations_Call) RunAndReturn(run func(context.Context) ([]*model.Destination, error)) *MockStore_Destinations_Call
type MockStore_DisconnectUnreportedAgents_Call ¶ added in v1.23.0
MockStore_DisconnectUnreportedAgents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DisconnectUnreportedAgents'
func (*MockStore_DisconnectUnreportedAgents_Call) Return ¶ added in v1.23.0
func (_c *MockStore_DisconnectUnreportedAgents_Call) Return(_a0 error) *MockStore_DisconnectUnreportedAgents_Call
func (*MockStore_DisconnectUnreportedAgents_Call) Run ¶ added in v1.23.0
func (_c *MockStore_DisconnectUnreportedAgents_Call) Run(run func(ctx context.Context, since time.Time)) *MockStore_DisconnectUnreportedAgents_Call
func (*MockStore_DisconnectUnreportedAgents_Call) RunAndReturn ¶ added in v1.23.0
func (_c *MockStore_DisconnectUnreportedAgents_Call) RunAndReturn(run func(context.Context, time.Time) error) *MockStore_DisconnectUnreportedAgents_Call
type MockStore_Expecter ¶ added in v1.22.0
type MockStore_Expecter struct {
// contains filtered or unexported fields
}
func (*MockStore_Expecter) Agent ¶ added in v1.22.0
func (_e *MockStore_Expecter) Agent(ctx interface{}, id interface{}) *MockStore_Agent_Call
Agent is a helper method to define mock.On call
- ctx context.Context
- id string
func (*MockStore_Expecter) AgentConfiguration ¶ added in v1.22.0
func (_e *MockStore_Expecter) AgentConfiguration(ctx interface{}, agent interface{}) *MockStore_AgentConfiguration_Call
AgentConfiguration is a helper method to define mock.On call
- ctx context.Context
- agent *model.Agent
func (*MockStore_Expecter) AgentIndex ¶ added in v1.22.0
func (_e *MockStore_Expecter) AgentIndex(ctx interface{}) *MockStore_AgentIndex_Call
AgentIndex is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) AgentRolloutUpdates ¶ added in v1.22.0
func (_e *MockStore_Expecter) AgentRolloutUpdates(ctx interface{}) *MockStore_AgentRolloutUpdates_Call
AgentRolloutUpdates is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) AgentVersion ¶ added in v1.22.0
func (_e *MockStore_Expecter) AgentVersion(ctx interface{}, name interface{}) *MockStore_AgentVersion_Call
AgentVersion is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) AgentVersions ¶ added in v1.22.0
func (_e *MockStore_Expecter) AgentVersions(ctx interface{}) *MockStore_AgentVersions_Call
AgentVersions is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) Agents ¶ added in v1.22.0
func (_e *MockStore_Expecter) Agents(ctx interface{}, options ...interface{}) *MockStore_Agents_Call
Agents is a helper method to define mock.On call
- ctx context.Context
- options ...store.QueryOption
func (*MockStore_Expecter) AgentsCount ¶ added in v1.22.0
func (_e *MockStore_Expecter) AgentsCount(_a0 interface{}, _a1 ...interface{}) *MockStore_AgentsCount_Call
AgentsCount is a helper method to define mock.On call
- _a0 context.Context
- _a1 ...store.QueryOption
func (*MockStore_Expecter) AgentsIDsMatchingConfiguration ¶ added in v1.22.0
func (_e *MockStore_Expecter) AgentsIDsMatchingConfiguration(ctx interface{}, conf interface{}) *MockStore_AgentsIDsMatchingConfiguration_Call
AgentsIDsMatchingConfiguration is a helper method to define mock.On call
- ctx context.Context
- conf *model.Configuration
func (*MockStore_Expecter) ApplyResources ¶ added in v1.22.0
func (_e *MockStore_Expecter) ApplyResources(ctx interface{}, resources interface{}) *MockStore_ApplyResources_Call
ApplyResources is a helper method to define mock.On call
- ctx context.Context
- resources []model.Resource
func (*MockStore_Expecter) CleanupDisconnectedAgents ¶ added in v1.22.0
func (_e *MockStore_Expecter) CleanupDisconnectedAgents(ctx interface{}, since interface{}) *MockStore_CleanupDisconnectedAgents_Call
CleanupDisconnectedAgents is a helper method to define mock.On call
- ctx context.Context
- since time.Time
func (*MockStore_Expecter) Clear ¶ added in v1.22.0
func (_e *MockStore_Expecter) Clear() *MockStore_Clear_Call
Clear is a helper method to define mock.On call
func (*MockStore_Expecter) Close ¶ added in v1.22.0
func (_e *MockStore_Expecter) Close() *MockStore_Close_Call
Close is a helper method to define mock.On call
func (*MockStore_Expecter) Configuration ¶ added in v1.22.0
func (_e *MockStore_Expecter) Configuration(ctx interface{}, name interface{}) *MockStore_Configuration_Call
Configuration is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) ConfigurationIndex ¶ added in v1.22.0
func (_e *MockStore_Expecter) ConfigurationIndex(ctx interface{}) *MockStore_ConfigurationIndex_Call
ConfigurationIndex is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) Configurations ¶ added in v1.22.0
func (_e *MockStore_Expecter) Configurations(ctx interface{}, options ...interface{}) *MockStore_Configurations_Call
Configurations is a helper method to define mock.On call
- ctx context.Context
- options ...store.QueryOption
func (*MockStore_Expecter) DeleteAgentVersion ¶ added in v1.22.0
func (_e *MockStore_Expecter) DeleteAgentVersion(ctx interface{}, name interface{}) *MockStore_DeleteAgentVersion_Call
DeleteAgentVersion is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) DeleteAgents ¶ added in v1.22.0
func (_e *MockStore_Expecter) DeleteAgents(ctx interface{}, agentIDs interface{}) *MockStore_DeleteAgents_Call
DeleteAgents is a helper method to define mock.On call
- ctx context.Context
- agentIDs []string
func (*MockStore_Expecter) DeleteConfiguration ¶ added in v1.22.0
func (_e *MockStore_Expecter) DeleteConfiguration(ctx interface{}, name interface{}) *MockStore_DeleteConfiguration_Call
DeleteConfiguration is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) DeleteDestination ¶ added in v1.22.0
func (_e *MockStore_Expecter) DeleteDestination(ctx interface{}, name interface{}) *MockStore_DeleteDestination_Call
DeleteDestination is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) DeleteDestinationType ¶ added in v1.22.0
func (_e *MockStore_Expecter) DeleteDestinationType(ctx interface{}, name interface{}) *MockStore_DeleteDestinationType_Call
DeleteDestinationType is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) DeleteProcessor ¶ added in v1.22.0
func (_e *MockStore_Expecter) DeleteProcessor(ctx interface{}, name interface{}) *MockStore_DeleteProcessor_Call
DeleteProcessor is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) DeleteProcessorType ¶ added in v1.22.0
func (_e *MockStore_Expecter) DeleteProcessorType(ctx interface{}, name interface{}) *MockStore_DeleteProcessorType_Call
DeleteProcessorType is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) DeleteResources ¶ added in v1.22.0
func (_e *MockStore_Expecter) DeleteResources(ctx interface{}, resources interface{}) *MockStore_DeleteResources_Call
DeleteResources is a helper method to define mock.On call
- ctx context.Context
- resources []model.Resource
func (*MockStore_Expecter) DeleteSource ¶ added in v1.22.0
func (_e *MockStore_Expecter) DeleteSource(ctx interface{}, name interface{}) *MockStore_DeleteSource_Call
DeleteSource is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) DeleteSourceType ¶ added in v1.22.0
func (_e *MockStore_Expecter) DeleteSourceType(ctx interface{}, name interface{}) *MockStore_DeleteSourceType_Call
DeleteSourceType is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) Destination ¶ added in v1.22.0
func (_e *MockStore_Expecter) Destination(ctx interface{}, name interface{}) *MockStore_Destination_Call
Destination is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) DestinationType ¶ added in v1.22.0
func (_e *MockStore_Expecter) DestinationType(ctx interface{}, name interface{}) *MockStore_DestinationType_Call
DestinationType is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) DestinationTypes ¶ added in v1.22.0
func (_e *MockStore_Expecter) DestinationTypes(ctx interface{}) *MockStore_DestinationTypes_Call
DestinationTypes is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) Destinations ¶ added in v1.22.0
func (_e *MockStore_Expecter) Destinations(ctx interface{}) *MockStore_Destinations_Call
Destinations is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) DisconnectUnreportedAgents ¶ added in v1.23.0
func (_e *MockStore_Expecter) DisconnectUnreportedAgents(ctx interface{}, since interface{}) *MockStore_DisconnectUnreportedAgents_Call
DisconnectUnreportedAgents is a helper method to define mock.On call
- ctx context.Context
- since time.Time
func (*MockStore_Expecter) Measurements ¶ added in v1.22.0
func (_e *MockStore_Expecter) Measurements() *MockStore_Measurements_Call
Measurements is a helper method to define mock.On call
func (*MockStore_Expecter) PauseRollout ¶ added in v1.22.0
func (_e *MockStore_Expecter) PauseRollout(ctx interface{}, configurationName interface{}) *MockStore_PauseRollout_Call
PauseRollout is a helper method to define mock.On call
- ctx context.Context
- configurationName string
func (*MockStore_Expecter) Processor ¶ added in v1.22.0
func (_e *MockStore_Expecter) Processor(ctx interface{}, name interface{}) *MockStore_Processor_Call
Processor is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) ProcessorType ¶ added in v1.22.0
func (_e *MockStore_Expecter) ProcessorType(ctx interface{}, name interface{}) *MockStore_ProcessorType_Call
ProcessorType is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) ProcessorTypes ¶ added in v1.22.0
func (_e *MockStore_Expecter) ProcessorTypes(ctx interface{}) *MockStore_ProcessorTypes_Call
ProcessorTypes is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) Processors ¶ added in v1.22.0
func (_e *MockStore_Expecter) Processors(ctx interface{}) *MockStore_Processors_Call
Processors is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) ReportConnectedAgents ¶ added in v1.23.0
func (_e *MockStore_Expecter) ReportConnectedAgents(ctx interface{}, agentIDs interface{}, _a2 interface{}) *MockStore_ReportConnectedAgents_Call
ReportConnectedAgents is a helper method to define mock.On call
- ctx context.Context
- agentIDs []string
- _a2 time.Time
func (*MockStore_Expecter) ResourceHistory ¶ added in v1.22.0
func (_e *MockStore_Expecter) ResourceHistory(ctx interface{}, resourceKind interface{}, resourceName interface{}) *MockStore_ResourceHistory_Call
ResourceHistory is a helper method to define mock.On call
- ctx context.Context
- resourceKind model.Kind
- resourceName string
func (*MockStore_Expecter) ResumeRollout ¶ added in v1.22.0
func (_e *MockStore_Expecter) ResumeRollout(ctx interface{}, configurationName interface{}) *MockStore_ResumeRollout_Call
ResumeRollout is a helper method to define mock.On call
- ctx context.Context
- configurationName string
func (*MockStore_Expecter) Source ¶ added in v1.22.0
func (_e *MockStore_Expecter) Source(ctx interface{}, name interface{}) *MockStore_Source_Call
Source is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) SourceType ¶ added in v1.22.0
func (_e *MockStore_Expecter) SourceType(ctx interface{}, name interface{}) *MockStore_SourceType_Call
SourceType is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockStore_Expecter) SourceTypes ¶ added in v1.22.0
func (_e *MockStore_Expecter) SourceTypes(ctx interface{}) *MockStore_SourceTypes_Call
SourceTypes is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) Sources ¶ added in v1.22.0
func (_e *MockStore_Expecter) Sources(ctx interface{}) *MockStore_Sources_Call
Sources is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) StartRollout ¶ added in v1.22.0
func (_e *MockStore_Expecter) StartRollout(ctx interface{}, configurationName interface{}, options interface{}) *MockStore_StartRollout_Call
StartRollout is a helper method to define mock.On call
- ctx context.Context
- configurationName string
- options *model.RolloutOptions
func (*MockStore_Expecter) UpdateAgent ¶ added in v1.24.0
func (_e *MockStore_Expecter) UpdateAgent(ctx interface{}, agentID interface{}, updater interface{}) *MockStore_UpdateAgent_Call
UpdateAgent is a helper method to define mock.On call
- ctx context.Context
- agentID string
- updater store.AgentUpdater
func (*MockStore_Expecter) UpdateAgents ¶ added in v1.24.0
func (_e *MockStore_Expecter) UpdateAgents(ctx interface{}, agentIDs interface{}, updater interface{}) *MockStore_UpdateAgents_Call
UpdateAgents is a helper method to define mock.On call
- ctx context.Context
- agentIDs []string
- updater store.AgentUpdater
func (*MockStore_Expecter) UpdateAllRollouts ¶ added in v1.22.0
func (_e *MockStore_Expecter) UpdateAllRollouts(ctx interface{}) *MockStore_UpdateAllRollouts_Call
UpdateAllRollouts is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) UpdateConfiguration ¶ added in v1.22.0
func (_e *MockStore_Expecter) UpdateConfiguration(ctx interface{}, name interface{}, updater interface{}) *MockStore_UpdateConfiguration_Call
UpdateConfiguration is a helper method to define mock.On call
- ctx context.Context
- name string
- updater store.ConfigurationUpdater
func (*MockStore_Expecter) UpdateRollout ¶ added in v1.22.0
func (_e *MockStore_Expecter) UpdateRollout(ctx interface{}, configurationName interface{}) *MockStore_UpdateRollout_Call
UpdateRollout is a helper method to define mock.On call
- ctx context.Context
- configurationName string
func (*MockStore_Expecter) UpdateRollouts ¶ added in v1.22.0
func (_e *MockStore_Expecter) UpdateRollouts(ctx interface{}) *MockStore_UpdateRollouts_Call
UpdateRollouts is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) Updates ¶ added in v1.22.0
func (_e *MockStore_Expecter) Updates(ctx interface{}) *MockStore_Updates_Call
Updates is a helper method to define mock.On call
- ctx context.Context
func (*MockStore_Expecter) UpsertAgent ¶ added in v1.22.0
func (_e *MockStore_Expecter) UpsertAgent(ctx interface{}, agentID interface{}, updater interface{}) *MockStore_UpsertAgent_Call
UpsertAgent is a helper method to define mock.On call
- ctx context.Context
- agentID string
- updater store.AgentUpdater
func (*MockStore_Expecter) UpsertAgents ¶ added in v1.22.0
func (_e *MockStore_Expecter) UpsertAgents(ctx interface{}, agentIDs interface{}, updater interface{}) *MockStore_UpsertAgents_Call
UpsertAgents is a helper method to define mock.On call
- ctx context.Context
- agentIDs []string
- updater store.AgentUpdater
func (*MockStore_Expecter) UserSessions ¶ added in v1.22.0
func (_e *MockStore_Expecter) UserSessions() *MockStore_UserSessions_Call
UserSessions is a helper method to define mock.On call
type MockStore_Measurements_Call ¶ added in v1.22.0
MockStore_Measurements_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Measurements'
func (*MockStore_Measurements_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Measurements_Call) Return(_a0 stats.Measurements) *MockStore_Measurements_Call
func (*MockStore_Measurements_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Measurements_Call) Run(run func()) *MockStore_Measurements_Call
func (*MockStore_Measurements_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Measurements_Call) RunAndReturn(run func() stats.Measurements) *MockStore_Measurements_Call
type MockStore_PauseRollout_Call ¶ added in v1.22.0
MockStore_PauseRollout_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PauseRollout'
func (*MockStore_PauseRollout_Call) Return ¶ added in v1.22.0
func (_c *MockStore_PauseRollout_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_PauseRollout_Call
func (*MockStore_PauseRollout_Call) Run ¶ added in v1.22.0
func (_c *MockStore_PauseRollout_Call) Run(run func(ctx context.Context, configurationName string)) *MockStore_PauseRollout_Call
func (*MockStore_PauseRollout_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_PauseRollout_Call) RunAndReturn(run func(context.Context, string) (*model.Configuration, error)) *MockStore_PauseRollout_Call
type MockStore_ProcessorType_Call ¶ added in v1.22.0
MockStore_ProcessorType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessorType'
func (*MockStore_ProcessorType_Call) Return ¶ added in v1.22.0
func (_c *MockStore_ProcessorType_Call) Return(_a0 *model.ProcessorType, _a1 error) *MockStore_ProcessorType_Call
func (*MockStore_ProcessorType_Call) Run ¶ added in v1.22.0
func (_c *MockStore_ProcessorType_Call) Run(run func(ctx context.Context, name string)) *MockStore_ProcessorType_Call
func (*MockStore_ProcessorType_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_ProcessorType_Call) RunAndReturn(run func(context.Context, string) (*model.ProcessorType, error)) *MockStore_ProcessorType_Call
type MockStore_ProcessorTypes_Call ¶ added in v1.22.0
MockStore_ProcessorTypes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessorTypes'
func (*MockStore_ProcessorTypes_Call) Return ¶ added in v1.22.0
func (_c *MockStore_ProcessorTypes_Call) Return(_a0 []*model.ProcessorType, _a1 error) *MockStore_ProcessorTypes_Call
func (*MockStore_ProcessorTypes_Call) Run ¶ added in v1.22.0
func (_c *MockStore_ProcessorTypes_Call) Run(run func(ctx context.Context)) *MockStore_ProcessorTypes_Call
func (*MockStore_ProcessorTypes_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_ProcessorTypes_Call) RunAndReturn(run func(context.Context) ([]*model.ProcessorType, error)) *MockStore_ProcessorTypes_Call
type MockStore_Processor_Call ¶ added in v1.22.0
MockStore_Processor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Processor'
func (*MockStore_Processor_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Processor_Call) Return(_a0 *model.Processor, _a1 error) *MockStore_Processor_Call
func (*MockStore_Processor_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Processor_Call) Run(run func(ctx context.Context, name string)) *MockStore_Processor_Call
func (*MockStore_Processor_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Processor_Call) RunAndReturn(run func(context.Context, string) (*model.Processor, error)) *MockStore_Processor_Call
type MockStore_Processors_Call ¶ added in v1.22.0
MockStore_Processors_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Processors'
func (*MockStore_Processors_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Processors_Call) Return(_a0 []*model.Processor, _a1 error) *MockStore_Processors_Call
func (*MockStore_Processors_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Processors_Call) Run(run func(ctx context.Context)) *MockStore_Processors_Call
func (*MockStore_Processors_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Processors_Call) RunAndReturn(run func(context.Context) ([]*model.Processor, error)) *MockStore_Processors_Call
type MockStore_ReportConnectedAgents_Call ¶ added in v1.23.0
MockStore_ReportConnectedAgents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReportConnectedAgents'
func (*MockStore_ReportConnectedAgents_Call) Return ¶ added in v1.23.0
func (_c *MockStore_ReportConnectedAgents_Call) Return(_a0 error) *MockStore_ReportConnectedAgents_Call
func (*MockStore_ReportConnectedAgents_Call) Run ¶ added in v1.23.0
func (_c *MockStore_ReportConnectedAgents_Call) Run(run func(ctx context.Context, agentIDs []string, _a2 time.Time)) *MockStore_ReportConnectedAgents_Call
func (*MockStore_ReportConnectedAgents_Call) RunAndReturn ¶ added in v1.23.0
func (_c *MockStore_ReportConnectedAgents_Call) RunAndReturn(run func(context.Context, []string, time.Time) error) *MockStore_ReportConnectedAgents_Call
type MockStore_ResourceHistory_Call ¶ added in v1.22.0
MockStore_ResourceHistory_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ResourceHistory'
func (*MockStore_ResourceHistory_Call) Return ¶ added in v1.22.0
func (_c *MockStore_ResourceHistory_Call) Return(_a0 []*model.AnyResource, _a1 error) *MockStore_ResourceHistory_Call
func (*MockStore_ResourceHistory_Call) Run ¶ added in v1.22.0
func (_c *MockStore_ResourceHistory_Call) Run(run func(ctx context.Context, resourceKind model.Kind, resourceName string)) *MockStore_ResourceHistory_Call
func (*MockStore_ResourceHistory_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_ResourceHistory_Call) RunAndReturn(run func(context.Context, model.Kind, string) ([]*model.AnyResource, error)) *MockStore_ResourceHistory_Call
type MockStore_ResumeRollout_Call ¶ added in v1.22.0
MockStore_ResumeRollout_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ResumeRollout'
func (*MockStore_ResumeRollout_Call) Return ¶ added in v1.22.0
func (_c *MockStore_ResumeRollout_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_ResumeRollout_Call
func (*MockStore_ResumeRollout_Call) Run ¶ added in v1.22.0
func (_c *MockStore_ResumeRollout_Call) Run(run func(ctx context.Context, configurationName string)) *MockStore_ResumeRollout_Call
func (*MockStore_ResumeRollout_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_ResumeRollout_Call) RunAndReturn(run func(context.Context, string) (*model.Configuration, error)) *MockStore_ResumeRollout_Call
type MockStore_SourceType_Call ¶ added in v1.22.0
MockStore_SourceType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SourceType'
func (*MockStore_SourceType_Call) Return ¶ added in v1.22.0
func (_c *MockStore_SourceType_Call) Return(_a0 *model.SourceType, _a1 error) *MockStore_SourceType_Call
func (*MockStore_SourceType_Call) Run ¶ added in v1.22.0
func (_c *MockStore_SourceType_Call) Run(run func(ctx context.Context, name string)) *MockStore_SourceType_Call
func (*MockStore_SourceType_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_SourceType_Call) RunAndReturn(run func(context.Context, string) (*model.SourceType, error)) *MockStore_SourceType_Call
type MockStore_SourceTypes_Call ¶ added in v1.22.0
MockStore_SourceTypes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SourceTypes'
func (*MockStore_SourceTypes_Call) Return ¶ added in v1.22.0
func (_c *MockStore_SourceTypes_Call) Return(_a0 []*model.SourceType, _a1 error) *MockStore_SourceTypes_Call
func (*MockStore_SourceTypes_Call) Run ¶ added in v1.22.0
func (_c *MockStore_SourceTypes_Call) Run(run func(ctx context.Context)) *MockStore_SourceTypes_Call
func (*MockStore_SourceTypes_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_SourceTypes_Call) RunAndReturn(run func(context.Context) ([]*model.SourceType, error)) *MockStore_SourceTypes_Call
type MockStore_Source_Call ¶ added in v1.22.0
MockStore_Source_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Source'
func (*MockStore_Source_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Source_Call) Return(_a0 *model.Source, _a1 error) *MockStore_Source_Call
func (*MockStore_Source_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Source_Call) Run(run func(ctx context.Context, name string)) *MockStore_Source_Call
func (*MockStore_Source_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Source_Call) RunAndReturn(run func(context.Context, string) (*model.Source, error)) *MockStore_Source_Call
type MockStore_Sources_Call ¶ added in v1.22.0
MockStore_Sources_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Sources'
func (*MockStore_Sources_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Sources_Call) Return(_a0 []*model.Source, _a1 error) *MockStore_Sources_Call
func (*MockStore_Sources_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Sources_Call) Run(run func(ctx context.Context)) *MockStore_Sources_Call
func (*MockStore_Sources_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Sources_Call) RunAndReturn(run func(context.Context) ([]*model.Source, error)) *MockStore_Sources_Call
type MockStore_StartRollout_Call ¶ added in v1.22.0
MockStore_StartRollout_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartRollout'
func (*MockStore_StartRollout_Call) Return ¶ added in v1.22.0
func (_c *MockStore_StartRollout_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_StartRollout_Call
func (*MockStore_StartRollout_Call) Run ¶ added in v1.22.0
func (_c *MockStore_StartRollout_Call) Run(run func(ctx context.Context, configurationName string, options *model.RolloutOptions)) *MockStore_StartRollout_Call
func (*MockStore_StartRollout_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_StartRollout_Call) RunAndReturn(run func(context.Context, string, *model.RolloutOptions) (*model.Configuration, error)) *MockStore_StartRollout_Call
type MockStore_UpdateAgent_Call ¶ added in v1.24.0
MockStore_UpdateAgent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateAgent'
func (*MockStore_UpdateAgent_Call) Return ¶ added in v1.24.0
func (_c *MockStore_UpdateAgent_Call) Return(_a0 *model.Agent, _a1 error) *MockStore_UpdateAgent_Call
func (*MockStore_UpdateAgent_Call) Run ¶ added in v1.24.0
func (_c *MockStore_UpdateAgent_Call) Run(run func(ctx context.Context, agentID string, updater store.AgentUpdater)) *MockStore_UpdateAgent_Call
func (*MockStore_UpdateAgent_Call) RunAndReturn ¶ added in v1.24.0
func (_c *MockStore_UpdateAgent_Call) RunAndReturn(run func(context.Context, string, store.AgentUpdater) (*model.Agent, error)) *MockStore_UpdateAgent_Call
type MockStore_UpdateAgents_Call ¶ added in v1.24.0
MockStore_UpdateAgents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateAgents'
func (*MockStore_UpdateAgents_Call) Return ¶ added in v1.24.0
func (_c *MockStore_UpdateAgents_Call) Return(_a0 []*model.Agent, _a1 error) *MockStore_UpdateAgents_Call
func (*MockStore_UpdateAgents_Call) Run ¶ added in v1.24.0
func (_c *MockStore_UpdateAgents_Call) Run(run func(ctx context.Context, agentIDs []string, updater store.AgentUpdater)) *MockStore_UpdateAgents_Call
func (*MockStore_UpdateAgents_Call) RunAndReturn ¶ added in v1.24.0
func (_c *MockStore_UpdateAgents_Call) RunAndReturn(run func(context.Context, []string, store.AgentUpdater) ([]*model.Agent, error)) *MockStore_UpdateAgents_Call
type MockStore_UpdateAllRollouts_Call ¶ added in v1.22.0
MockStore_UpdateAllRollouts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateAllRollouts'
func (*MockStore_UpdateAllRollouts_Call) Return ¶ added in v1.22.0
func (_c *MockStore_UpdateAllRollouts_Call) Return(_a0 error) *MockStore_UpdateAllRollouts_Call
func (*MockStore_UpdateAllRollouts_Call) Run ¶ added in v1.22.0
func (_c *MockStore_UpdateAllRollouts_Call) Run(run func(ctx context.Context)) *MockStore_UpdateAllRollouts_Call
func (*MockStore_UpdateAllRollouts_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_UpdateAllRollouts_Call) RunAndReturn(run func(context.Context) error) *MockStore_UpdateAllRollouts_Call
type MockStore_UpdateConfiguration_Call ¶ added in v1.22.0
MockStore_UpdateConfiguration_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateConfiguration'
func (*MockStore_UpdateConfiguration_Call) Return ¶ added in v1.22.0
func (_c *MockStore_UpdateConfiguration_Call) Return(config *model.Configuration, status model.UpdateStatus, err error) *MockStore_UpdateConfiguration_Call
func (*MockStore_UpdateConfiguration_Call) Run ¶ added in v1.22.0
func (_c *MockStore_UpdateConfiguration_Call) Run(run func(ctx context.Context, name string, updater store.ConfigurationUpdater)) *MockStore_UpdateConfiguration_Call
func (*MockStore_UpdateConfiguration_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_UpdateConfiguration_Call) RunAndReturn(run func(context.Context, string, store.ConfigurationUpdater) (*model.Configuration, model.UpdateStatus, error)) *MockStore_UpdateConfiguration_Call
type MockStore_UpdateRollout_Call ¶ added in v1.22.0
MockStore_UpdateRollout_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateRollout'
func (*MockStore_UpdateRollout_Call) Return ¶ added in v1.22.0
func (_c *MockStore_UpdateRollout_Call) Return(_a0 *model.Configuration, _a1 error) *MockStore_UpdateRollout_Call
func (*MockStore_UpdateRollout_Call) Run ¶ added in v1.22.0
func (_c *MockStore_UpdateRollout_Call) Run(run func(ctx context.Context, configurationName string)) *MockStore_UpdateRollout_Call
func (*MockStore_UpdateRollout_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_UpdateRollout_Call) RunAndReturn(run func(context.Context, string) (*model.Configuration, error)) *MockStore_UpdateRollout_Call
type MockStore_UpdateRollouts_Call ¶ added in v1.22.0
MockStore_UpdateRollouts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateRollouts'
func (*MockStore_UpdateRollouts_Call) Return ¶ added in v1.22.0
func (_c *MockStore_UpdateRollouts_Call) Return(_a0 []*model.Configuration, _a1 error) *MockStore_UpdateRollouts_Call
func (*MockStore_UpdateRollouts_Call) Run ¶ added in v1.22.0
func (_c *MockStore_UpdateRollouts_Call) Run(run func(ctx context.Context)) *MockStore_UpdateRollouts_Call
func (*MockStore_UpdateRollouts_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_UpdateRollouts_Call) RunAndReturn(run func(context.Context) ([]*model.Configuration, error)) *MockStore_UpdateRollouts_Call
type MockStore_Updates_Call ¶ added in v1.22.0
MockStore_Updates_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Updates'
func (*MockStore_Updates_Call) Return ¶ added in v1.22.0
func (_c *MockStore_Updates_Call) Return(_a0 eventbus.Source[store.BasicEventUpdates]) *MockStore_Updates_Call
func (*MockStore_Updates_Call) Run ¶ added in v1.22.0
func (_c *MockStore_Updates_Call) Run(run func(ctx context.Context)) *MockStore_Updates_Call
func (*MockStore_Updates_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_Updates_Call) RunAndReturn(run func(context.Context) eventbus.Source[store.BasicEventUpdates]) *MockStore_Updates_Call
type MockStore_UpsertAgent_Call ¶ added in v1.22.0
MockStore_UpsertAgent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpsertAgent'
func (*MockStore_UpsertAgent_Call) Return ¶ added in v1.22.0
func (_c *MockStore_UpsertAgent_Call) Return(_a0 *model.Agent, _a1 error) *MockStore_UpsertAgent_Call
func (*MockStore_UpsertAgent_Call) Run ¶ added in v1.22.0
func (_c *MockStore_UpsertAgent_Call) Run(run func(ctx context.Context, agentID string, updater store.AgentUpdater)) *MockStore_UpsertAgent_Call
func (*MockStore_UpsertAgent_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_UpsertAgent_Call) RunAndReturn(run func(context.Context, string, store.AgentUpdater) (*model.Agent, error)) *MockStore_UpsertAgent_Call
type MockStore_UpsertAgents_Call ¶ added in v1.22.0
MockStore_UpsertAgents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpsertAgents'
func (*MockStore_UpsertAgents_Call) Return ¶ added in v1.22.0
func (_c *MockStore_UpsertAgents_Call) Return(_a0 []*model.Agent, _a1 error) *MockStore_UpsertAgents_Call
func (*MockStore_UpsertAgents_Call) Run ¶ added in v1.22.0
func (_c *MockStore_UpsertAgents_Call) Run(run func(ctx context.Context, agentIDs []string, updater store.AgentUpdater)) *MockStore_UpsertAgents_Call
func (*MockStore_UpsertAgents_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_UpsertAgents_Call) RunAndReturn(run func(context.Context, []string, store.AgentUpdater) ([]*model.Agent, error)) *MockStore_UpsertAgents_Call
type MockStore_UserSessions_Call ¶ added in v1.22.0
MockStore_UserSessions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UserSessions'
func (*MockStore_UserSessions_Call) Return ¶ added in v1.22.0
func (_c *MockStore_UserSessions_Call) Return(_a0 sessions.Store) *MockStore_UserSessions_Call
func (*MockStore_UserSessions_Call) Run ¶ added in v1.22.0
func (_c *MockStore_UserSessions_Call) Run(run func()) *MockStore_UserSessions_Call
func (*MockStore_UserSessions_Call) RunAndReturn ¶ added in v1.22.0
func (_c *MockStore_UserSessions_Call) RunAndReturn(run func() sessions.Store) *MockStore_UserSessions_Call