mongodb

Documentation

Index

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

Variables

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

Types

type BulkWriteConfig

type BulkWriteConfig struct {
	Timeout       time.Duration `yaml:"timeout"`
	ThrottleTime  time.Duration `yaml:"throttleTime"`
	DocumentLimit uint16        `yaml:"documentLimit"`
}

func (*BulkWriteConfig) Validate

func (c *BulkWriteConfig) Validate() error

type Config

type Config struct {
	Mongo     pkgMongo.Config `yaml:",inline"`
	BulkWrite BulkWriteConfig `yaml:"bulkWrite"`
}

func (*Config) Validate

func (c *Config) Validate() error

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(ctx context.Context, s *store.SigningRecord) bool

type Store

type Store struct {
	*pkgMongo.Store
	// contains filtered or unexported fields
}

func New

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

func (*Store) Close

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

func (*Store) CreateSigningRecord

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

func (*Store) DeleteNonDeviceExpiredRecords

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

func (*Store) DeleteSigningRecords

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

func (*Store) FlushBulkWriter

func (s *Store) FlushBulkWriter() error

func (*Store) LoadSigningRecords

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

func (*Store) UpdateSigningRecord

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