leveldb

Documentation

Index

• Constants
• func OpenPath(path string) (flat.KV, error)
• type DB
  • func New(d *leveldb.DB) *DB
  • func Open(path string, opt *opt.Options) (*DB, error)
  • func (db *DB) Close() error
  • func (db *DB) SetReadOptions(ro *opt.ReadOptions)
  • func (db *DB) SetWriteOptions(wo *opt.WriteOptions)
  • func (db *DB) Tx(ctx context.Context, rw bool) (flat.Tx, error)
  • func (db *DB) Update(ctx context.Context, fn func(tx flat.Tx) error) error
  • func (db *DB) View(ctx context.Context, fn func(tx flat.Tx) error) error
• type Iterator
  • func (it *Iterator) Close() error
  • func (it *Iterator) Err() error
  • func (it *Iterator) Key() flat.Key
  • func (it *Iterator) Next(ctx context.Context) bool
  • func (it *Iterator) Reset()
  • func (it *Iterator) Seek(ctx context.Context, key flat.Key) bool
  • func (it *Iterator) Val() flat.Value
  • func (it *Iterator) WithPrefix(pref flat.Key) flat.Iterator
• type Tx
  • func (tx *Tx) Close() error
  • func (tx *Tx) Commit(ctx context.Context) error
  • func (tx *Tx) Del(ctx context.Context, k flat.Key) error
  • func (tx *Tx) Get(ctx context.Context, key flat.Key) (flat.Value, error)
  • func (tx *Tx) GetBatch(ctx context.Context, keys []flat.Key) ([]flat.Value, error)
  • func (tx *Tx) Put(ctx context.Context, k flat.Key, v flat.Value) error
  • func (tx *Tx) Scan(ctx context.Context, opts ...flat.IteratorOption) flat.Iterator

Constants

const (
	Name = "leveldb"
)

Functions

func OpenPath

func OpenPath(path string) (flat.KV, error)

Types

type DB

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

func New

func New(d *leveldb.DB) *DB

func Open

func Open(path string, opt *opt.Options) (*DB, error)

func (*DB) Close

func (db *DB) Close() error

func (*DB) SetReadOptions

func (db *DB) SetReadOptions(ro *opt.ReadOptions)

func (*DB) SetWriteOptions

func (db *DB) SetWriteOptions(wo *opt.WriteOptions)

func (*DB) Tx

func (db *DB) Tx(ctx context.Context, rw bool) (flat.Tx, error)

func (*DB) Update

func (db *DB) Update(ctx context.Context, fn func(tx flat.Tx) error) error

func (*DB) View

func (db *DB) View(ctx context.Context, fn func(tx flat.Tx) error) error

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() flat.Key

func (*Iterator) Next

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

func (*Iterator) Reset

func (it *Iterator) Reset()

func (*Iterator) Seek

func (it *Iterator) Seek(ctx context.Context, key flat.Key) bool

func (*Iterator) Val

func (it *Iterator) Val() flat.Value

func (*Iterator) WithPrefix

func (it *Iterator) WithPrefix(pref flat.Key) flat.Iterator

type Tx

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

func (*Tx) Close

func (tx *Tx) Close() error

func (*Tx) Commit

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

func (*Tx) Del

func (tx *Tx) Del(ctx context.Context, k flat.Key) error

func (*Tx) Get

func (tx *Tx) Get(ctx context.Context, key flat.Key) (flat.Value, error)

func (*Tx) GetBatch

func (tx *Tx) GetBatch(ctx context.Context, keys []flat.Key) ([]flat.Value, error)

func (*Tx) Put

func (tx *Tx) Put(ctx context.Context, k flat.Key, v flat.Value) error

func (*Tx) Scan

func (tx *Tx) Scan(ctx context.Context, opts ...flat.IteratorOption) flat.Iterator