Documentation

Overview

    Package gtreap provides an in-memory implementation of the KVStore interfaces using the gtreap balanced-binary treap, copy-on-write data structure.

    Package gtreap provides an in-memory implementation of the KVStore interfaces using the gtreap balanced-binary treap, copy-on-write data structure.

    Package gtreap provides an in-memory implementation of the KVStore interfaces using the gtreap balanced-binary treap, copy-on-write data structure.

    Index

    Constants

    View Source
    const Name = "gtreap"

    Variables

    This section is empty.

    Functions

    func New

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

    Types

    type Item

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

    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) Valid

    func (w *Iterator) Valid() bool

    func (*Iterator) Value

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

    type Reader

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

    func (*Reader) Close

    func (w *Reader) Close() error

    func (*Reader) Get

    func (w *Reader) Get(k []byte) (v []byte, err error)

    func (*Reader) MultiGet

    func (r *Reader) MultiGet(keys [][]byte) ([][]byte, error)

    func (*Reader) PrefixIterator

    func (w *Reader) PrefixIterator(k []byte) store.KVIterator

    func (*Reader) RangeIterator

    func (w *Reader) RangeIterator(start, end []byte) store.KVIterator

    type Store

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

    func (*Store) Close

    func (s *Store) Close() error

    func (*Store) Reader

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

    func (*Store) Writer

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

    type Writer

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

    func (*Writer) Close

    func (w *Writer) Close() error

    func (*Writer) ExecuteBatch

    func (w *Writer) ExecuteBatch(batch store.KVBatch) error

    func (*Writer) NewBatch

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

    func (*Writer) NewBatchEx

    func (w *Writer) NewBatchEx(options store.KVBatchOptions) ([]byte, store.KVBatch, error)