store

Sep 26, 2023

Changes in this version

+ func ApplyOffsetAndLimit(list []T, opts QueryOptions) []T

Sep 13, 2023

Changes in this version

type BoltstoreCore

+ func (s *BoltstoreCore) AssignConfigurationToAgent(ctx context.Context, configuration *model.Configuration, agent *model.Agent) (newConfiguration *model.Configuration, err error)

Sep 1, 2023

Changes in this version

+ const DefaultRolloutBatchFlushInterval

type BoltstoreCore

+ RolloutBatcher RolloutBatcher

+ func (s *BoltstoreCore) UpdateAgentStatus(ctx context.Context, agentID string, status model.AgentStatus) error

+ type DefaultRolloutBatcher struct

+ func NewDefaultBatcher(ctx context.Context, logger *zap.Logger, flushInterval time.Duration, s Store) *DefaultRolloutBatcher

+ func (d *DefaultRolloutBatcher) Batch(ctx context.Context, agentEvents Events[*model.Agent]) error

+ func (d *DefaultRolloutBatcher) Shutdown(ctx context.Context) error

+ type NopRolloutBatcher struct

+ func NewNopRolloutBatcher() *NopRolloutBatcher

+ func (n *NopRolloutBatcher) Batch(_ context.Context, _ Events[*model.Agent]) error

+ func (n *NopRolloutBatcher) Shutdown(_ context.Context) error

+ type RolloutBatcher interface

+ Batch func(ctx context.Context, agentEvents Events[*model.Agent]) error

+ Shutdown func(ctx context.Context) error

+ type RolloutEventBatch map[string]struct

+ func (r RolloutEventBatch) BatchConfig(configName string)

type Store

+ UpdateAgentStatus func(ctx context.Context, agentID string, status model.AgentStatus) error

Aug 9, 2023

Changes in this version

type BoltstoreCore

+ func (s *BoltstoreCore) UpdateAgent(ctx context.Context, agentID string, updater AgentUpdater) (*model.Agent, error)

+ func (s *BoltstoreCore) UpdateAgents(ctx context.Context, agentIDs []string, updater AgentUpdater) ([]*model.Agent, error)

type Store

+ UpdateAgent func(ctx context.Context, agentID string, updater AgentUpdater) (*model.Agent, error)

+ UpdateAgents func(ctx context.Context, agentIDs []string, updater AgentUpdater) ([]*model.Agent, error)

Aug 3, 2023

Changes in this version

+ func RunReportConnectedAgentsTests(ctx context.Context, t *testing.T, store Store)

+ func RunTestSeedDeprecated(ctx context.Context, t *testing.T, store Store)

type BoltstoreCore

+ func (s *BoltstoreCore) DisconnectUnreportedAgents(ctx context.Context, since time.Time) error

+ func (s *BoltstoreCore) ReportConnectedAgents(ctx context.Context, agentIDs []string, time time.Time) error

type Store

+ DisconnectUnreportedAgents func(ctx context.Context, since time.Time) error

+ ReportConnectedAgents func(ctx context.Context, agentIDs []string, time time.Time) error

Jul 5, 2023

Changes in this version

+ func MaskSensitiveParameters(ctx context.Context, resource R)

+ func PreserveSensitiveParameters(ctx context.Context, updated model.Resource, existing *model.AnyResource) error

Jun 19, 2023

Changes in this version

+ var UpdatesContextKey key

type BoltstoreCommon

+ CreateEventUpdate func() BasicEventUpdates

type EventUpdates

+ AgentVersionsField Events[*model.AgentVersion]

+ AgentsField Events[*model.Agent]

+ ConfigurationsField Events[*model.Configuration]

+ DestinationTypesField Events[*model.DestinationType]

+ DestinationsField Events[*model.Destination]

+ ProcessorTypesField Events[*model.ProcessorType]

+ ProcessorsField Events[*model.Processor]

+ SourceTypesField Events[*model.SourceType]

+ SourcesField Events[*model.Source]

type RolloutUpdates

+ UpdatesField Events[*model.ConfigurationVersions]

Jun 2, 2023

Changes in this version

+ const BucketAgents

+ const BucketArchive

+ const BucketMeasurements

+ const BucketResources

+ var ErrDoesNotSupportHistory = errors.New("store does not support resource history")

+ var ErrResourceInUse = errors.New("resource in use")

+ var ErrStoreResourceMissing = errors.New("resource not found")

+ func AgentKey(id string) []byte

+ func AgentPrefix() []byte

+ func ApplySortOffsetAndLimit(list []T, opts QueryOptions, fieldAccessor fieldAccessor[T]) []T

+ func CurrentRolloutsForConfiguration(idx search.Index, configurationName string) ([]string, error)

+ func DeleteResource(ctx context.Context, s BoltstoreCommon, kind model.Kind, uniqueKey string, ...) (resource R, exists bool, err error)

+ func DeleteResourceAndNotify(ctx context.Context, s BoltstoreCommon, kind model.Kind, uniqueKey string, ...) (resource R, exists bool, err error)

+ func FindAgents(ctx context.Context, idx search.Index, key string, value string) ([]string, error)

+ func FindResource(ctx context.Context, s BoltstoreCommon, tx *bbolt.Tx, kind model.Kind, ...) (resource R, key []byte, bucket *bbolt.Bucket, exists bool, err error)

+ func FindSuggestions(idx search.Index, key string, prefix string) ([]string, error)

+ func GetSeedResources(ctx context.Context, files embed.FS, folders []string) ([]model.Resource, error)

+ func HandleRolloutUpdates(ctx context.Context, s Store, logger *zap.Logger)

+ func InitBoltstoreDB(storageFilePath string) (*bbolt.DB, error)

+ func IsNewConfigurationVersion(curResource *model.AnyResource, newResource model.Resource) (bool, *model.Configuration, error)

+ func KeyFromResource(r model.Resource) []byte

+ func MergeUpdates(into, from BasicEventUpdates) bool

+ func NewBPCookieStore(secret string) *sessions.CookieStore

+ func NewDependencyError(d DependentResources) error

+ func Resource(ctx context.Context, s BoltstoreCommon, kind model.Kind, uniqueKey string) (resource R, exists bool, err error)

+ func ResourceKey(kind model.Kind, name string) []byte

+ func Resources(ctx context.Context, s BoltstoreCommon, kind model.Kind) ([]R, error)

+ func ResourcesByUniqueKeys(ctx context.Context, s BoltstoreCommon, kind model.Kind, uniqueKeys []string, ...) ([]R, error)

+ func ResourcesPrefix(kind model.Kind) []byte

+ func Seed(ctx context.Context, store Store, logger *zap.Logger, files embed.FS, ...) error

+ func SeedSearchIndexes(ctx context.Context, store Store, logger *zap.Logger)

+ func StartedRolloutsFromIndex(_ context.Context, index search.Index) ([]string, error)

+ func UpdateDependentResources(ctx context.Context, store Store, resources []model.Resource, ...) ([]model.ResourceStatus, error)

+ func UpdateResource(ctx context.Context, s BoltstoreCommon, tx *bbolt.Tx, kind model.Kind, ...) (r R, status model.UpdateStatus, err error)

+ func UpdateRolloutMetrics(ctx context.Context, agentIndex search.Index, config *model.Configuration) (int, error)

+ func UpsertResource(ctx context.Context, s BoltstoreCommon, tx *bbolt.Tx, r model.Resource) (model.UpdateStatus, error)

+ type AgentUpdater func(current *model.Agent)

+ type ArchiveStore interface

+ ResourceHistory func(ctx context.Context, resourceKind model.Kind, resourceName string) ([]*model.AnyResource, error)

+ type BasicEventUpdates interface

+ AddAffectedConfigurations func(configurations []*model.Configuration)

+ AddAffectedDestinations func(destinations []*model.Destination)

+ AddAffectedProcessors func(processors []*model.Processor)

+ AddAffectedSources func(sources []*model.Source)

+ AffectsConfiguration func(configuration *model.Configuration) bool

+ AffectsDestination func(destination *model.Destination) bool

+ AffectsProcessor func(processor *model.Processor) bool

+ AffectsResourceProcessors func(processors []model.ResourceConfiguration) bool

+ AffectsSource func(source *model.Source) bool

+ AgentVersions func() Events[*model.AgentVersion]

+ Agents func() Events[*model.Agent]

+ Configurations func() Events[*model.Configuration]

+ CouldAffectConfigurations func() bool

+ CouldAffectDestinations func() bool

+ CouldAffectProcessors func() bool

+ CouldAffectSources func() bool

+ DestinationTypes func() Events[*model.DestinationType]

+ Destinations func() Events[*model.Destination]

+ Empty func() bool

+ IncludeAgent func(agent *model.Agent, eventType EventType)

+ IncludeResource func(r model.Resource, eventType EventType)

+ Merge func(other BasicEventUpdates) bool

+ ProcessorTypes func() Events[*model.ProcessorType]

+ Processors func() Events[*model.Processor]

+ Size func() int

+ SourceTypes func() Events[*model.SourceType]

+ Sources func() Events[*model.Source]

+ TransitiveUpdates func() []model.Resource

+ func NewEventUpdates() BasicEventUpdates

+ func UpdatesForContext(ctx context.Context) (updates BasicEventUpdates, newContext context.Context, shouldNotify bool)

+ type BoltstoreCommon interface

+ AgentsBucket func(ctx context.Context, tx *bbolt.Tx) (*bbolt.Bucket, error)

+ AgentsIndex func(ctx context.Context) search.Index

+ ArchiveBucket func(ctx context.Context, tx *bbolt.Tx) (*bbolt.Bucket, error)

+ ConfigurationsIndex func(ctx context.Context) search.Index

+ Database func() *bbolt.DB

+ MeasurementsBucket func(ctx context.Context, tx *bbolt.Tx, metric string) (*bbolt.Bucket, error)

+ Notify func(ctx context.Context, updates BasicEventUpdates)

+ ResourceKey func(r model.Resource) []byte

+ ResourcesBucket func(ctx context.Context, tx *bbolt.Tx, kind model.Kind) (*bbolt.Bucket, error)

+ ZapLogger func() *zap.Logger

+ type BoltstoreCore struct

+ DB *bbolt.DB

+ Logger *zap.Logger

+ SessionStorage sessions.Store

+ StoreUpdates *Updates

+ func (s *BoltstoreCore) Agent(ctx context.Context, id string) (*model.Agent, error)

+ func (s *BoltstoreCore) AgentConfiguration(ctx context.Context, agent *model.Agent) (*model.Configuration, error)

+ func (s *BoltstoreCore) AgentIndex(ctx context.Context) search.Index

+ func (s *BoltstoreCore) AgentMetrics(ctx context.Context, ids []string, options ...stats.QueryOption) (stats.MetricData, error)

+ func (s *BoltstoreCore) AgentRolloutUpdates(_ context.Context) eventbus.Source[RolloutEventUpdates]

+ func (s *BoltstoreCore) AgentVersion(ctx context.Context, name string) (*model.AgentVersion, error)

+ func (s *BoltstoreCore) AgentVersions(ctx context.Context) ([]*model.AgentVersion, error)

+ func (s *BoltstoreCore) Agents(ctx context.Context, options ...QueryOption) ([]*model.Agent, error)

+ func (s *BoltstoreCore) AgentsCount(ctx context.Context, options ...QueryOption) (int, error)

+ func (s *BoltstoreCore) AgentsIDsMatchingConfiguration(ctx context.Context, configuration *model.Configuration) ([]string, error)

+ func (s *BoltstoreCore) CleanupDisconnectedAgents(ctx context.Context, since time.Time) error

+ func (s *BoltstoreCore) Configuration(ctx context.Context, name string) (*model.Configuration, error)

+ func (s *BoltstoreCore) ConfigurationIndex(ctx context.Context) search.Index

+ func (s *BoltstoreCore) ConfigurationMetrics(ctx context.Context, name string, options ...stats.QueryOption) (stats.MetricData, error)

+ func (s *BoltstoreCore) Configurations(ctx context.Context, options ...QueryOption) ([]*model.Configuration, error)

+ func (s *BoltstoreCore) Database() *bbolt.DB

+ func (s *BoltstoreCore) DeleteAgentVersion(ctx context.Context, name string) (*model.AgentVersion, error)

+ func (s *BoltstoreCore) DeleteConfiguration(ctx context.Context, name string) (*model.Configuration, error)

+ func (s *BoltstoreCore) DeleteDestination(ctx context.Context, name string) (*model.Destination, error)

+ func (s *BoltstoreCore) DeleteDestinationType(ctx context.Context, name string) (*model.DestinationType, error)

+ func (s *BoltstoreCore) DeleteProcessor(ctx context.Context, name string) (*model.Processor, error)

+ func (s *BoltstoreCore) DeleteProcessorType(ctx context.Context, name string) (*model.ProcessorType, error)

+ func (s *BoltstoreCore) DeleteResourcesCore(ctx context.Context, resources []model.Resource) ([]model.ResourceStatus, error)

+ func (s *BoltstoreCore) DeleteSource(ctx context.Context, name string) (*model.Source, error)

+ func (s *BoltstoreCore) DeleteSourceType(ctx context.Context, name string) (*model.SourceType, error)

+ func (s *BoltstoreCore) Destination(ctx context.Context, name string) (*model.Destination, error)

+ func (s *BoltstoreCore) DestinationType(ctx context.Context, name string) (*model.DestinationType, error)

+ func (s *BoltstoreCore) DestinationTypes(ctx context.Context) ([]*model.DestinationType, error)

+ func (s *BoltstoreCore) Destinations(ctx context.Context) ([]*model.Destination, error)

+ func (s *BoltstoreCore) FindAgentConfiguration(ctx context.Context, agent *model.Agent) (*model.Configuration, error)

+ func (s *BoltstoreCore) MeasurementsSize(ctx context.Context) (int, error)

+ func (s *BoltstoreCore) OverviewMetrics(ctx context.Context, options ...stats.QueryOption) (stats.MetricData, error)

+ func (s *BoltstoreCore) PauseRollout(ctx context.Context, configurationName string) (*model.Configuration, error)

+ func (s *BoltstoreCore) ProcessMetrics(ctx context.Context) error

+ func (s *BoltstoreCore) Processor(ctx context.Context, name string) (*model.Processor, error)

+ func (s *BoltstoreCore) ProcessorType(ctx context.Context, name string) (*model.ProcessorType, error)

+ func (s *BoltstoreCore) ProcessorTypes(ctx context.Context) ([]*model.ProcessorType, error)

+ func (s *BoltstoreCore) Processors(ctx context.Context) ([]*model.Processor, error)

+ func (s *BoltstoreCore) ResourceHistory(ctx context.Context, resourceKind model.Kind, resourceName string) ([]*model.AnyResource, error)

+ func (s *BoltstoreCore) ResumeRollout(ctx context.Context, configurationName string) (*model.Configuration, error)

+ func (s *BoltstoreCore) SaveAgentMetrics(ctx context.Context, metrics []*record.Metric) error

+ func (s *BoltstoreCore) Source(ctx context.Context, name string) (*model.Source, error)

+ func (s *BoltstoreCore) SourceType(ctx context.Context, name string) (*model.SourceType, error)

+ func (s *BoltstoreCore) SourceTypes(ctx context.Context) ([]*model.SourceType, error)

+ func (s *BoltstoreCore) Sources(ctx context.Context) ([]*model.Source, error)

+ func (s *BoltstoreCore) StartMeasurements(ctx context.Context)

+ func (s *BoltstoreCore) StartRollout(ctx context.Context, configurationName string, options *model.RolloutOptions) (*model.Configuration, error)

+ func (s *BoltstoreCore) UpdateConfiguration(ctx context.Context, name string, updater ConfigurationUpdater) (config *model.Configuration, status model.UpdateStatus, err error)

+ func (s *BoltstoreCore) UpdateRollout(ctx context.Context, configuration string) (updatedConfig *model.Configuration, err error)

+ func (s *BoltstoreCore) UpdateRollouts(ctx context.Context) ([]*model.Configuration, error)

+ func (s *BoltstoreCore) Updates(_ context.Context) eventbus.Source[BasicEventUpdates]

+ func (s *BoltstoreCore) UpsertAgent(ctx context.Context, id string, updater AgentUpdater) (*model.Agent, error)

+ func (s *BoltstoreCore) UpsertAgents(ctx context.Context, agentIDs []string, updater AgentUpdater) ([]*model.Agent, error)

+ type BroadCastBuilder func(ctx context.Context, options Options, logger *zap.Logger, maxEventsToMerge int) broadcast.Broadcast[T]

+ func BuildBasicEventBroadcast() BroadCastBuilder[BasicEventUpdates]

+ func BuildRolloutEventBroadcast() BroadCastBuilder[RolloutEventUpdates]

+ type ConfigurationUpdater func(current *model.Configuration)

+ type Dependency struct

+ Kind model.Kind

+ Name string

+ type DependencyError struct

+ Dependencies DependentResources

+ func (de *DependencyError) Error() string

+ type DependentResources []Dependency

+ func FindDependentResources(ctx context.Context, configurationIndex search.Index, name string, ...) (DependentResources, error)

+ func (r *DependentResources) Add(d Dependency)

+ func (r *DependentResources) Empty() bool

+ func (r *DependentResources) Message() string

+ type Event struct

+ Item T

+ Type EventType

+ type EventType uint8

+ const EventTypeInsert

+ const EventTypeLabel

+ const EventTypeRemove

+ const EventTypeRollout

+ const EventTypeUpdate

+ type EventUpdates struct

+ func (u *EventUpdates) AddAffectedConfigurations(configurations []*model.Configuration)

+ func (u *EventUpdates) AddAffectedDestinations(destinations []*model.Destination)

+ func (u *EventUpdates) AddAffectedProcessors(processors []*model.Processor)

+ func (u *EventUpdates) AddAffectedSources(sources []*model.Source)

+ func (u *EventUpdates) AffectsConfiguration(configuration *model.Configuration) bool

+ func (u *EventUpdates) AffectsDestination(destination *model.Destination) bool

+ func (u *EventUpdates) AffectsProcessor(processor *model.Processor) bool

+ func (u *EventUpdates) AffectsResourceProcessors(processors []model.ResourceConfiguration) bool

+ func (u *EventUpdates) AffectsSource(source *model.Source) bool

+ func (u *EventUpdates) AgentVersions() Events[*model.AgentVersion]

+ func (u *EventUpdates) Agents() Events[*model.Agent]

+ func (u *EventUpdates) Configurations() Events[*model.Configuration]

+ func (u *EventUpdates) CouldAffectConfigurations() bool

+ func (u *EventUpdates) CouldAffectDestinations() bool

+ func (u *EventUpdates) CouldAffectProcessors() bool

+ func (u *EventUpdates) CouldAffectSources() bool

+ func (u *EventUpdates) DestinationTypes() Events[*model.DestinationType]

+ func (u *EventUpdates) Destinations() Events[*model.Destination]

+ func (u *EventUpdates) Empty() bool

+ func (u *EventUpdates) HasDestinationEvents() bool

+ func (u *EventUpdates) HasDestinationTypeEvents() bool

+ func (u *EventUpdates) HasProcessorEvents() bool

+ func (u *EventUpdates) HasProcessorTypeEvents() bool

+ func (u *EventUpdates) HasSourceEvents() bool

+ func (u *EventUpdates) HasSourceTypeEvents() bool

+ func (u *EventUpdates) IncludeAgent(agent *model.Agent, eventType EventType)

+ func (u *EventUpdates) IncludeAgentVersion(agentVersion *model.AgentVersion, eventType EventType)

+ func (u *EventUpdates) IncludeConfiguration(configuration *model.Configuration, eventType EventType)

+ func (u *EventUpdates) IncludeDestination(destination *model.Destination, eventType EventType)

+ func (u *EventUpdates) IncludeDestinationType(destinationType *model.DestinationType, eventType EventType)

+ func (u *EventUpdates) IncludeProcessor(processor *model.Processor, eventType EventType)

+ func (u *EventUpdates) IncludeProcessorType(processorType *model.ProcessorType, eventType EventType)

+ func (u *EventUpdates) IncludeResource(r model.Resource, eventType EventType)

+ func (u *EventUpdates) IncludeSource(source *model.Source, eventType EventType)

+ func (u *EventUpdates) IncludeSourceType(sourceType *model.SourceType, eventType EventType)

+ func (u *EventUpdates) Merge(other BasicEventUpdates) bool

+ func (u *EventUpdates) ProcessorTypes() Events[*model.ProcessorType]

+ func (u *EventUpdates) Processors() Events[*model.Processor]

+ func (u *EventUpdates) Size() int

+ func (u *EventUpdates) SourceTypes() Events[*model.SourceType]

+ func (u *EventUpdates) Sources() Events[*model.Source]

+ func (u *EventUpdates) TransitiveUpdates() []model.Resource

+ type Events map[string]Event[T]

+ func NewEvents() Events[T]

+ func NewEventsWithItem(item T, eventType EventType) Events[T]

+ func (e Events[T]) ByType(eventType EventType) []Event[T]

+ func (e Events[T]) CanSafelyMerge(other Events[T]) bool

+ func (e Events[T]) Clone() Events[T]

+ func (e Events[T]) Contains(uniqueKey string, eventType EventType) bool

+ func (e Events[T]) ContainsKey(uniqueKey string) bool

+ func (e Events[T]) Empty() bool

+ func (e Events[T]) Include(item T, eventType EventType)

+ func (e Events[T]) Keys() []string

+ func (e Events[T]) Merge(other Events[T])

+ func (e Events[T]) Updates() []Event[T]

+ type Options struct

+ DisableMeasurementsCleanup bool

+ DisableRolloutUpdater bool

+ MaxEventsToMerge int

+ SessionsSecret string

+ type QueryOption func(*QueryOptions)

+ func WithLimit(limit int) QueryOption

+ func WithOffset(offset int) QueryOption

+ func WithQuery(query *search.Query) QueryOption

+ func WithSelector(selector model.Selector) QueryOption

+ func WithSort(field string) QueryOption

+ type QueryOptions struct

+ Limit int

+ Offset int

+ Query *search.Query

+ Selector model.Selector

+ Sort string

+ func MakeQueryOptions(options []QueryOption) QueryOptions

+ type RolloutEventUpdates interface

+ Empty func() bool

+ Merge func(other RolloutEventUpdates) bool

+ Updates func() Events[*model.ConfigurationVersions]

+ func NewRolloutUpdates(_ context.Context, agentEvents Events[*model.Agent]) RolloutEventUpdates

+ type RolloutUpdateCreator func(context.Context, Events[*model.Agent]) RolloutEventUpdates

+ type RolloutUpdates struct

+ func (r *RolloutUpdates) Empty() bool

+ func (r *RolloutUpdates) Merge(other RolloutEventUpdates) bool

+ func (r *RolloutUpdates) Updates() Events[*model.ConfigurationVersions]

+ type Store interface

+ Agent func(ctx context.Context, id string) (*model.Agent, error)

+ AgentConfiguration func(ctx context.Context, agent *model.Agent) (*model.Configuration, error)

+ AgentIndex func(ctx context.Context) search.Index

+ AgentRolloutUpdates func(ctx context.Context) eventbus.Source[RolloutEventUpdates]

+ AgentVersion func(ctx context.Context, name string) (*model.AgentVersion, error)

+ AgentVersions func(ctx context.Context) ([]*model.AgentVersion, error)

+ Agents func(ctx context.Context, options ...QueryOption) ([]*model.Agent, error)

+ AgentsCount func(context.Context, ...QueryOption) (int, error)

+ AgentsIDsMatchingConfiguration func(ctx context.Context, conf *model.Configuration) ([]string, error)

+ ApplyResources func(ctx context.Context, resources []model.Resource) ([]model.ResourceStatus, error)

+ CleanupDisconnectedAgents func(ctx context.Context, since time.Time) error

+ Clear func()

+ Close func() error

+ Configuration func(ctx context.Context, name string) (*model.Configuration, error)

+ ConfigurationIndex func(ctx context.Context) search.Index

+ Configurations func(ctx context.Context, options ...QueryOption) ([]*model.Configuration, error)

+ DeleteAgentVersion func(ctx context.Context, name string) (*model.AgentVersion, error)

+ DeleteAgents func(ctx context.Context, agentIDs []string) ([]*model.Agent, error)

+ DeleteConfiguration func(ctx context.Context, name string) (*model.Configuration, error)

+ DeleteDestination func(ctx context.Context, name string) (*model.Destination, error)

+ DeleteDestinationType func(ctx context.Context, name string) (*model.DestinationType, error)

+ DeleteProcessor func(ctx context.Context, name string) (*model.Processor, error)

+ DeleteProcessorType func(ctx context.Context, name string) (*model.ProcessorType, error)

+ DeleteResources func(ctx context.Context, resources []model.Resource) ([]model.ResourceStatus, error)

+ DeleteSource func(ctx context.Context, name string) (*model.Source, error)

+ DeleteSourceType func(ctx context.Context, name string) (*model.SourceType, error)

+ Destination func(ctx context.Context, name string) (*model.Destination, error)

+ DestinationType func(ctx context.Context, name string) (*model.DestinationType, error)

+ DestinationTypes func(ctx context.Context) ([]*model.DestinationType, error)

+ Destinations func(ctx context.Context) ([]*model.Destination, error)

+ Measurements func() stats.Measurements

+ PauseRollout func(ctx context.Context, configurationName string) (*model.Configuration, error)

+ Processor func(ctx context.Context, name string) (*model.Processor, error)

+ ProcessorType func(ctx context.Context, name string) (*model.ProcessorType, error)

+ ProcessorTypes func(ctx context.Context) ([]*model.ProcessorType, error)

+ Processors func(ctx context.Context) ([]*model.Processor, error)

+ ResumeRollout func(ctx context.Context, configurationName string) (*model.Configuration, error)

+ Source func(ctx context.Context, name string) (*model.Source, error)

+ SourceType func(ctx context.Context, name string) (*model.SourceType, error)

+ SourceTypes func(ctx context.Context) ([]*model.SourceType, error)

+ Sources func(ctx context.Context) ([]*model.Source, error)

+ StartRollout func(ctx context.Context, configurationName string, options *model.RolloutOptions) (*model.Configuration, error)

+ UpdateAllRollouts func(ctx context.Context) error

+ UpdateConfiguration func(ctx context.Context, name string, updater ConfigurationUpdater) (config *model.Configuration, status model.UpdateStatus, err error)

+ UpdateRollout func(ctx context.Context, configurationName string) (*model.Configuration, error)

+ UpdateRollouts func(ctx context.Context) ([]*model.Configuration, error)

+ Updates func(ctx context.Context) eventbus.Source[BasicEventUpdates]

+ UpsertAgent func(ctx context.Context, agentID string, updater AgentUpdater) (*model.Agent, error)

+ UpsertAgents func(ctx context.Context, agentIDs []string, updater AgentUpdater) ([]*model.Agent, error)

+ UserSessions func() sessions.Store

+ func NewBoltStore(ctx context.Context, db *bbolt.DB, options Options, logger *zap.Logger) Store

+ func NewMapStore(ctx context.Context, options Options, logger *zap.Logger) Store

+ type Updates struct

+ func NewUpdates(ctx context.Context, options Options, logger *zap.Logger, ...) *Updates

+ func (s *Updates) RolloutUpdates() eventbus.Source[RolloutEventUpdates]

+ func (s *Updates) Send(ctx context.Context, updates BasicEventUpdates)

+ func (s *Updates) Shutdown(_ context.Context)

+ func (s *Updates) Updates() eventbus.Source[BasicEventUpdates]