rocksdb

Documentation

Index

• func NewKVStore(dir string, wal string, fs vfs.IFS) (kv.IKVStore, error)
• type KV
  • func (r *KV) BulkRemoveEntries(fk []byte, lk []byte) error
  • func (r *KV) Close() error
  • func (r *KV) CommitWriteBatch(wb kv.IWriteBatch) error
  • func (r *KV) CompactEntries(fk []byte, lk []byte) error
  • func (r *KV) DeleteValue(key []byte) error
  • func (r *KV) FullCompaction() error
  • func (r *KV) GetValue(key []byte, op func([]byte) error) error
  • func (r *KV) GetWriteBatch(ctx raftio.IContext) kv.IWriteBatch
  • func (r *KV) IterateValue(fk []byte, lk []byte, inc bool, op func(key []byte, data []byte) (bool, error)) error
  • func (r *KV) Name() string
  • func (r *KV) SaveValue(key []byte, value []byte) error

Functions

func NewKVStore

func NewKVStore(dir string, wal string, fs vfs.IFS) (kv.IKVStore, error)

NewKVStore returns a RocksDB based IKVStore instance.

Types

type KV

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

KV is a RocksDB based IKVStore type.

func (*KV) BulkRemoveEntries

func (r *KV) BulkRemoveEntries(fk []byte, lk []byte) error

BulkRemoveEntries returns the keys specified by the input range.

func (*KV) Close

func (r *KV) Close() error

Close closes the RDB object.

func (*KV) CommitWriteBatch

func (r *KV) CommitWriteBatch(wb kv.IWriteBatch) error

CommitWriteBatch commits the write batch.

func (*KV) CompactEntries

func (r *KV) CompactEntries(fk []byte, lk []byte) error

CompactEntries compacts the specified key range.

func (*KV) DeleteValue

func (r *KV) DeleteValue(key []byte) error

DeleteValue deletes the specified key value pair.

func (*KV) FullCompaction

func (r *KV) FullCompaction() error

FullCompaction compacts the whole key space.

func (*KV) GetValue

func (r *KV) GetValue(key []byte,
	op func([]byte) error) error

GetValue returns the value associated with the specified key.

func (*KV) GetWriteBatch

func (r *KV) GetWriteBatch(ctx raftio.IContext) kv.IWriteBatch

GetWriteBatch returns a write batch instance.

func (*KV) IterateValue

func (r *KV) IterateValue(fk []byte, lk []byte, inc bool,
	op func(key []byte, data []byte) (bool, error)) error

IterateValue iterates the key value pairs.

func (*KV) Name

func (r *KV) Name() string

Name returns the IKVStore type name.

func (*KV) SaveValue

func (r *KV) SaveValue(key []byte, value []byte) error

SaveValue saves the specified key value pair.