memory

Documentation

Overview

Package memory implements storage interfaces for bolt key-value store database.

Index

• type DevicesStorage
  • func (s *DevicesStorage) All(ctx context.Context) ([]models.Device, error)
  • func (d *DevicesStorage) New(ctx context.Context, userID string, newDevice models.Device) (string, error)
  • func (d *DevicesStorage) NewByOwner(ctx context.Context, deviceOwner string, newDevice models.Device) (string, error)
  • func (d *DevicesStorage) OfUser(ctx context.Context, userID string) ([]models.Device, error)
  • func (s *DevicesStorage) Read(ctx context.Context, id string) (*models.Device, error)
  • func (s *DevicesStorage) Remove(ctx context.Context, id string) error
  • func (s *DevicesStorage) Update(ctx context.Context, d models.Device) error
• type Factory
  • func New(db *bolt.DB) (*Factory, error)
  • func (f Factory) Devices() storage.Devices
  • func (f Factory) StatusTx() *StatusStorageTx
  • func (f Factory) TwoFactor() storage.TwoFactor
  • func (f Factory) Users() storage.Users
• type StatusStorageTx
  • func (s *StatusStorageTx) DevicesStatus(ctx context.Context, f func(context.Context, storage.Status) error) error
• type TwoFactorStorage
  • func (t *TwoFactorStorage) Get(ctx context.Context, userID string) (*models.TwoFactor, error)
  • func (t *TwoFactorStorage) Remove(ctx context.Context, userID string) error
  • func (t *TwoFactorStorage) Update(ctx context.Context, userID string, f func(*models.TwoFactor) error) error
• type UsersStorage
  • func (s *UsersStorage) All(ctx context.Context) ([]storage.UserEntry, error)
  • func (s *UsersStorage) New(ctx context.Context, newUser storage.UserEntry) (string, error)
  • func (s *UsersStorage) Read(ctx context.Context, id string) (*storage.UserEntry, error)
  • func (s *UsersStorage) Remove(ctx context.Context, id string) error
  • func (s *UsersStorage) Update(ctx context.Context, id string, f func(*storage.UserEntry) error) error

Types

type DevicesStorage

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

DevicesStorage implements storage.Devices interface for bolt database.

func (*DevicesStorage) All

func (s *DevicesStorage) All(ctx context.Context) ([]models.Device, error)

All returns slice with all devices from storage.

func (*DevicesStorage) New

func (d *DevicesStorage) New(ctx context.Context, userID string, newDevice models.Device) (string, error)

New stores given devices data in database and returns new device (given in new model) id.

func (*DevicesStorage) NewByOwner

func (d *DevicesStorage) NewByOwner(ctx context.Context, deviceOwner string, newDevice models.Device) (string, error)

NewByOwner stores given devices (owned by user with given nickname) data in database and returns its id.

func (*DevicesStorage) OfUser

func (d *DevicesStorage) OfUser(ctx context.Context, userID string) ([]models.Device, error)

OfUser returns list of models owned by user with given id.

func (*DevicesStorage) Read

func (s *DevicesStorage) Read(ctx context.Context, id string) (*models.Device, error)

Read returns single device data with given ID.

func (*DevicesStorage) Remove

func (s *DevicesStorage) Remove(ctx context.Context, id string) error

Remove deletes device with given id from storage.

func (*DevicesStorage) Update

func (s *DevicesStorage) Update(ctx context.Context, d models.Device) error

Update overwrites existing device data.

type Factory

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

Factory implements storage.Factory interface for bolt database.

func New

func New(db *bolt.DB) (*Factory, error)

New returns pointer to new memory storage Factory.

func (Factory) Devices

func (f Factory) Devices() storage.Devices

func (Factory) StatusTx

func (f Factory) StatusTx() *StatusStorageTx

StatusTx returns storage interface for reading and writing information about numbers of online users and unkown devices.

func (Factory) TwoFactor

func (f Factory) TwoFactor() storage.TwoFactor

func (Factory) Users

func (f Factory) Users() storage.Users

Users returns storage interface for manipulating users data.

type StatusStorageTx

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

StatusStorageTx implements storage.StatusTx interface.

func (*StatusStorageTx) DevicesStatus

func (s *StatusStorageTx) DevicesStatus(
	ctx context.Context,
	f func(context.Context, storage.Status) error,
) error

DevicesStatus accepts function that manipulates number of unknown devices and online users in single safe transaction.

type TwoFactorStorage

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

TwoFactorStorage implements TwoFactor storage interface for bolt database.

func (*TwoFactorStorage) Get

func (t *TwoFactorStorage) Get(ctx context.Context, userID string) (*models.TwoFactor, error)

Get returns two factor methods for user with given user ID.

func (*TwoFactorStorage) Remove

func (t *TwoFactorStorage) Remove(ctx context.Context, userID string) error

Remove deletes all two factor methods of user with given user ID. You can still use Update method after all to start adding more methods.

func (*TwoFactorStorage) Update

func (t *TwoFactorStorage) Update(ctx context.Context, userID string, f func(*models.TwoFactor) error) error

Updates apply given function to two factor methods of user with given user ID.

type UsersStorage

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

UsersStorage implements storage.Users interface for bolt database.

func (*UsersStorage) All

func (s *UsersStorage) All(ctx context.Context) ([]storage.UserEntry, error)

All returns slice with all users from storage.

func (*UsersStorage) New

func (s *UsersStorage) New(ctx context.Context, newUser storage.UserEntry) (string, error)

New stores given user data in database and returns assigned (given) id.

func (*UsersStorage) Read

func (s *UsersStorage) Read(ctx context.Context, id string) (*storage.UserEntry, error)

Read returns single user data with given ID.

func (*UsersStorage) Remove

func (s *UsersStorage) Remove(ctx context.Context, id string) error

Remove deletes user with given id from storage.

func (*UsersStorage) Update

func (s *UsersStorage) Update(ctx context.Context, id string, f func(*storage.UserEntry) error) error

Update overwrites existing user data.