leveldb

Documentation

Index

• Constants
• func Create(path string, m graph.Options) (kv.BucketKV, error)
• func Open(path string, m graph.Options) (kv.BucketKV, error)
• type DB
  • func (db *DB) Close() error
  • func (db *DB) Tx(update bool) (kv.FlatTx, error)
  • func (db *DB) Type() string
• type Iterator
  • func (it *Iterator) Close() error
  • func (it *Iterator) Err() error
  • func (it *Iterator) Key() []byte
  • func (it *Iterator) Next(ctx context.Context) bool
  • func (it *Iterator) Val() []byte
• type Tx
  • func (tx *Tx) Commit(ctx context.Context) error
  • func (tx *Tx) Del(k []byte) error
  • func (tx *Tx) Get(ctx context.Context, keys [][]byte) ([][]byte, error)
  • func (tx *Tx) Put(k, v []byte) error
  • func (tx *Tx) Rollback() error
  • func (tx *Tx) Scan(pref []byte) kv.KVIterator

Constants

const (
	Type = "leveldb"
)

Functions

func Create

func Create(path string, m graph.Options) (kv.BucketKV, error)

func Open

func Open(path string, m graph.Options) (kv.BucketKV, error)

Types

type DB

type DB struct {
	DB *leveldb.DB
	// contains filtered or unexported fields
}

func (*DB) Close

func (db *DB) Close() error

func (*DB) Tx

func (db *DB) Tx(update bool) (kv.FlatTx, error)

func (*DB) Type

func (db *DB) Type() string

type Iterator

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

func (*Iterator) Close

func (it *Iterator) Close() error

func (*Iterator) Err

func (it *Iterator) Err() error

func (*Iterator) Key

func (it *Iterator) Key() []byte

func (*Iterator) Next

func (it *Iterator) Next(ctx context.Context) bool

func (*Iterator) Val

func (it *Iterator) Val() []byte

type Tx

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

func (*Tx) Commit

func (tx *Tx) Commit(ctx context.Context) error

func (*Tx) Del

func (tx *Tx) Del(k []byte) error

func (*Tx) Get

func (tx *Tx) Get(ctx context.Context, keys [][]byte) ([][]byte, error)

func (*Tx) Put

func (tx *Tx) Put(k, v []byte) error

func (*Tx) Rollback

func (tx *Tx) Rollback() error

func (*Tx) Scan

func (tx *Tx) Scan(pref []byte) kv.KVIterator