storage

Jun 15, 2025

Changes in this version

+ type DBError string

+ func (e DBError) Error() string

May 31, 2025

Changes in this version

type WarpTransactioner

+ Discard func() error

type WarpTxn

+ func (t *WarpTxn) Discard() error

May 29, 2025

Changes in this version

type DB

+ func (db *DB) NewTxn() (WarpTransactioner, error)

+ type Txn = badger.Txn

+ type WarpTransactioner interface

+ BatchGet func(keys ...DatabaseKey) ([]ListItem, error)

+ BatchSet func(data []ListItem) (err error)

+ Commit func() error

+ Decrement func(key DatabaseKey) (uint64, error)

+ Delete func(key DatabaseKey) error

+ Get func(key DatabaseKey) ([]byte, error)

+ Increment func(key DatabaseKey) (uint64, error)

+ IterateKeys func(prefix DatabaseKey, handler IterKeysFunc) error

+ List func(prefix DatabaseKey, limit *uint64, cursor *string) ([]ListItem, string, error)

+ ReverseIterateKeys func(prefix DatabaseKey, handler IterKeysFunc) error

+ Rollback func()

+ Set func(key DatabaseKey, value []byte) error

+ SetWithTTL func(key DatabaseKey, value []byte, ttl time.Duration) error

type WarpTxn

+ func (t *WarpTxn) BatchGet(keys ...DatabaseKey) ([]ListItem, error)

+ func (t *WarpTxn) BatchSet(data []ListItem) (err error)

+ func (t *WarpTxn) Commit() error

+ func (t *WarpTxn) Decrement(key DatabaseKey) (uint64, error)

+ func (t *WarpTxn) Delete(key DatabaseKey) error

+ func (t *WarpTxn) Get(key DatabaseKey) ([]byte, error)

+ func (t *WarpTxn) Increment(key DatabaseKey) (uint64, error)

+ func (t *WarpTxn) IterateKeys(prefix DatabaseKey, handler IterKeysFunc) error

+ func (t *WarpTxn) List(prefix DatabaseKey, limit *uint64, cursor *string) ([]ListItem, string, error)

+ func (t *WarpTxn) ReverseIterateKeys(prefix DatabaseKey, handler IterKeysFunc) error

+ func (t *WarpTxn) Rollback()

+ func (t *WarpTxn) Set(key DatabaseKey, value []byte) error

+ func (t *WarpTxn) SetWithTTL(key DatabaseKey, value []byte, ttl time.Duration) error

May 18, 2025

Changes in this version

+ const Delimeter

+ const FixedKey

+ const FixedRangeKey

+ const NoneRangeKey

+ var ErrKeyNotFound = badger.ErrKeyNotFound

+ var ErrNotRunning = errors.New("DB is not running")

+ var ErrStopIteration = errors.New("stop iteration")

+ var ErrWrongPassword = errors.New("wrong username or password")

+ type DB struct

+ func New(path string, isInMemory bool, dataFolder string) (*DB, error)

+ func (db *DB) Close()

+ func (db *DB) Delete(key DatabaseKey) error

+ func (db *DB) GC()

+ func (db *DB) Get(key DatabaseKey) ([]byte, error)

+ func (db *DB) GetExpiration(key DatabaseKey) (uint64, error)

+ func (db *DB) GetSize(key DatabaseKey) (int64, error)

+ func (db *DB) InnerDB() *badger.DB

+ func (db *DB) IsClosed() bool

+ func (db *DB) IsFirstRun() bool

+ func (db *DB) NewReadTxn() (WarpTxReader, error)

+ func (db *DB) NewWriteTxn() (WarpTxWriter, error)

+ func (db *DB) NextSequence() (uint64, error)

+ func (db *DB) Path() string

+ func (db *DB) Run(username, password string) (err error)

+ func (db *DB) Set(key DatabaseKey, value []byte) error

+ func (db *DB) SetWithTTL(key DatabaseKey, value []byte, ttl time.Duration) error

+ func (db *DB) Stats() map[string]string

+ func (db *DB) Sync() error

+ type DatabaseKey string

+ func (k DatabaseKey) Bytes() []byte

+ func (k DatabaseKey) DropId() string

+ func (k DatabaseKey) IsEmpty() bool

+ func (k DatabaseKey) String() string

+ type IdLayer string

+ func (l IdLayer) AddId(mandatoryPrefix string) IdLayer

+ func (l IdLayer) AddReversedTimestamp(tm time.Time) RangeLayer

+ func (l IdLayer) Build() DatabaseKey

+ type IterKeysFunc func(key string) error

+ type ListItem struct

+ Key string

+ Value []byte

+ type Namespace string

+ func NewPrefixBuilder(mandatoryNamespace string) Namespace

+ func (ns Namespace) AddRootID(mandatoryPrefix string) ParentLayer

+ func (ns Namespace) AddSubPrefix(p string) Namespace

+ func (ns Namespace) Build() DatabaseKey

+ type ParentLayer string

+ func (l ParentLayer) AddParentId(mandatoryPrefix string) IdLayer

+ func (l ParentLayer) AddRange(mandatoryPrefix RangePrefix) RangeLayer

+ func (l ParentLayer) AddReversedTimestamp(tm time.Time) RangeLayer

+ func (l ParentLayer) Build() DatabaseKey

+ type PrefixBuilder struct

+ func (pb *PrefixBuilder) AddReaderId(readerId string) *PrefixBuilder

+ func (pb *PrefixBuilder) AddWriterId(writerId string) *PrefixBuilder

+ type RangeLayer string

+ func (l RangeLayer) AddParentId(mandatoryPrefix string) IdLayer

+ func (l RangeLayer) Build() DatabaseKey

+ type RangePrefix string

+ type WarpDB = badger.DB

+ type WarpDBLogger interface

+ Debugf func(string, ...interface{})

+ Errorf func(string, ...interface{})

+ Infof func(string, ...interface{})

+ Warningf func(string, ...interface{})

+ type WarpReadTxn struct

+ func (t *WarpReadTxn) BatchGet(keys ...DatabaseKey) ([]ListItem, error)

+ func (t *WarpReadTxn) Commit() error

+ func (t *WarpReadTxn) Get(key DatabaseKey) ([]byte, error)

+ func (t *WarpReadTxn) IterateKeys(prefix DatabaseKey, handler IterKeysFunc) error

+ func (t *WarpReadTxn) List(prefix DatabaseKey, limit *uint64, cursor *string) ([]ListItem, string, error)

+ func (t *WarpReadTxn) ReverseIterateKeys(prefix DatabaseKey, handler IterKeysFunc) error

+ func (t *WarpReadTxn) Rollback()

+ type WarpTxReader interface

+ BatchGet func(keys ...DatabaseKey) ([]ListItem, error)

+ Commit func() error

+ Get func(key DatabaseKey) ([]byte, error)

+ IterateKeys func(prefix DatabaseKey, handler IterKeysFunc) error

+ List func(prefix DatabaseKey, limit *uint64, cursor *string) ([]ListItem, string, error)

+ ReverseIterateKeys func(prefix DatabaseKey, handler IterKeysFunc) error

+ Rollback func()

+ type WarpTxWriter interface

+ BatchSet func(data []ListItem) (err error)

+ Commit func() error

+ Decrement func(key DatabaseKey) (uint64, error)

+ Delete func(key DatabaseKey) error

+ Get func(key DatabaseKey) ([]byte, error)

+ Increment func(key DatabaseKey) (uint64, error)

+ Rollback func()

+ Set func(key DatabaseKey, value []byte) error

+ SetWithTTL func(key DatabaseKey, value []byte, ttl time.Duration) error

+ type WarpTxn = badger.Txn

+ type WarpWriteTxn struct

+ func (t *WarpWriteTxn) BatchSet(data []ListItem) (err error)

+ func (t *WarpWriteTxn) Commit() error

+ func (t *WarpWriteTxn) Decrement(key DatabaseKey) (uint64, error)

+ func (t *WarpWriteTxn) Delete(key DatabaseKey) error

+ func (t *WarpWriteTxn) Get(key DatabaseKey) ([]byte, error)

+ func (t *WarpWriteTxn) Increment(key DatabaseKey) (uint64, error)

+ func (t *WarpWriteTxn) Rollback()

+ func (t *WarpWriteTxn) Set(key DatabaseKey, value []byte) error

+ func (t *WarpWriteTxn) SetWithTTL(key DatabaseKey, value []byte, ttl time.Duration) error