levelkv

Documentation

Index

• type LevelKV
  • func NewLevelKVDB(ctx context.Context, ev *iflog.IpfsLog, log *zap.Logger) (*LevelKV, error)
  • func (kv *LevelKV) Close()
  • func (kv *LevelKV) Delete(ctx context.Context, key []byte) error
  • func (kv *LevelKV) Get(key []byte) ([]byte, error)
  • func (kv *LevelKV) GetSnapshot() (*leveldb.Snapshot, error)
  • func (kv *LevelKV) Has(key []byte) bool
  • func (kv *LevelKV) List() map[string]string
  • func (kv *LevelKV) NewIterator(slice *util.Range, ro *opt.ReadOptions) iterator.Iterator
  • func (kv *LevelKV) Put(ctx context.Context, key, value []byte) error
• type OperateType

Types

type LevelKV

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

func NewLevelKVDB

func NewLevelKVDB(ctx context.Context, ev *iflog.IpfsLog, log *zap.Logger) (*LevelKV, error)

func (*LevelKV) Close

func (kv *LevelKV) Close()

func (*LevelKV) Delete

func (kv *LevelKV) Delete(ctx context.Context, key []byte) error

func (*LevelKV) Get

func (kv *LevelKV) Get(key []byte) ([]byte, error)

func (*LevelKV) GetSnapshot

func (kv *LevelKV) GetSnapshot() (*leveldb.Snapshot, error)

func (*LevelKV) Has

func (kv *LevelKV) Has(key []byte) bool

func (*LevelKV) List

func (kv *LevelKV) List() map[string]string

func (*LevelKV) NewIterator

func (kv *LevelKV) NewIterator(slice *util.Range, ro *opt.ReadOptions) iterator.Iterator

func (*LevelKV) Put

func (kv *LevelKV) Put(ctx context.Context, key, value []byte) error

type OperateType

type OperateType byte

const (
	SetOperateType OperateType = iota
	DeleteOperateType
)