cqldb

package
v2.19.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 15, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL