Documentation
¶
Index ¶
- type Config
- 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 (s *Store) AddCloseFunc(f func())
- func (s *Store) Clear(ctx context.Context) error
- func (s *Store) Close(_ context.Context) error
- func (s *Store) NewTransaction(ctx context.Context) persistence.PersistenceTx
- func (s *Store) Table() string
- func (s *Store) TruncateTable(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
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 {
// contains filtered or unexported fields
}
Store implements an Store for cqldb.
func (*Store) AddCloseFunc ¶
func (s *Store) AddCloseFunc(f func())
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()
Source Files
Click to show internal directories.
Click to hide internal directories.