db

README

db

a key-value file system database

Documentation

Index

• Variables
• func ToBytes(data any) []byte
• type DB
  • func New(dirs ...string) (*DB, error)
  • func (t *DB) Close()
  • func (t *DB) ConcurrencyList(prefix string, concurrency int, fn func(key string, value []byte) error) error
  • func (t *DB) ConflictRetryTxn(fn func(txn *Txn) error) error
  • func (t *DB) Dec(txn *Txn, key string, step int64) (int64, error)
  • func (t *DB) Del(txn *Txn, key string) error
  • func (t *DB) Get(txn *Txn, key string) ([]byte, error)
  • func (t *DB) Has(txn *Txn, key string) (bool, error)
  • func (t *DB) Inc(txn *Txn, key string, step int64) (int64, error)
  • func (t *DB) List(prefix string, beginKey string, keyOnly bool, ...) error
  • func (t *DB) Set(txn *Txn, key string, value any) error
  • func (t *DB) Txn(fn func(txn *Txn) error, readOnly ...bool) error
  • func (t *DB) Unmarshal(txn *Txn, key string, value any) error
• type Txn

Variables

var ErrConflict = badger.ErrConflict

var ErrKeyNotFound = badger.ErrKeyNotFound

var ErrStopIterate = errors.New("stop iterate")

Functions

func ToBytes

func ToBytes(data any) []byte

Types

type DB

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

func New

func New(dirs ...string) (*DB, error)

or set env: DATABASE_DIR

func (*DB) Close

func (t *DB) Close()

func (*DB) ConcurrencyList

func (t *DB) ConcurrencyList(prefix string, concurrency int, fn func(key string, value []byte) error) error

func (*DB) ConflictRetryTxn

func (t *DB) ConflictRetryTxn(fn func(txn *Txn) error) error

func (*DB) Dec

func (t *DB) Dec(txn *Txn, key string, step int64) (int64, error)

func (*DB) Del

func (t *DB) Del(txn *Txn, key string) error

func (*DB) Get

func (t *DB) Get(txn *Txn, key string) ([]byte, error)

func (*DB) Has

func (t *DB) Has(txn *Txn, key string) (bool, error)

func (*DB) Inc

func (t *DB) Inc(txn *Txn, key string, step int64) (int64, error)

return new value

func (*DB) List

func (t *DB) List(prefix string, beginKey string, keyOnly bool, fn func(key string, value []byte) error) error

func (*DB) Set

func (t *DB) Set(txn *Txn, key string, value any) error

func (*DB) Txn

func (t *DB) Txn(fn func(txn *Txn) error, readOnly ...bool) error

func (*DB) Unmarshal

func (t *DB) Unmarshal(txn *Txn, key string, value any) error

type Txn

type Txn struct {
	*badger.Txn
}