bbolt

Documentation

Index

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

Constants

const (
	Name = "bbolt"
)

Functions

func OpenPath

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

Types

type DB

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

func New

func New(d *bolt.DB) *DB

func Open

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

func (*DB) Close

func (db *DB) Close() error

func (*DB) DB

func (db *DB) DB() *bolt.DB

func (*DB) Tx

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

func (*DB) Update

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

func (*DB) View

func (db *DB) View(ctx context.Context, fn func(tx kv.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() kv.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 kv.Key) bool

func (*Iterator) Val

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

func (*Iterator) WithPrefix

func (it *Iterator) WithPrefix(pref kv.Key) kv.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 kv.Key) error

func (*Tx) Get

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

func (*Tx) GetBatch

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

func (*Tx) Put

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

func (*Tx) Scan

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