storage

type BadgerHoldStorage struct {
	Name         string `json:"-"` // Storage identifier
	GlobalDbPath string `json:"-"` // Base data directory
	DataPath     string `json:"-"` // Module subdirectory
	DataBaseName string `json:"-"` // Database directory name
	// contains filtered or unexported fields
}

type BadgerStorage struct {
	Name         string `json:"-"` // Storage identifier
	GlobalDbPath string `json:"-"` // Base data directory
	DataPath     string `json:"-"` // Module subdirectory
	DataBaseName string `json:"-"` // Database directory name
	// contains filtered or unexported fields
}

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

type BinFileStorage struct {
	Name         string `json:"-"` // Storage identifier
	GlobalDbPath string `json:"-"` // Base data directory
	DataPath     string `json:"-"` // Module subdirectory
	DataBaseName string `json:"-"` // Filename
	// contains filtered or unexported fields
}

type BinStorage interface {
	// IsExists returns true if the storage file exists.
	IsExists() bool
	// Save writes raw binary data to storage.
	Save(rawData []byte) (err error)
	// Load reads raw binary data from storage.
	Load() (rawData []byte, err error)
}

type Data interface {
	Key
	// Encode serializes the data to bytes for storage.
	Encode() []byte
	// Decode deserializes the data from bytes.
	Decode([]byte) error
}

type Key interface {
	// GetKey returns the byte representation of the storage key.
	GetKey() []byte
}

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

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

type Replicator interface {
	// Update is called when data is saved.
	Update(key []byte, data []byte)
	// Delete is called when data is deleted.
	Delete(key []byte)
}

type SimpleKeyStorage interface {
	// Save persists data to storage.
	Save(data Data) (err error)
	// Read retrieves data by key and populates the data parameter.
	Read(key Key, data Data) (err error)
	// ReadAll iterates over all records, calling processor for each value.
	ReadAll(processor func(raw []byte) (err error)) (err error)
	// ReadAllKey iterates over all records, calling processor with both key and value.
	ReadAllKey(processor func(key, raw []byte) (err error)) (err error)
	// Delete removes a record by key.
	Delete(rowKey []byte) (err error)
}

type SimpleStorage interface {
	// Save persists data to storage.
	Save(data Data) (err error)
	// Read retrieves data by key and populates the data parameter.
	Read(key Key, data Data) (err error)
	// ReadAll iterates over all records, calling processor for each.
	ReadAll(processor func(raw []byte) (err error)) (err error)
	// Delete removes a record by key.
	Delete(rowKey []byte) (err error)
}