freeq

Documentation

Index

• Constants
• Variables
• func GetDefault(ctx context.Context, kind, ns string) (store kv.KVStore, err error)
• func New(mo kv.MergeOperator, logger gae.LogInt, dbi gae.DbExInt, namespace []byte) (kv.KVStore, error)
• type Batch
  • func (this *Batch) Close() error
  • func (this *Batch) Delete(key []byte)
  • func (this *Batch) Merge(key, val []byte)
  • func (this *Batch) Reset()
  • func (this *Batch) Set(key, val []byte)
• type Iterator
  • func (this *Iterator) Close() error
  • func (this *Iterator) Count() (n int)
  • func (this *Iterator) Current() ([]byte, []byte, bool)
  • func (this Iterator) Error() error
  • func (this *Iterator) Key() []byte
  • func (this *Iterator) Next()
  • func (this *Iterator) Reset()
  • func (this *Iterator) Reset0()
  • func (this *Iterator) Seek(key []byte)
  • func (this *Iterator) Valid() bool
  • func (this *Iterator) Value() []byte
• type Reader
  • func (this *Reader) Close() error
  • func (this *Reader) Get(key []byte) (v []byte, err error)
  • func (this *Reader) MultiGet(keys [][]byte) (vv [][]byte, err error)
  • func (this *Reader) PrefixIterator(prefix []byte) (pt kv.KVIterator)
  • func (this *Reader) PrefixIterator0(prefix []byte) (pt kv.KVIterator)
  • func (this *Reader) RangeIterator(start, end []byte) (rt kv.KVIterator)
  • func (this *Reader) RangeIterator0(start, end []byte) (rt kv.KVIterator)
  • func (this *Reader) ReversePrefixIterator(prefix []byte) (t kv.KVIterator)
  • func (this *Reader) ReverseRangeIterator(start, end []byte) (t kv.KVIterator)
• type Store
  • func (this *Store) Close() error
  • func (this *Store) Reader() (kv.KVReader, error)
  • func (this *Store) Writer() (kv.KVWriter, error)
• type Writer
  • func (this *Writer) Close() error
  • func (this *Writer) ExecuteBatch(batch kv.KVBatch) (err error)
  • func (this *Writer) NewBatch() kv.KVBatch
  • func (this *Writer) NewBatchEx(options kv.KVBatchOptions) ([]byte, kv.KVBatch, error)

Constants

const C_Klimit = 500

const C_Kmetasize = 4

const C_Kmincompress = 120

const C_Kreserved = 16

const C_Ksepbyte = 0x7f

Variables

var C_Kterminator = []byte{0x7f, 0x7f}

var C_Vlimit = (1024 << 10) // 1MB

var ErrInvalidValue = errors.New("invalid size for value.")

Functions

func GetDefault

func GetDefault(ctx context.Context, kind, ns string) (store kv.KVStore, err error)

func New

func New(mo kv.MergeOperator, logger gae.LogInt, dbi gae.DbExInt, namespace []byte) (kv.KVStore, error)

Types

type Batch

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

func (*Batch) Close

func (this *Batch) Close() error

func (*Batch) Delete

func (this *Batch) Delete(key []byte)

func (*Batch) Merge

func (this *Batch) Merge(key, val []byte)

func (*Batch) Reset

func (this *Batch) Reset()

func (*Batch) Set

func (this *Batch) Set(key, val []byte)

type Iterator

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

func (*Iterator) Close

func (this *Iterator) Close() error

func (*Iterator) Count

func (this *Iterator) Count() (n int)

func (*Iterator) Current

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

func (Iterator) Error

func (this Iterator) Error() error

func (*Iterator) Key

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

func (*Iterator) Next

func (this *Iterator) Next()

func (*Iterator) Reset

func (this *Iterator) Reset()

func (*Iterator) Reset0

func (this *Iterator) Reset0()

func (*Iterator) Seek

func (this *Iterator) Seek(key []byte)

func (*Iterator) Valid

func (this *Iterator) Valid() bool

func (*Iterator) Value

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

type Reader

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

func (*Reader) Close

func (this *Reader) Close() error

func (*Reader) Get

func (this *Reader) Get(key []byte) (v []byte, err error)

func (*Reader) MultiGet

func (this *Reader) MultiGet(keys [][]byte) (vv [][]byte, err error)

func (*Reader) PrefixIterator

func (this *Reader) PrefixIterator(prefix []byte) (pt kv.KVIterator)

func (*Reader) PrefixIterator0

func (this *Reader) PrefixIterator0(prefix []byte) (pt kv.KVIterator)

func (*Reader) RangeIterator

func (this *Reader) RangeIterator(start, end []byte) (rt kv.KVIterator)

func (*Reader) RangeIterator0

func (this *Reader) RangeIterator0(start, end []byte) (rt kv.KVIterator)

func (*Reader) ReversePrefixIterator

func (this *Reader) ReversePrefixIterator(prefix []byte) (t kv.KVIterator)

func (*Reader) ReverseRangeIterator

func (this *Reader) ReverseRangeIterator(start, end []byte) (t kv.KVIterator)

type Store

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

func (*Store) Close

func (this *Store) Close() error

func (*Store) Reader

func (this *Store) Reader() (kv.KVReader, error)

func (*Store) Writer

func (this *Store) Writer() (kv.KVWriter, error)

type Writer

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

func (*Writer) Close

func (this *Writer) Close() error

func (*Writer) ExecuteBatch

func (this *Writer) ExecuteBatch(batch kv.KVBatch) (err error)

func (*Writer) NewBatch

func (this *Writer) NewBatch() kv.KVBatch

func (*Writer) NewBatchEx

func (this *Writer) NewBatchEx(options kv.KVBatchOptions) ([]byte, kv.KVBatch, error)