cqldb

Documentation

Index

• type Config
  • func (c *Config) Validate() error
• type PersistenceTx
  • func (p *PersistenceTx) Close()
  • func (p *PersistenceTx) Delete(deviceID, owner string) error
  • func (p *PersistenceTx) Persist(d *persistence.AuthorizedDevice) error
  • func (p *PersistenceTx) Retrieve(deviceID, owner string) (_ *persistence.AuthorizedDevice, ok bool, err error)
  • func (p *PersistenceTx) RetrieveByDevice(deviceID string) (_ *persistence.AuthorizedDevice, ok bool, err error)
  • func (p *PersistenceTx) RetrieveByOwner(owner string) persistence.Iterator
• type Store
  • func New(ctx context.Context, config *Config, fileWatcher *fsnotify.Watcher, ...) (*Store, error)
  • func (s *Store) NewTransaction(ctx context.Context) persistence.PersistenceTx

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 PersistenceTx

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

PersistenceTx prevents data race for a sequence of read and write operations.

func (*PersistenceTx) Close

func (p *PersistenceTx) Close()

Close must always be called (use defer immediately after NewTransaction).

func (*PersistenceTx) Delete

func (p *PersistenceTx) Delete(deviceID, owner string) error

Delete removes the device's authorization record.

func (*PersistenceTx) Persist

func (p *PersistenceTx) Persist(d *persistence.AuthorizedDevice) error

func (*PersistenceTx) Retrieve

func (p *PersistenceTx) Retrieve(deviceID, owner string) (_ *persistence.AuthorizedDevice, ok bool, err error)

Retrieve device's authorization details.

func (*PersistenceTx) RetrieveByDevice

func (p *PersistenceTx) RetrieveByDevice(deviceID string) (_ *persistence.AuthorizedDevice, ok bool, err error)

RetrieveByDevice device's authorization details.

func (*PersistenceTx) RetrieveByOwner

func (p *PersistenceTx) RetrieveByOwner(owner string) persistence.Iterator

RetrieveAll retrieves all owner's authorized devices.

type Store

type Store struct {
	*cqldb.Store
}

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) NewTransaction

func (s *Store) NewTransaction(ctx context.Context) persistence.PersistenceTx

NewTransaction creates a new transaction. A transaction must always be closed:

tx := s.persistence.NewTransaction()
defer tx.Close()