bucketclient

Documentation

Index

• type BucketAlertStore
  • func NewBucketAlertStore(bkt objstore.Bucket, cfgProvider bucket.TenantConfigProvider, ...) *BucketAlertStore
  • func (s *BucketAlertStore) DeleteAlertConfig(ctx context.Context, userID string) error
  • func (s *BucketAlertStore) DeleteFullState(ctx context.Context, userID string) error
  • func (s *BucketAlertStore) GetAlertConfig(ctx context.Context, userID string) (alertspb.AlertConfigDesc, error)
  • func (s *BucketAlertStore) GetAlertConfigs(ctx context.Context, userIDs []string) (map[string]alertspb.AlertConfigDesc, error)
  • func (s *BucketAlertStore) GetFullState(ctx context.Context, userID string) (alertspb.FullStateDesc, error)
  • func (s *BucketAlertStore) ListAllUsers(ctx context.Context) ([]string, error)
  • func (s *BucketAlertStore) ListUsersWithFullState(ctx context.Context) ([]string, error)
  • func (s *BucketAlertStore) SetAlertConfig(ctx context.Context, cfg alertspb.AlertConfigDesc) error
  • func (s *BucketAlertStore) SetFullState(ctx context.Context, userID string, fs alertspb.FullStateDesc) error

Types

type BucketAlertStore

type BucketAlertStore struct {
	// contains filtered or unexported fields
}

BucketAlertStore is used to support the AlertStore interface against an object storage backend. It is implemented using the Thanos objstore.Bucket interface

func NewBucketAlertStore

func NewBucketAlertStore(bkt objstore.Bucket, cfgProvider bucket.TenantConfigProvider, logger log.Logger) *BucketAlertStore

func (*BucketAlertStore) DeleteAlertConfig

func (s *BucketAlertStore) DeleteAlertConfig(ctx context.Context, userID string) error

DeleteAlertConfig implements alertstore.AlertStore.

func (*BucketAlertStore) DeleteFullState

func (s *BucketAlertStore) DeleteFullState(ctx context.Context, userID string) error

DeleteFullState implements alertstore.AlertStore.

func (*BucketAlertStore) GetAlertConfig

func (s *BucketAlertStore) GetAlertConfig(ctx context.Context, userID string) (alertspb.AlertConfigDesc, error)

GetAlertConfig implements alertstore.AlertStore.

func (*BucketAlertStore) GetAlertConfigs

func (s *BucketAlertStore) GetAlertConfigs(ctx context.Context, userIDs []string) (map[string]alertspb.AlertConfigDesc, error)

GetAlertConfigs implements alertstore.AlertStore.

func (*BucketAlertStore) GetFullState

func (s *BucketAlertStore) GetFullState(ctx context.Context, userID string) (alertspb.FullStateDesc, error)

GetFullState implements alertstore.AlertStore.

func (*BucketAlertStore) ListAllUsers

func (s *BucketAlertStore) ListAllUsers(ctx context.Context) ([]string, error)

ListAllUsers implements alertstore.AlertStore.

func (*BucketAlertStore) ListUsersWithFullState

func (s *BucketAlertStore) ListUsersWithFullState(ctx context.Context) ([]string, error)

ListUsersWithFullState implements alertstore.AlertStore.

func (*BucketAlertStore) SetAlertConfig

func (s *BucketAlertStore) SetAlertConfig(ctx context.Context, cfg alertspb.AlertConfigDesc) error

SetAlertConfig implements alertstore.AlertStore.

func (*BucketAlertStore) SetFullState

func (s *BucketAlertStore) SetFullState(ctx context.Context, userID string, fs alertspb.FullStateDesc) error

SetFullState implements alertstore.AlertStore.