boltdb

Documentation

Index

• Variables
• type KV
  • func New(db *bolt.DB) *KV
  • func (kv KV) Close() error
  • func (kv KV) Update(fn func(kv.Update) error) error
  • func (kv KV) View(fn func(kv.View) error) error
• type KeyspaceUpdate
  • func (u KeyspaceUpdate) Delete(_ context.Context, k []byte) error
  • func (u KeyspaceUpdate) Get(ctx context.Context, opts kv.GetOptions) ([]kv.Item, error)
  • func (u KeyspaceUpdate) Put(_ context.Context, k, v []byte) error
  • func (u KeyspaceUpdate) Range(ctx context.Context, opts ...kv.RangeOption) ([]kv.Item, error)
• type KeyspaceView
  • func (k KeyspaceView) Get(_ context.Context, opts kv.GetOptions) (items []kv.Item, err error)
  • func (k KeyspaceView) Range(_ context.Context, opts ...kv.RangeOption) (items []kv.Item, err error)
• type Update
  • func (u Update) CreateKeyspace(key []byte) error
  • func (u Update) Keyspace(key []byte) (_ kv.KeyspaceUpdate, err error)
• type View
  • func (v View) Keyspace(key []byte) (_ kv.KeyspaceView, err error)

Variables

var (
	ErrBucketNotExist = errors.New("bucket not exist")
)

Types

type KV

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

func New

func New(db *bolt.DB) *KV

func (KV) Close

func (kv KV) Close() error

func (KV) Update

func (kv KV) Update(fn func(kv.Update) error) error

func (KV) View

func (kv KV) View(fn func(kv.View) error) error

type KeyspaceUpdate

type KeyspaceUpdate KeyspaceView

func (KeyspaceUpdate) Delete

func (u KeyspaceUpdate) Delete(_ context.Context, k []byte) error

func (KeyspaceUpdate) Get

func (u KeyspaceUpdate) Get(ctx context.Context, opts kv.GetOptions) ([]kv.Item, error)

func (KeyspaceUpdate) Put

func (u KeyspaceUpdate) Put(_ context.Context, k, v []byte) error

func (KeyspaceUpdate) Range

func (u KeyspaceUpdate) Range(ctx context.Context, opts ...kv.RangeOption) ([]kv.Item, error)

type KeyspaceView

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

func (KeyspaceView) Get

func (k KeyspaceView) Get(_ context.Context, opts kv.GetOptions) (items []kv.Item, err error)

func (KeyspaceView) Range

func (k KeyspaceView) Range(_ context.Context, opts ...kv.RangeOption) (items []kv.Item, err error)

type Update

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

func (Update) CreateKeyspace

func (u Update) CreateKeyspace(key []byte) error

func (Update) Keyspace

func (u Update) Keyspace(key []byte) (_ kv.KeyspaceUpdate, err error)

type View

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

func (View) Keyspace

func (v View) Keyspace(key []byte) (_ kv.KeyspaceView, err error)