db

Documentation

Index

• Variables
• type DB
  • func NewDB(dataDir string) (*DB, error)
  • func (db *DB) Count(prefix string, filter string, countProcessor func(cnt int64) error) error
  • func (db *DB) Del(prefix string, key string) error
  • func (db *DB) DelByPrefix(prefix string) error
  • func (db *DB) DelEverything() error
  • func (db *DB) DelManyRefs(prefix string, keys []string) error
  • func (db *DB) Enumerate(prefix string, enumProcessor func(key string, value []byte) (bool, error)) error
  • func (db *DB) Fix() error
  • func (db *DB) Get(prefix string, key string, valueProcessor func(value []byte) error) error
  • func (db *DB) List(prefix string, filter string, offset int64, limit int64, ...) error
  • func (db *DB) RefMany(prefix string, keys []string) error
  • func (db *DB) Set(prefix string, key string, value interface{}) error
  • func (db *DB) SetMany(prefix string, keys []string, values []interface{}) error

Variables

var ErrKeyNotFound = errors.New("Key not found")

ErrKeyNotFound ..

Types

type DB

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

DB holds the database

func NewDB

func NewDB(dataDir string) (*DB, error)

NewDB creates or loads a database at folder dataDir

func (*DB) Count

func (db *DB) Count(prefix string, filter string, countProcessor func(cnt int64) error) error

Count ..

func (*DB) Del

func (db *DB) Del(prefix string, key string) error

Del ..

func (*DB) DelByPrefix

func (db *DB) DelByPrefix(prefix string) error

DelByPrefix ..

func (*DB) DelEverything

func (db *DB) DelEverything() error

DelEverything ..

func (*DB) DelManyRefs

func (db *DB) DelManyRefs(prefix string, keys []string) error

DelManyRefs ..

func (*DB) Enumerate

func (db *DB) Enumerate(prefix string, enumProcessor func(key string, value []byte) (bool, error)) error

Enumerate ..

func (*DB) Fix

func (db *DB) Fix() error

Fix ..

func (*DB) Get

func (db *DB) Get(prefix string, key string, valueProcessor func(value []byte) error) error

Get ..

func (*DB) List

func (db *DB) List(prefix string, filter string, offset int64, limit int64, valuesProcessor func(keys []string, values [][]byte) error) error

List ..

func (*DB) RefMany

func (db *DB) RefMany(prefix string, keys []string) error

RefMany ..

func (*DB) Set

func (db *DB) Set(prefix string, key string, value interface{}) error

Set ..

func (*DB) SetMany

func (db *DB) SetMany(prefix string, keys []string, values []interface{}) error

SetMany ..