inmem

Documentation

Index

• Constants
• func StoreConstructor(config map[string]interface{}) (store.KVStore, error)
• type Iterator
  • func (i *Iterator) Close() error
  • func (i *Iterator) Current() ([]byte, []byte, bool)
  • func (i *Iterator) Key() []byte
  • func (i *Iterator) Next()
  • func (i *Iterator) Seek(k []byte)
  • func (i *Iterator) SeekFirst()
  • func (i *Iterator) Valid() bool
  • func (i *Iterator) Value() []byte
• type Reader
  • func (r *Reader) BytesSafeAfterClose() bool
  • func (r *Reader) Close() error
  • func (r *Reader) Get(key []byte) ([]byte, error)
  • func (r *Reader) Iterator(key []byte) store.KVIterator
• type Store
  • func MustOpen() *Store
  • func New() (*Store, error)
  • func (i *Store) Close() error
  • func (i *Store) Open() error
  • func (i *Store) Reader() (store.KVReader, error)
  • func (i *Store) SetMergeOperator(mo store.MergeOperator)
  • func (i *Store) Writer() (store.KVWriter, error)
• type Writer
  • func (w *Writer) BytesSafeAfterClose() bool
  • func (w *Writer) Close() error
  • func (w *Writer) Delete(key []byte) error
  • func (w *Writer) Get(key []byte) ([]byte, error)
  • func (w *Writer) Iterator(key []byte) store.KVIterator
  • func (w *Writer) NewBatch() store.KVBatch
  • func (w *Writer) Set(key, val []byte) error

Constants

const Name = "mem"

Functions

func StoreConstructor

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

Types

type Iterator

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

func (*Iterator) Close

func (i *Iterator) Close() error

func (*Iterator) Current

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

func (*Iterator) Key

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

func (*Iterator) Next

func (i *Iterator) Next()

func (*Iterator) Seek

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

func (*Iterator) SeekFirst

func (i *Iterator) SeekFirst()

func (*Iterator) Valid

func (i *Iterator) Valid() bool

func (*Iterator) Value

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

type Reader

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

func (*Reader) BytesSafeAfterClose

func (r *Reader) BytesSafeAfterClose() bool

func (*Reader) Close

func (r *Reader) Close() error

func (*Reader) Get

func (r *Reader) Get(key []byte) ([]byte, error)

func (*Reader) Iterator

func (r *Reader) Iterator(key []byte) store.KVIterator

type Store

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

func MustOpen

func MustOpen() *Store

func New

func New() (*Store, error)

func (*Store) Close

func (i *Store) Close() error

func (*Store) Open

func (i *Store) Open() error

func (*Store) Reader

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

func (*Store) SetMergeOperator

func (i *Store) SetMergeOperator(mo store.MergeOperator)

func (*Store) Writer

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

type Writer

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

func (*Writer) BytesSafeAfterClose

func (w *Writer) BytesSafeAfterClose() bool

func (*Writer) Close

func (w *Writer) Close() error

func (*Writer) Delete

func (w *Writer) Delete(key []byte) error

func (*Writer) Get

func (w *Writer) Get(key []byte) ([]byte, error)

these two methods can safely read using the regular methods without a read transaction, because we know that no one else is writing but us

func (*Writer) Iterator

func (w *Writer) Iterator(key []byte) store.KVIterator

func (*Writer) NewBatch

func (w *Writer) NewBatch() store.KVBatch

func (*Writer) Set

func (w *Writer) Set(key, val []byte) error