cqldb

Documentation

Index

• Variables
• type Config
  • func (c *Config) Validate() error
• type Index
• type SigningRecordsIterator
  • func (i *SigningRecordsIterator) Err() error
  • func (i *SigningRecordsIterator) Next(_ context.Context, s *store.SigningRecord) bool
• type Store
  • func New(ctx context.Context, config *Config, fileWatcher *fsnotify.Watcher, ...) (*Store, error)
  • func (s *Store) AddCloseFunc(f func())
  • func (s *Store) Clear(ctx context.Context) error
  • func (s *Store) ClearTable(ctx context.Context) error
  • func (s *Store) Close(_ context.Context) error
  • func (s *Store) CreateSigningRecord(ctx context.Context, signingRecord *store.SigningRecord) error
  • func (s *Store) DeleteNonDeviceExpiredRecords(_ context.Context, _ time.Time) (int64, error)
  • func (s *Store) DeleteSigningRecords(ctx context.Context, owner string, query *store.DeleteSigningRecordsQuery) (int64, error)
  • func (s *Store) LoadSigningRecords(ctx context.Context, owner string, query *store.SigningRecordsQuery, ...) error
  • func (s *Store) Table() string
  • func (s *Store) UpdateSigningRecord(ctx context.Context, signingRecord *store.SigningRecord) error

Variables

var ErrCannotRemoveSigningRecord = errors.New("cannot remove signing record")

Types

type Config

type Config struct {
	Embedded cqldb.Config `yaml:",inline" json:",inline"`
	Table    string       `yaml:"table" json:"table"`
}

Config provides Mongo DB configuration options

func (*Config) Validate

func (c *Config) Validate() error

type Index

type Index struct {
	Name            string
	PartitionKey    string
	SecondaryColumn string
}

type SigningRecordsIterator

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

func (*SigningRecordsIterator) Err

func (i *SigningRecordsIterator) Err() error

func (*SigningRecordsIterator) Next

func (i *SigningRecordsIterator) Next(_ context.Context, s *store.SigningRecord) bool

type Store

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

Store implements an Store for cqldb.

func New

func New(ctx context.Context, config *Config, fileWatcher *fsnotify.Watcher, logger log.Logger, tracerProvider trace.TracerProvider) (*Store, error)

func (*Store) AddCloseFunc

func (s *Store) AddCloseFunc(f func())

func (*Store) Clear

func (s *Store) Clear(ctx context.Context) error

Clear clears the event storage.

func (*Store) ClearTable

func (s *Store) ClearTable(ctx context.Context) error

Clear documents in collections, but don't drop the database or the collections

func (*Store) Close

func (s *Store) Close(_ context.Context) error

Close closes the database session.

func (*Store) CreateSigningRecord

func (s *Store) CreateSigningRecord(ctx context.Context, signingRecord *store.SigningRecord) error

func (*Store) DeleteNonDeviceExpiredRecords

func (s *Store) DeleteNonDeviceExpiredRecords(_ context.Context, _ time.Time) (int64, error)

func (*Store) DeleteSigningRecords

func (s *Store) DeleteSigningRecords(ctx context.Context, owner string, query *store.DeleteSigningRecordsQuery) (int64, error)

func (*Store) LoadSigningRecords

func (s *Store) LoadSigningRecords(ctx context.Context, owner string, query *store.SigningRecordsQuery, h store.LoadSigningRecordsFunc) error

func (*Store) Table

func (s *Store) Table() string

func (*Store) UpdateSigningRecord

func (s *Store) UpdateSigningRecord(ctx context.Context, signingRecord *store.SigningRecord) error