storage

Documentation

Index

• type BadgerHoldStorage
  • func NewBadgerHoldStorage(name, globalDbPath, dbPath, dbFile string) (s *BadgerHoldStorage, err error)
  • func (s *BadgerHoldStorage) Do(processor func(db *badgerhold.Store))
  • func (s *BadgerHoldStorage) Insert(value interface{}) (err error)
• type BadgerStorage
  • func NewBadgerStorage(name, globalDbPath, dbPath, dbFile string) (s *BadgerStorage, err error)
  • func (s *BadgerStorage) Delete(rowKey []byte) (err error)
  • func (s *BadgerStorage) Do(processor func(db *badger.DB))
  • func (s *BadgerStorage) Read(key Key, data Data) (err error)
  • func (s *BadgerStorage) ReadAll(processor func(raw []byte) (err error)) (err error)
  • func (s *BadgerStorage) ReadAllKey(processor func(key, raw []byte) (err error)) (err error)
  • func (s *BadgerStorage) Save(value Data) (err error)
• type BadgerStorageReplicated
  • func NewBadgerStorageReplicated(name, globalDbPath, dbPath, dbFile string, replicator Replicator) (s *BadgerStorageReplicated, err error)
  • func (s *BadgerStorageReplicated) Delete(rowKey []byte) (err error)
  • func (s *BadgerStorageReplicated) Save(value Data) (err error)
• type BinFileStorage
  • func NewBinFileStorage(name, globalDbPath, dbPath, dbFile string) (s *BinFileStorage, err error)
  • func (s *BinFileStorage) IsExists() bool
  • func (s *BinFileStorage) Load() (rawData []byte, err error)
  • func (s *BinFileStorage) Save(rawData []byte) (err error)
• type BinStorage
• type Data
• type Key
• type Manager
  • func NewStorageManager(globalDbPath string) (m *Manager, err error)
  • func (m *Manager) GetBinFileStorage(name, moduleDbPath, moduleDbName string) (s BinStorage, err error)
  • func (m *Manager) GetModuleStorage(name, dbPath string) (s *ModuleManager)
  • func (m *Manager) GetNewBadgerHoldStorage(name, moduleDbPath, moduleDbName string) (s *BadgerHoldStorage, err error)
  • func (m *Manager) GetNewBadgerStorage(name, moduleDbPath, moduleDbName string) (s SimpleKeyStorage, err error)
• type ModuleManager
  • func (mm *ModuleManager) GetBinFileStorage(dbName string) (s BinStorage)
  • func (mm *ModuleManager) GetNewBadgerHoldStorage(moduleDbName string) (s *BadgerHoldStorage)
  • func (mm *ModuleManager) GetNewBadgerStorage(moduleDbName string) (s SimpleKeyStorage)
• type Replicator
• type SimpleKeyStorage
• type SimpleStorage

Types

type BadgerHoldStorage

type BadgerHoldStorage struct {
	Name         string `json:"-"`
	GlobalDbPath string `json:"-"`
	DataPath     string `json:"-"`
	DataBaseName string `json:"-"`
	// contains filtered or unexported fields
}

func NewBadgerHoldStorage

func NewBadgerHoldStorage(name, globalDbPath, dbPath, dbFile string) (s *BadgerHoldStorage, err error)

func (*BadgerHoldStorage) Do

func (s *BadgerHoldStorage) Do(processor func(db *badgerhold.Store))

func (*BadgerHoldStorage) Insert

func (s *BadgerHoldStorage) Insert(value interface{}) (err error)

type BadgerStorage

type BadgerStorage struct {
	Name         string `json:"-"`
	GlobalDbPath string `json:"-"`
	DataPath     string `json:"-"`
	DataBaseName string `json:"-"`
	// contains filtered or unexported fields
}

func NewBadgerStorage

func NewBadgerStorage(name, globalDbPath, dbPath, dbFile string) (s *BadgerStorage, err error)

func (*BadgerStorage) Delete

func (s *BadgerStorage) Delete(rowKey []byte) (err error)

func (*BadgerStorage) Do

func (s *BadgerStorage) Do(processor func(db *badger.DB))

func (*BadgerStorage) Read

func (s *BadgerStorage) Read(key Key, data Data) (err error)

func (*BadgerStorage) ReadAll

func (s *BadgerStorage) ReadAll(processor func(raw []byte) (err error)) (err error)

func (*BadgerStorage) ReadAllKey

func (s *BadgerStorage) ReadAllKey(processor func(key, raw []byte) (err error)) (err error)

func (*BadgerStorage) Save

func (s *BadgerStorage) Save(value Data) (err error)

type BadgerStorageReplicated

type BadgerStorageReplicated struct {
	BadgerStorage
	// contains filtered or unexported fields
}

func NewBadgerStorageReplicated

func NewBadgerStorageReplicated(name, globalDbPath, dbPath, dbFile string, replicator Replicator) (s *BadgerStorageReplicated, err error)

func (*BadgerStorageReplicated) Delete

func (s *BadgerStorageReplicated) Delete(rowKey []byte) (err error)

func (*BadgerStorageReplicated) Save

func (s *BadgerStorageReplicated) Save(value Data) (err error)

type BinFileStorage

type BinFileStorage struct {
	Name         string `json:"-"`
	GlobalDbPath string `json:"-"`
	DataPath     string `json:"-"`
	DataBaseName string `json:"-"`
	// contains filtered or unexported fields
}

func NewBinFileStorage

func NewBinFileStorage(name, globalDbPath, dbPath, dbFile string) (s *BinFileStorage, err error)

func (*BinFileStorage) IsExists

func (s *BinFileStorage) IsExists() bool

func (*BinFileStorage) Load

func (s *BinFileStorage) Load() (rawData []byte, err error)

func (*BinFileStorage) Save

func (s *BinFileStorage) Save(rawData []byte) (err error)

type BinStorage

type BinStorage interface {
	IsExists() bool
	Save(rawData []byte) (err error)
	Load() (rawData []byte, err error)
}

type Data

type Data interface {
	Key
	Encode() []byte
	Decode([]byte) error
}

type Key

type Key interface {
	GetKey() []byte
}

type Manager

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

func NewStorageManager

func NewStorageManager(globalDbPath string) (m *Manager, err error)

func (*Manager) GetBinFileStorage

func (m *Manager) GetBinFileStorage(name, moduleDbPath, moduleDbName string) (s BinStorage, err error)

func (*Manager) GetModuleStorage

func (m *Manager) GetModuleStorage(name, dbPath string) (s *ModuleManager)

func (*Manager) GetNewBadgerHoldStorage

func (m *Manager) GetNewBadgerHoldStorage(name, moduleDbPath, moduleDbName string) (s *BadgerHoldStorage, err error)

func (*Manager) GetNewBadgerStorage

func (m *Manager) GetNewBadgerStorage(name, moduleDbPath, moduleDbName string) (s SimpleKeyStorage, err error)

type ModuleManager

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

func (*ModuleManager) GetBinFileStorage

func (mm *ModuleManager) GetBinFileStorage(dbName string) (s BinStorage)

func (*ModuleManager) GetNewBadgerHoldStorage

func (mm *ModuleManager) GetNewBadgerHoldStorage(moduleDbName string) (s *BadgerHoldStorage)

func (*ModuleManager) GetNewBadgerStorage

func (mm *ModuleManager) GetNewBadgerStorage(moduleDbName string) (s SimpleKeyStorage)

type Replicator

type Replicator interface {
	Update(key []byte, data []byte)
	Delete(key []byte)
}

type SimpleKeyStorage

type SimpleKeyStorage interface {
	Save(data Data) (err error)
	Read(key Key, data Data) (err error)
	ReadAll(processor func(raw []byte) (err error)) (err error)
	ReadAllKey(processor func(key, raw []byte) (err error)) (err error)
	Delete(rowKey []byte) (err error)
}

type SimpleStorage

type SimpleStorage interface {
	Save(data Data) (err error)
	Read(key Key, data Data) (err error)
	ReadAll(processor func(raw []byte) (err error)) (err error)
	Delete(rowKey []byte) (err error)
}