storage

Documentation

Index

• Constants
• func NewMetricsStorage(dbType, dbConnectionURL string) (*cosmosdb.MetricsStorageCosmosDB, error)
• type CertStorage
  • func NewCertStorage(dbType, dbConnectionURL string, randomKey []byte, encryptionEnabled bool, ...) (CertStorage, error)
• type UserStorage
  • func New(dbType, dbConnectionURL, dbPath string, randomKey []byte, ...) (UserStorage, error)
• type UserStorageWithCache
  • func NewUserStorageWithCache(storage UserStorage, logger log.Logger) (*UserStorageWithCache, error)
  • func (s *UserStorageWithCache) ActivateSessionKey(userID []byte, active bool) error
  • func (s *UserStorageWithCache) AddAccount(userID []byte, accountAddress []byte, signature []byte, ...) error
  • func (s *UserStorageWithCache) AddSessionKey(userID []byte, key wecommon.GWSessionKey) error
  • func (s *UserStorageWithCache) AddUser(userID []byte, privateKey []byte) error
  • func (s *UserStorageWithCache) DeleteUser(userID []byte) error
  • func (s *UserStorageWithCache) GetEncryptionKey() []byte
  • func (s *UserStorageWithCache) GetUser(userID []byte) (*wecommon.GWUser, error)
  • func (s *UserStorageWithCache) RemoveSessionKey(userID []byte) error

Constants

const UserCacheSize = 10_000

Functions

func NewMetricsStorage

func NewMetricsStorage(dbType, dbConnectionURL string) (*cosmosdb.MetricsStorageCosmosDB, error)

NewMetricsStorage is a factory function to create a MetricsStorage instance

Types

type CertStorage

type CertStorage interface {
	autocert.Cache
}

CertStorage defines the interface for certificate storage

func NewCertStorage

func NewCertStorage(dbType, dbConnectionURL string, randomKey []byte, encryptionEnabled bool, logger gethlog.Logger) (CertStorage, error)

NewCertStorage creates a new certificate storage instance based on the database type

type UserStorage

type UserStorage interface {
	AddUser(userID []byte, privateKey []byte) error
	DeleteUser(userID []byte) error
	AddAccount(userID []byte, accountAddress []byte, signature []byte, signatureType viewingkey.SignatureType) error
	AddSessionKey(userID []byte, key common.GWSessionKey) error
	ActivateSessionKey(userID []byte, active bool) error
	RemoveSessionKey(userID []byte) error
	GetUser(userID []byte) (*common.GWUser, error)
	GetEncryptionKey() []byte
}

todo - pass the Context

func New

func New(dbType, dbConnectionURL, dbPath string, randomKey []byte, logger gethlog.Logger) (UserStorage, error)

type UserStorageWithCache

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

UserStorageWithCache implements the UserStorage interface with caching

func NewUserStorageWithCache

func NewUserStorageWithCache(storage UserStorage, logger log.Logger) (*UserStorageWithCache, error)

NewUserStorageWithCache creates a new UserStorageWithCache instance

func (*UserStorageWithCache) ActivateSessionKey

func (s *UserStorageWithCache) ActivateSessionKey(userID []byte, active bool) error

func (*UserStorageWithCache) AddAccount

func (s *UserStorageWithCache) AddAccount(userID []byte, accountAddress []byte, signature []byte, signatureType viewingkey.SignatureType) error

AddAccount adds an account to a user and invalidates the cache for the userID

func (*UserStorageWithCache) AddSessionKey

func (s *UserStorageWithCache) AddSessionKey(userID []byte, key wecommon.GWSessionKey) error

func (*UserStorageWithCache) AddUser

func (s *UserStorageWithCache) AddUser(userID []byte, privateKey []byte) error

AddUser adds a new user and invalidates the cache for the userID

func (*UserStorageWithCache) DeleteUser

func (s *UserStorageWithCache) DeleteUser(userID []byte) error

DeleteUser deletes a user and invalidates the cache for the userID

func (*UserStorageWithCache) GetEncryptionKey

func (s *UserStorageWithCache) GetEncryptionKey() []byte

GetEncryptionKey delegates to the underlying storage

func (*UserStorageWithCache) GetUser

func (s *UserStorageWithCache) GetUser(userID []byte) (*wecommon.GWUser, error)

GetUser retrieves a user from the cache or underlying storage

func (*UserStorageWithCache) RemoveSessionKey

func (s *UserStorageWithCache) RemoveSessionKey(userID []byte) error