rocksdb

Documentation

Index

• type RocksDB
  • func NewDB(name string, dir string) (*RocksDB, error)
  • func NewDBWithOptions(name string, dir string, opts *gorocksdb.Options) (*RocksDB, error)
  • func (db *RocksDB) Close() error
  • func (db *RocksDB) DB() *gorocksdb.DB
  • func (db *RocksDB) Delete(key []byte) error
  • func (db *RocksDB) DeleteSync(key []byte) error
  • func (db *RocksDB) Get(key []byte) ([]byte, error)
  • func (db *RocksDB) Has(key []byte) (bool, error)
  • func (db *RocksDB) Iterator(start, end []byte) (tmdb.Iterator, error)
  • func (db *RocksDB) NewBatch() tmdb.Batch
  • func (db *RocksDB) Print() error
  • func (db *RocksDB) ReverseIterator(start, end []byte) (tmdb.Iterator, error)
  • func (db *RocksDB) Set(key []byte, value []byte) error
  • func (db *RocksDB) SetSync(key []byte, value []byte) error
  • func (db *RocksDB) Stats() map[string]string

Types

type RocksDB

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

RocksDB is a RocksDB backend.

func NewDB

func NewDB(name string, dir string) (*RocksDB, error)

func NewDBWithOptions

func NewDBWithOptions(name string, dir string, opts *gorocksdb.Options) (*RocksDB, error)

func (*RocksDB) Close

func (db *RocksDB) Close() error

Close implements DB.

func (*RocksDB) DB

func (db *RocksDB) DB() *gorocksdb.DB

func (*RocksDB) Delete

func (db *RocksDB) Delete(key []byte) error

Delete implements DB.

func (*RocksDB) DeleteSync

func (db *RocksDB) DeleteSync(key []byte) error

DeleteSync implements DB.

func (*RocksDB) Get

func (db *RocksDB) Get(key []byte) ([]byte, error)

Get implements DB.

func (*RocksDB) Has

func (db *RocksDB) Has(key []byte) (bool, error)

Has implements DB.

func (*RocksDB) Iterator

func (db *RocksDB) Iterator(start, end []byte) (tmdb.Iterator, error)

Iterator implements DB.

func (*RocksDB) NewBatch

func (db *RocksDB) NewBatch() tmdb.Batch

NewBatch implements DB.

func (*RocksDB) Print

func (db *RocksDB) Print() error

Print implements DB.

func (*RocksDB) ReverseIterator

func (db *RocksDB) ReverseIterator(start, end []byte) (tmdb.Iterator, error)

ReverseIterator implements DB.

func (*RocksDB) Set

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

Set implements DB.

func (*RocksDB) SetSync

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

SetSync implements DB.

func (*RocksDB) Stats

func (db *RocksDB) Stats() map[string]string

Stats implements DB.