gtreap

package
v0.0.0-...-7be7ecd Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 8, 2015 License: Apache-2.0 Imports: 7 Imported by: 0

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.

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 MAX_CONCURRENT_WRITERS = 1
View Source
const Name = "gtreap"

Variables

This section is empty.

Functions

func StoreConstructor

func StoreConstructor(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) SeekFirst

func (w *Iterator) SeekFirst()

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

func (w *Reader) BytesSafeAfterClose() bool

func (*Reader) Close

func (w *Reader) Close() error

func (*Reader) Get

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

func (*Reader) Iterator

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

type Store

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

func (*Store) Close

func (s *Store) Close() error

func (*Store) Open

func (s *Store) Open() error

func (*Store) Reader

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

func (*Store) SetMergeOperator

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

func (*Store) Writer

func (s *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(k []byte) (err error)

func (*Writer) Get

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

func (*Writer) Iterator

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

func (*Writer) NewBatch

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

func (*Writer) Set

func (w *Writer) Set(k, v []byte) (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL