kvdb

README

TODO: syndtr/goleveldb should be replaced with actual LevelDB instance

Documentation

Index

• Constants
• type DB
  • func NewDB(name string, backend string, dir string) DB
  • func NewLevelDB(name string) (DB, error)
  • func NewMemDB(path string) (DB, error)
• type IBatch
• type IQuery
• type LevelDB
  • func (db *LevelDB) Close()
  • func (db *LevelDB) DB() *leveldb.DB
  • func (db *LevelDB) Delete(key []byte)
  • func (db *LevelDB) DeleteSync(key []byte)
  • func (db *LevelDB) Get(key []byte) []byte
  • func (db *LevelDB) GetIter(key string, bitSize int64) IQuery
  • func (d *LevelDB) NewBatch(sync bool) IBatch
  • func (db *LevelDB) Print()
  • func (db *LevelDB) Query(key string, beg, end, bitSize int64) IQuery
  • func (db *LevelDB) Set(key []byte, value []byte)
  • func (db *LevelDB) SetSync(key []byte, value []byte)
• type MemDB
  • func (db *MemDB) Close()
  • func (db *MemDB) Delete(key []byte)
  • func (db *MemDB) DeleteSync(key []byte)
  • func (db *MemDB) Get(key []byte) []byte
  • func (db *MemDB) GetIter(key string, bitSize int64) IQuery
  • func (db *MemDB) NewBatch(sync bool) IBatch
  • func (db *MemDB) Print()
  • func (db *MemDB) Query(key string, beg, end, bitSize int64) IQuery
  • func (db *MemDB) Set(key []byte, value []byte)
  • func (db *MemDB) SetSync(key []byte, value []byte)

Constants

const DBBackendLevelDB = "leveldb"

const DBBackendMemDB = "memdb"

Database types

const DBBackendRocksDB = "rocksdb"

Types

type DB

type DB interface {
	Get([]byte) []byte
	Set([]byte, []byte)
	SetSync([]byte, []byte)
	Delete([]byte)
	DeleteSync([]byte)
	Close()
	Query(key string, beg, end, bitSize int64) IQuery
	GetIter(key string, bitSize int64) IQuery
	NewBatch(sync bool) IBatch
	// For debugging
	Print()
}

func NewDB

func NewDB(name string, backend string, dir string) DB

func NewLevelDB

func NewLevelDB(name string) (DB, error)

func NewMemDB

func NewMemDB(path string) (DB, error)

type IBatch

type IBatch interface {
	Put(key, value []byte) error
	Delete(key []byte) error
	Commit() error
}

type IQuery

type IQuery interface {
	Seek(i int64) IQuery
	FetchAll(limit int64, asc bool) (keys [][]byte, vals [][]byte, err error)
	Key() []byte
	Close()
	Error() error
	Value() []byte
	Prev() bool
	Next() bool
}

type LevelDB

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

func (*LevelDB) Close

func (db *LevelDB) Close()

func (*LevelDB) DB

func (db *LevelDB) DB() *leveldb.DB

func (*LevelDB) Delete

func (db *LevelDB) Delete(key []byte)

func (*LevelDB) DeleteSync

func (db *LevelDB) DeleteSync(key []byte)

func (*LevelDB) Get

func (db *LevelDB) Get(key []byte) []byte

func (*LevelDB) GetIter

func (db *LevelDB) GetIter(key string, bitSize int64) IQuery

func (*LevelDB) NewBatch

func (d *LevelDB) NewBatch(sync bool) IBatch

因为是金融系统，这个选项还是有必要，避免发生丢数据的情况 而我们设计整个系统尽量采用批量提交，所以性能应该还是可以的

func (*LevelDB) Print

func (db *LevelDB) Print()

func (*LevelDB) Query

func (db *LevelDB) Query(key string, beg, end, bitSize int64) IQuery

func (*LevelDB) Set

func (db *LevelDB) Set(key []byte, value []byte)

func (*LevelDB) SetSync

func (db *LevelDB) SetSync(key []byte, value []byte)

type MemDB

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

func (*MemDB) Close

func (db *MemDB) Close()

func (*MemDB) Delete

func (db *MemDB) Delete(key []byte)

func (*MemDB) DeleteSync

func (db *MemDB) DeleteSync(key []byte)

func (*MemDB) Get

func (db *MemDB) Get(key []byte) []byte

func (*MemDB) GetIter

func (db *MemDB) GetIter(key string, bitSize int64) IQuery

func (*MemDB) NewBatch

func (db *MemDB) NewBatch(sync bool) IBatch

func (*MemDB) Print

func (db *MemDB) Print()

func (*MemDB) Query

func (db *MemDB) Query(key string, beg, end, bitSize int64) IQuery

func (*MemDB) Set

func (db *MemDB) Set(key []byte, value []byte)

func (*MemDB) SetSync

func (db *MemDB) SetSync(key []byte, value []byte)