leveldb

Documentation

Index

• func NewKVStore(dir string, wal string) (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) (kv.IKVStore, error)

NewKVStore returns a new leveldb based IKVStore instance.

Types

type KV

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

KV is a leveldb based IKVStore type.

func (*KV) BulkRemoveEntries

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

BulkRemoveEntries ...

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 ...

func (*KV) CompactEntries

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

CompactEntries ...

func (*KV) DeleteValue

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

DeleteValue ...

func (*KV) FullCompaction

func (r *KV) FullCompaction() error

FullCompaction ...

func (*KV) GetValue

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

GetValue ...

func (*KV) GetWriteBatch

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

GetWriteBatch ...

func (*KV) IterateValue

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

IterateValue ...

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 ...