rocksdb

Documentation

Index

• func ExistOrStore(rocksdb *gorocksdb.DB, wb *gorocksdb.WriteBatch, key []byte) (bool, error)
• func RocksDbBatchDelWithWB(wb *gorocksdb.WriteBatch, keyList [][]byte)
• func RocksDbBatchWriteWithWB(wb *gorocksdb.WriteBatch, objList IHashListBatchWrite, ...) error
• func RocksDbIteratorLoad(rocksdb *gorocksdb.DB, keyPrefix []byte, ...) error
• func RocksDbLoadOneByPrefix(rocksdb *gorocksdb.DB, keyPrefix []byte, ...) (interface{}, error)
• func RocksDbNormalLoad(rocksDb *gorocksdb.DB, key []byte, handle func(bytes []byte) error) error
• func RocksDbNormalStore(rocksDb *gorocksdb.DB, key []byte, bytes func() ([]byte, error)) error
• func RocksDbSafeGet(rocksdb *gorocksdb.DB, key []byte) ([]byte, error)
• func RocksDbSafeGetWithReadOpt(rocksdb *gorocksdb.DB, rOpts *gorocksdb.ReadOptions, key []byte) ([]byte, error)
• func SafeHandleReaderKV(key, value *gorocksdb.Slice, ...) (bool, error)
• type IHashListBatchWrite

Functions

func ExistOrStore

func ExistOrStore(rocksdb *gorocksdb.DB, wb *gorocksdb.WriteBatch, key []byte) (bool, error)

func RocksDbBatchDelWithWB

func RocksDbBatchDelWithWB(wb *gorocksdb.WriteBatch, keyList [][]byte)

func RocksDbBatchWriteWithWB

func RocksDbBatchWriteWithWB(wb *gorocksdb.WriteBatch, objList IHashListBatchWrite, key func(hash types.Hash) []byte) error

func RocksDbIteratorLoad

func RocksDbIteratorLoad(rocksdb *gorocksdb.DB, keyPrefix []byte, handleBytes func(keyBytes, dataBytes []byte) error) error

func RocksDbLoadOneByPrefix

func RocksDbLoadOneByPrefix(rocksdb *gorocksdb.DB, keyPrefix []byte, handleBytes func(keyBytes, dataBytes []byte) (interface{}, error)) (interface{}, error)

func RocksDbNormalLoad

func RocksDbNormalLoad(rocksDb *gorocksdb.DB, key []byte, handle func(bytes []byte) error) error

func RocksDbNormalStore

func RocksDbNormalStore(rocksDb *gorocksdb.DB, key []byte, bytes func() ([]byte, error)) error

func RocksDbSafeGet

func RocksDbSafeGet(rocksdb *gorocksdb.DB, key []byte) ([]byte, error)

func RocksDbSafeGetWithReadOpt

func RocksDbSafeGetWithReadOpt(rocksdb *gorocksdb.DB, rOpts *gorocksdb.ReadOptions, key []byte) ([]byte, error)

func SafeHandleReaderKV

func SafeHandleReaderKV(key, value *gorocksdb.Slice, handleBytes func(keyBytes, dataBytes []byte) error) (bool, error)

Types

type IHashListBatchWrite

type IHashListBatchWrite interface {
	Obj(i int) interface{}
	Size() int
	Hash(i int) types.Hash
}