natskv

Documentation

Index

• Constants
• func New(mo store.MergeOperator, config map[string]interface{}) (store.KVStore, error)
• type EncondedKey
• type Iterator
  • func (it *Iterator) Close() error
  • func (it *Iterator) Current() ([]byte, []byte, bool)
  • func (it *Iterator) Key() []byte
  • func (it *Iterator) Next()
  • func (it *Iterator) Seek(key []byte)
  • func (it *Iterator) Valid() bool
  • func (it *Iterator) Value() []byte
• type KV
  • func (kv *KV) Delete(key string, opts ...nats.DeleteOpt) error
  • func (kv *KV) Get(key []byte) (nats.KeyValueEntry, error)
  • func (kv_ *KV) ListKeys(opts ...nats.WatchOpt) (*keyLister, error)
  • func (kv *KV) Put(key string, value []byte) (revision uint64, err error)
• type RangeIterator
  • func (it *RangeIterator) Close() error
  • func (it *RangeIterator) Current() ([]byte, []byte, bool)
  • func (it *RangeIterator) Key() []byte
  • func (it *RangeIterator) Next()
  • func (it *RangeIterator) Seek(key []byte)
  • func (it *RangeIterator) Valid() bool
  • func (it *RangeIterator) Value() []byte
• type Reader
  • func (r *Reader) Close() error
  • func (r *Reader) Get(key []byte) ([]byte, error)
  • func (r *Reader) MultiGet(keys [][]byte) ([][]byte, error)
  • func (r *Reader) PrefixIterator(prefix []byte) store.KVIterator
  • func (r *Reader) RangeIterator(start, end []byte) store.KVIterator
• type Store
  • func (s *Store) Close() error
  • func (s *Store) Reader() (store.KVReader, error)
  • func (s *Store) Writer() (store.KVWriter, error)
• type Writer
  • func (w *Writer) Close() error
  • func (w *Writer) ExecuteBatch(batch store.KVBatch) error
  • func (w *Writer) NewBatch() store.KVBatch
  • func (w *Writer) NewBatchEx(options store.KVBatchOptions) ([]byte, store.KVBatch, error)

Constants

const (
	Name = "natskv"
)

Functions

func New

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

Types

type EncondedKey

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

type Iterator

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

func (*Iterator) Close

func (it *Iterator) Close() error

func (*Iterator) Current

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

func (*Iterator) Key

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

func (*Iterator) Next

func (it *Iterator) Next()

func (*Iterator) Seek

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

Seek will advance the iterator to the specified key

func (*Iterator) Valid

func (it *Iterator) Valid() bool

func (*Iterator) Value

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

type KV

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

func (*KV) Delete

func (kv *KV) Delete(key string, opts ...nats.DeleteOpt) error

func (*KV) Get

func (kv *KV) Get(key []byte) (nats.KeyValueEntry, error)

func (*KV) ListKeys

func (kv_ *KV) ListKeys(opts ...nats.WatchOpt) (*keyLister, error)

func (*KV) Put

func (kv *KV) Put(key string, value []byte) (revision uint64, err error)

type RangeIterator

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

func (*RangeIterator) Close

func (it *RangeIterator) Close() error

func (*RangeIterator) Current

func (it *RangeIterator) Current() ([]byte, []byte, bool)

func (*RangeIterator) Key

func (it *RangeIterator) Key() []byte

func (*RangeIterator) Next

func (it *RangeIterator) Next()

func (*RangeIterator) Seek

func (it *RangeIterator) Seek(key []byte)

Seek will advance the iterator to the specified key

func (*RangeIterator) Valid

func (it *RangeIterator) Valid() bool

func (*RangeIterator) Value

func (it *RangeIterator) Value() []byte

type Reader

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

func (*Reader) Close

func (r *Reader) Close() error

func (*Reader) Get

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

func (*Reader) MultiGet

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

func (*Reader) PrefixIterator

func (r *Reader) PrefixIterator(prefix []byte) store.KVIterator

func (*Reader) RangeIterator

func (r *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)