Documentation
¶
Index ¶
- Variables
- type BulkWriteConfig
- type Config
- type SigningRecordsIterator
- type Store
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var CommonNameKeyQueryIndex = bson.D{ {Key: store.CommonNameKey, Value: 1}, {Key: store.OwnerKey, Value: 1}, }
View Source
var DeviceIDKeyQueryIndex = bson.D{ {Key: store.DeviceIDKey, Value: 1}, {Key: store.OwnerKey, Value: 1}, }
View Source
var ErrCannotRemoveSigningRecord = errors.New("cannot remove signing record")
View Source
var PublicKeyQueryIndex = bson.D{ {Key: store.CommonNameKey, Value: 1}, }
Functions ¶
This section is empty.
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"` }
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 ¶
func (*Store) CreateSigningRecord ¶
func (*Store) DeleteNonDeviceExpiredRecords ¶
func (*Store) DeleteSigningRecords ¶
func (*Store) FlushBulkWriter ¶
func (*Store) LoadSigningRecords ¶
func (s *Store) LoadSigningRecords(ctx context.Context, owner string, query *store.SigningRecordsQuery, h store.LoadSigningRecordsFunc) error
func (*Store) UpdateSigningRecord ¶
Click to show internal directories.
Click to hide internal directories.