cznicb

Documentation

Overview

Package cznicb provides an in-memory implementation of the KVStore interfaces using the cznic/b in-memory btree. Of note: this implementation does not have reader isolation.

Index

• Constants
• func StoreConstructor(config map[string]interface{}) (store.KVStore, error)
• type Batch
  • func (w *Batch) Close() error
  • func (w *Batch) Delete(k []byte)
  • func (w *Batch) Execute() (err error)
  • func (w *Batch) Merge(k []byte, oper store.AssociativeMerge)
  • func (w *Batch) Set(k, v []byte)
• type Iterator
  • func (w *Iterator) Close() error
  • func (w *Iterator) Current() ([]byte, []byte, bool)
  • func (w *Iterator) Key() []byte
  • func (w *Iterator) Next()
  • func (w *Iterator) Seek(k []byte)
  • func (w *Iterator) SeekFirst()
  • func (w *Iterator) Valid() bool
  • func (w *Iterator) Value() []byte
• type Store
  • func (s *Store) Close() error
  • func (s *Store) Delete(k []byte) (err error)
  • func (s *Store) Get(k []byte) ([]byte, error)
  • func (s *Store) Iterator(k []byte) store.KVIterator
  • func (s *Store) NewBatch() store.KVBatch
  • func (s *Store) Reader() (store.KVReader, error)
  • func (s *Store) Set(k, v []byte) (err error)
  • func (s *Store) Writer() (store.KVWriter, error)

Constants

const Name = "cznicb"

Functions

func StoreConstructor

func StoreConstructor(config map[string]interface{}) (
	store.KVStore, error)

Types

type Batch

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

func (*Batch) Close

func (w *Batch) Close() error

func (*Batch) Delete

func (w *Batch) Delete(k []byte)

func (*Batch) Execute

func (w *Batch) Execute() (err error)

func (*Batch) Merge

func (w *Batch) Merge(k []byte, oper store.AssociativeMerge)

func (*Batch) Set

func (w *Batch) Set(k, v []byte)

type Iterator

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

func (*Iterator) Close

func (w *Iterator) Close() error

func (*Iterator) Current

func (w *Iterator) Current() ([]byte, []byte, bool)

func (*Iterator) Key

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

func (*Iterator) Next

func (w *Iterator) Next()

func (*Iterator) Seek

func (w *Iterator) Seek(k []byte)

func (*Iterator) SeekFirst

func (w *Iterator) SeekFirst()

func (*Iterator) Valid

func (w *Iterator) Valid() bool

func (*Iterator) Value

func (w *Iterator) Value() []byte

type Store

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

func (*Store) Close

func (s *Store) Close() error

func (*Store) Delete

func (s *Store) Delete(k []byte) (err error)

func (*Store) Get

func (s *Store) Get(k []byte) ([]byte, error)

func (*Store) Iterator

func (s *Store) Iterator(k []byte) store.KVIterator

func (*Store) NewBatch

func (s *Store) NewBatch() store.KVBatch

func (*Store) Reader

func (s *Store) Reader() (store.KVReader, error)

func (*Store) Set

func (s *Store) Set(k, v []byte) (err error)

func (*Store) Writer

func (s *Store) Writer() (store.KVWriter, error)