buffered

Documentation

Index

• type BufferedKVStore
  • func NewBufferedKVStore(r kv.KVStoreReader) *BufferedKVStore
  • func NewBufferedKVStoreForMutations(r kv.KVStoreReader, m *Mutations) *BufferedKVStore
  • func (b *BufferedKVStore) Clone() *BufferedKVStore
  • func (b *BufferedKVStore) DangerouslyDumpToDict() dict.Dict
  • func (b *BufferedKVStore) DangerouslyDumpToString() string
  • func (b *BufferedKVStore) Del(key kv.Key)
  • func (b *BufferedKVStore) Get(key kv.Key) []byte
  • func (b *BufferedKVStore) Has(key kv.Key) bool
  • func (b *BufferedKVStore) Iterate(prefix kv.Key, f func(key kv.Key, value []byte) bool)
  • func (b *BufferedKVStore) IterateKeys(prefix kv.Key, f func(key kv.Key) bool)
  • func (b *BufferedKVStore) IterateKeysSorted(prefix kv.Key, f func(key kv.Key) bool)
  • func (b *BufferedKVStore) IterateSorted(prefix kv.Key, f func(key kv.Key, value []byte) bool)
  • func (b *BufferedKVStore) Mutations() *Mutations
  • func (b *BufferedKVStore) Set(key kv.Key, value []byte)
  • func (b *BufferedKVStore) SetMutations(muts *Mutations)
• type Mutations
  • func MutationsFromBytes(data []byte) (*Mutations, error)
  • func NewMutations() *Mutations
  • func (ms *Mutations) ApplyTo(w kv.KVWriter)
  • func (ms *Mutations) Bytes() []byte
  • func (ms *Mutations) Clone() *Mutations
  • func (ms *Mutations) Contains(k kv.Key) bool
  • func (ms *Mutations) Del(k kv.Key)
  • func (ms *Mutations) DelsSorted() []kv.Key
  • func (ms *Mutations) Dump() string
  • func (ms *Mutations) Get(k kv.Key) ([]byte, bool)
  • func (ms *Mutations) IsEmpty() bool
  • func (ms *Mutations) Read(r io.Reader) error
  • func (ms *Mutations) Set(k kv.Key, v []byte)
  • func (ms *Mutations) SetsSorted() kv.Items
  • func (ms *Mutations) Write(w io.Writer) error

Types

type BufferedKVStore

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

BufferedKVStore is a KVStore backed by a given KVStoreReader. Writes are cached in-memory; reads are delegated to the backing store for unmodified keys.

func NewBufferedKVStore

func NewBufferedKVStore(r kv.KVStoreReader) *BufferedKVStore

func NewBufferedKVStoreForMutations

func NewBufferedKVStoreForMutations(r kv.KVStoreReader, m *Mutations) *BufferedKVStore

func (*BufferedKVStore) Clone

func (b *BufferedKVStore) Clone() *BufferedKVStore

func (*BufferedKVStore) DangerouslyDumpToDict

func (b *BufferedKVStore) DangerouslyDumpToDict() dict.Dict

DangerouslyDumpToDict returns a Dict with the whole contents of the backing store + applied mutations.

func (*BufferedKVStore) DangerouslyDumpToString

func (b *BufferedKVStore) DangerouslyDumpToString() string

iterates over all key-value pairs in KVStore

func (*BufferedKVStore) Del

func (b *BufferedKVStore) Del(key kv.Key)

func (*BufferedKVStore) Get

func (b *BufferedKVStore) Get(key kv.Key) []byte

func (*BufferedKVStore) Has

func (b *BufferedKVStore) Has(key kv.Key) bool

func (*BufferedKVStore) Iterate

func (b *BufferedKVStore) Iterate(prefix kv.Key, f func(key kv.Key, value []byte) bool)

func (*BufferedKVStore) IterateKeys

func (b *BufferedKVStore) IterateKeys(prefix kv.Key, f func(key kv.Key) bool)

func (*BufferedKVStore) IterateKeysSorted

func (b *BufferedKVStore) IterateKeysSorted(prefix kv.Key, f func(key kv.Key) bool)

func (*BufferedKVStore) IterateSorted

func (b *BufferedKVStore) IterateSorted(prefix kv.Key, f func(key kv.Key, value []byte) bool)

func (*BufferedKVStore) Mutations

func (b *BufferedKVStore) Mutations() *Mutations

func (*BufferedKVStore) Set

func (b *BufferedKVStore) Set(key kv.Key, value []byte)

func (*BufferedKVStore) SetMutations

func (b *BufferedKVStore) SetMutations(muts *Mutations)

type Mutations

type Mutations struct {
	Sets map[kv.Key][]byte
	Dels map[kv.Key]struct{}
}

Mutations is a set of mutations: one for each key It provides a deterministic serialization

func MutationsFromBytes

func MutationsFromBytes(data []byte) (*Mutations, error)

func NewMutations

func NewMutations() *Mutations

func (*Mutations) ApplyTo

func (ms *Mutations) ApplyTo(w kv.KVWriter)

func (*Mutations) Bytes

func (ms *Mutations) Bytes() []byte

func (*Mutations) Clone

func (ms *Mutations) Clone() *Mutations

func (*Mutations) Contains

func (ms *Mutations) Contains(k kv.Key) bool

func (*Mutations) Del

func (ms *Mutations) Del(k kv.Key)

func (*Mutations) DelsSorted

func (ms *Mutations) DelsSorted() []kv.Key

func (*Mutations) Dump

func (ms *Mutations) Dump() string

func (*Mutations) Get

func (ms *Mutations) Get(k kv.Key) ([]byte, bool)

func (*Mutations) IsEmpty

func (ms *Mutations) IsEmpty() bool

func (*Mutations) Read

func (ms *Mutations) Read(r io.Reader) error

func (*Mutations) Set

func (ms *Mutations) Set(k kv.Key, v []byte)

func (*Mutations) SetsSorted

func (ms *Mutations) SetsSorted() kv.Items

func (*Mutations) Write

func (ms *Mutations) Write(w io.Writer) error