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) 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) 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) 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 MockSystemStore
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 mockConstructorTestingTNewMockArchiveStore) *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.
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 ¶
func NewMockStore(t mockConstructorTestingTNewMockStore) *MockStore
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.
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) 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) 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) 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 MockSystemStore ¶
MockSystemStore is an autogenerated mock type for the SystemStore type
func NewMockSystemStore ¶
func NewMockSystemStore(t mockConstructorTestingTNewMockSystemStore) *MockSystemStore
NewMockSystemStore creates a new instance of MockSystemStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*MockSystemStore) UpdateAllRollouts ¶
func (_m *MockSystemStore) UpdateAllRollouts(ctx context.Context) error
UpdateAllRollouts provides a mock function with given fields: ctx