engine

Documentation

Index

• type Engine
  • func NewLevelEngine(db *leveldb.DB) Engine
• type LevelEngine
  • func (ldb *LevelEngine) Bulk() kv.Bulk
  • func (ldb *LevelEngine) Close() error
  • func (ldb *LevelEngine) Delete(key []byte) error
  • func (ldb *LevelEngine) DeleteRange(ctx context.Context, r kv.Range) error
  • func (ldb *LevelEngine) Get(key []byte) ([]byte, error)
  • func (ldb *LevelEngine) Has(key []byte) (bool, error)
  • func (ldb *LevelEngine) IsNotFound(err error) bool
  • func (ldb *LevelEngine) Iterate(r kv.Range) kv.Iterator
  • func (ldb *LevelEngine) Put(key, val []byte) error
  • func (ldb *LevelEngine) Snapshot() kv.Snapshot
  • func (ldb *LevelEngine) Stats(s *leveldb.DBStats) error

Types

type Engine

type Engine interface {
	kv.Store
	io.Closer
}

Engine defines the interface of K-V engine.

func NewLevelEngine

func NewLevelEngine(db *leveldb.DB) Engine

NewLevelEngine creates leveldb instance which implements the Engine interface.

type LevelEngine

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

func (*LevelEngine) Bulk

func (ldb *LevelEngine) Bulk() kv.Bulk

func (*LevelEngine) Close

func (ldb *LevelEngine) Close() error

func (*LevelEngine) Delete

func (ldb *LevelEngine) Delete(key []byte) error

func (*LevelEngine) DeleteRange

func (ldb *LevelEngine) DeleteRange(ctx context.Context, r kv.Range) error

func (*LevelEngine) Get

func (ldb *LevelEngine) Get(key []byte) ([]byte, error)

func (*LevelEngine) Has

func (ldb *LevelEngine) Has(key []byte) (bool, error)

func (*LevelEngine) IsNotFound

func (ldb *LevelEngine) IsNotFound(err error) bool

func (*LevelEngine) Iterate

func (ldb *LevelEngine) Iterate(r kv.Range) kv.Iterator

func (*LevelEngine) Put

func (ldb *LevelEngine) Put(key, val []byte) error

func (*LevelEngine) Snapshot

func (ldb *LevelEngine) Snapshot() kv.Snapshot

func (*LevelEngine) Stats

func (ldb *LevelEngine) Stats(s *leveldb.DBStats) error