Documentation
¶
Index ¶
- func NewConditionKeyStore(js nats.JetStreamContext) nats.KeyValue
- func NewDefaultAlertingBroker(js nats.JetStreamContext, opts ...storage_opts.ClientSetOption) spec.AlertingStoreBroker
- func NewEndpointKeyStore(js nats.JetStreamContext) nats.KeyValue
- func NewIncidentKeyStore(js nats.JetStreamContext) nats.KeyValue
- func NewRouterObjectStore(js nats.JetStreamContext) nats.ObjectStore
- func NewStatusCache(js nats.JetStreamContext) nats.KeyValue
- type CompositeAlertingBroker
- type CompositeAlertingClientSet
- func (c *CompositeAlertingClientSet) CalculateHash(ctx context.Context, key string, syncOptions *storage_opts.SyncOptions) error
- func (c CompositeAlertingClientSet) Conditions() spec.ConditionStorage
- func (c CompositeAlertingClientSet) Endpoints() spec.EndpointStorage
- func (c *CompositeAlertingClientSet) ForceSync(ctx context.Context, incomingOpts ...storage_opts.SyncOption) error
- func (c *CompositeAlertingClientSet) GetHash(_ context.Context, key string) string
- func (c CompositeAlertingClientSet) Incidents() spec.IncidentStorage
- func (c *CompositeAlertingClientSet) Purge(ctx context.Context) error
- func (c CompositeAlertingClientSet) Routers() spec.RouterStorage
- func (c CompositeAlertingClientSet) States() spec.StateStorage
- func (c *CompositeAlertingClientSet) Sync(ctx context.Context, incomingOpts ...storage_opts.SyncOption) ([]string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConditionKeyStore ¶
func NewConditionKeyStore(js nats.JetStreamContext) nats.KeyValue
func NewDefaultAlertingBroker ¶ added in v0.11.0
func NewDefaultAlertingBroker(js nats.JetStreamContext, opts ...storage_opts.ClientSetOption) spec.AlertingStoreBroker
func NewEndpointKeyStore ¶
func NewEndpointKeyStore(js nats.JetStreamContext) nats.KeyValue
func NewIncidentKeyStore ¶
func NewIncidentKeyStore(js nats.JetStreamContext) nats.KeyValue
func NewRouterObjectStore ¶
func NewRouterObjectStore(js nats.JetStreamContext) nats.ObjectStore
func NewStatusCache ¶
func NewStatusCache(js nats.JetStreamContext) nats.KeyValue
Types ¶
type CompositeAlertingBroker ¶
type CompositeAlertingBroker struct { opts.ClientSetOptions *CompositeAlertingClientSet }
func NewCompositeAlertingBroker ¶
func NewCompositeAlertingBroker(options opts.ClientSetOptions) *CompositeAlertingBroker
func (*CompositeAlertingBroker) NewClientSet ¶
func (c *CompositeAlertingBroker) NewClientSet() spec.AlertingClientSet
func (*CompositeAlertingBroker) Use ¶
func (c *CompositeAlertingBroker) Use(store any)
type CompositeAlertingClientSet ¶
type CompositeAlertingClientSet struct { Logger *zap.SugaredLogger // contains filtered or unexported fields }
func (*CompositeAlertingClientSet) CalculateHash ¶
func (c *CompositeAlertingClientSet) CalculateHash(ctx context.Context, key string, syncOptions *storage_opts.SyncOptions) error
func (CompositeAlertingClientSet) Conditions ¶
func (c CompositeAlertingClientSet) Conditions() spec.ConditionStorage
func (CompositeAlertingClientSet) Endpoints ¶
func (c CompositeAlertingClientSet) Endpoints() spec.EndpointStorage
func (*CompositeAlertingClientSet) ForceSync ¶
func (c *CompositeAlertingClientSet) ForceSync(ctx context.Context, incomingOpts ...storage_opts.SyncOption) error
Based on the other storage, calculate what the virtual config should be, then overwrite the virtual config storage
func (*CompositeAlertingClientSet) GetHash ¶
func (c *CompositeAlertingClientSet) GetHash(_ context.Context, key string) string
func (CompositeAlertingClientSet) Incidents ¶
func (c CompositeAlertingClientSet) Incidents() spec.IncidentStorage
func (*CompositeAlertingClientSet) Purge ¶
func (c *CompositeAlertingClientSet) Purge(ctx context.Context) error
func (CompositeAlertingClientSet) Routers ¶
func (c CompositeAlertingClientSet) Routers() spec.RouterStorage
func (CompositeAlertingClientSet) States ¶
func (c CompositeAlertingClientSet) States() spec.StateStorage
func (*CompositeAlertingClientSet) Sync ¶
func (c *CompositeAlertingClientSet) Sync(ctx context.Context, incomingOpts ...storage_opts.SyncOption) ([]string, error)
Click to show internal directories.
Click to hide internal directories.