storage

Documentation

Index

• func KeysWithFixedSlashed(keys []string) []string
• func NewAppStorage(settings model.DatabaseSettings) (model.AppStorage, error)
• func NewConnectionTester(settings model.TestConnection) (model.ConnectionTester, error)
• func NewDatabaseConnectionTester(settings model.DatabaseSettings) model.ConnectionTester
• func NewFS(settings model.FileStorageSettings) (fs.FS, error)
• func NewFileStorageConnectionTester(settings model.FileStorageSettings, expectedFiles []string) model.ConnectionTester
• func NewInviteStorage(settings model.DatabaseSettings) (model.InviteStorage, error)
• func NewKeyStorage(settings model.FileStorageSettings) (model.KeyStorage, error)
• func NewKeyStorageConnectionTester(settings model.FileStorageSettings) model.ConnectionTester
• func NewManagementKeys(settings model.DatabaseSettings) (model.ManagementKeysStorage, error)
• func NewSessionStorage(settings model.SessionStorageSettings) (model.SessionStorage, error)
• func NewTokenBlacklistStorage(settings model.DatabaseSettings) (model.TokenBlacklist, error)
• func NewTokenStorage(settings model.DatabaseSettings) (model.TokenStorage, error)
• func NewUserStorage(settings model.DatabaseSettings) (model.UserStorage, error)
• func NewVerificationCodesStorage(settings model.DatabaseSettings) (model.VerificationCodeStorage, error)
• type AlwaysFailedConnectionTester
  • func (ct AlwaysFailedConnectionTester) Connect() error
• type AlwaysHappyConnectionTester
  • func (ct AlwaysHappyConnectionTester) Connect() error
• type FSWatcher
  • func NewFSWatcher(f fs.FS, keys []string, poll time.Duration) *FSWatcher
  • func (w *FSWatcher) AppendForWatching(path string)
  • func (w *FSWatcher) ErrorChan() <-chan error
  • func (w *FSWatcher) IsWatching() bool
  • func (w *FSWatcher) Stop()
  • func (w *FSWatcher) Watch()
  • func (w *FSWatcher) WatchChan() <-chan []string
• type RootReplacedFS
  • func (f *RootReplacedFS) Open(name string) (fs.File, error)

Functions

func KeysWithFixedSlashed

func KeysWithFixedSlashed(keys []string) []string

KeysWithFixedSlashed remove prefixed or postfixed slashed in a path because it is not valid path and will fail fs.ValidPath validation

func NewAppStorage

func NewAppStorage(settings model.DatabaseSettings) (model.AppStorage, error)

NewAppStorage creates new app storage from settings

func NewConnectionTester

func NewConnectionTester(settings model.TestConnection) (model.ConnectionTester, error)

func NewDatabaseConnectionTester

func NewDatabaseConnectionTester(settings model.DatabaseSettings) model.ConnectionTester

func NewFS

func NewFS(settings model.FileStorageSettings) (fs.FS, error)

func NewFileStorageConnectionTester

func NewFileStorageConnectionTester(settings model.FileStorageSettings, expectedFiles []string) model.ConnectionTester

func NewInviteStorage

func NewInviteStorage(settings model.DatabaseSettings) (model.InviteStorage, error)

NewInviteStorage creates new invite storage from settings

func NewKeyStorage

func NewKeyStorage(settings model.FileStorageSettings) (model.KeyStorage, error)

func NewKeyStorageConnectionTester

func NewKeyStorageConnectionTester(settings model.FileStorageSettings) model.ConnectionTester

func NewManagementKeys

func NewManagementKeys(settings model.DatabaseSettings) (model.ManagementKeysStorage, error)

NewManagementKeys creates new management keys storage from settings.

func NewSessionStorage

func NewSessionStorage(settings model.SessionStorageSettings) (model.SessionStorage, error)

NewSessionStorage creates new sessions storage from settings

func NewTokenBlacklistStorage

func NewTokenBlacklistStorage(settings model.DatabaseSettings) (model.TokenBlacklist, error)

NewTokenBlacklistStorage creates new tokens blacklist storage from settings

func NewTokenStorage

func NewTokenStorage(settings model.DatabaseSettings) (model.TokenStorage, error)

NewTokenStorage creates new tokens storage from settings

func NewUserStorage

func NewUserStorage(settings model.DatabaseSettings) (model.UserStorage, error)

NewUserStorage creates new users storage from settings

func NewVerificationCodesStorage

func NewVerificationCodesStorage(settings model.DatabaseSettings) (model.VerificationCodeStorage, error)

NewVerificationCodesStorage creates new verification codes storage from settings

Types

type AlwaysFailedConnectionTester

type AlwaysFailedConnectionTester struct{}

func (AlwaysFailedConnectionTester) Connect

func (ct AlwaysFailedConnectionTester) Connect() error

type AlwaysHappyConnectionTester

type AlwaysHappyConnectionTester struct{}

func (AlwaysHappyConnectionTester) Connect

func (ct AlwaysHappyConnectionTester) Connect() error

type FSWatcher

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

FSWatcher watch for files changes in FS and notifies on file change

func NewFSWatcher

func NewFSWatcher(f fs.FS, keys []string, poll time.Duration) *FSWatcher

func (*FSWatcher) AppendForWatching

func (w *FSWatcher) AppendForWatching(path string)

func (*FSWatcher) ErrorChan

func (w *FSWatcher) ErrorChan() <-chan error

func (*FSWatcher) IsWatching

func (w *FSWatcher) IsWatching() bool

func (*FSWatcher) Stop

func (w *FSWatcher) Stop()

func (*FSWatcher) Watch

func (w *FSWatcher) Watch()

func (*FSWatcher) WatchChan

func (w *FSWatcher) WatchChan() <-chan []string

type RootReplacedFS

type RootReplacedFS struct {
	Root string
	FS   fs.FS
}

RootReplacedFS add root prefix on top of every url of underlying fs.FS

func (*RootReplacedFS) Open

func (f *RootReplacedFS) Open(name string) (fs.File, error)

we add root path every time we want to open the file