buffered

Documentation

Index

• type BufferedKVStoreAccess
  • func NewBufferedKVStoreAccess(r kv.KVStoreReader) *BufferedKVStoreAccess
  • func (b *BufferedKVStoreAccess) ClearMutations()
  • func (b *BufferedKVStoreAccess) Copy() *BufferedKVStoreAccess
  • func (b *BufferedKVStoreAccess) DangerouslyDumpToDict() dict.Dict
  • func (b *BufferedKVStoreAccess) DangerouslyDumpToString() string
  • func (b *BufferedKVStoreAccess) Del(key kv.Key)
  • func (b *BufferedKVStoreAccess) Get(key kv.Key) ([]byte, error)
  • func (b *BufferedKVStoreAccess) Has(key kv.Key) (bool, error)
  • func (b *BufferedKVStoreAccess) Iterate(prefix kv.Key, f func(key kv.Key, value []byte) bool) error
  • func (b *BufferedKVStoreAccess) IterateKeys(prefix kv.Key, f func(key kv.Key) bool) error
  • func (b *BufferedKVStoreAccess) IterateKeysSorted(prefix kv.Key, f func(key kv.Key) bool) error
  • func (b *BufferedKVStoreAccess) IterateSorted(prefix kv.Key, f func(key kv.Key, value []byte) bool) error
  • func (b *BufferedKVStoreAccess) MustGet(key kv.Key) []byte
  • func (b *BufferedKVStoreAccess) MustHas(key kv.Key) bool
  • func (b *BufferedKVStoreAccess) MustIterate(prefix kv.Key, f func(key kv.Key, value []byte) bool)
  • func (b *BufferedKVStoreAccess) MustIterateKeys(prefix kv.Key, f func(key kv.Key) bool)
  • func (b *BufferedKVStoreAccess) MustIterateKeysSorted(prefix kv.Key, f func(key kv.Key) bool)
  • func (b *BufferedKVStoreAccess) MustIterateSorted(prefix kv.Key, f func(key kv.Key, value []byte) bool)
  • func (b *BufferedKVStoreAccess) Mutations() *Mutations
  • func (b *BufferedKVStoreAccess) Set(key kv.Key, value []byte)
• type Mutations
  • func NewMutations() *Mutations
  • func (ms *Mutations) Apply(kvw kv.KVWriter)
  • 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) IsModified() bool
  • func (ms *Mutations) Read(r io.Reader) error
  • func (ms *Mutations) ResetModified()
  • 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 BufferedKVStoreAccess

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

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

func NewBufferedKVStoreAccess

func NewBufferedKVStoreAccess(r kv.KVStoreReader) *BufferedKVStoreAccess

func (*BufferedKVStoreAccess) ClearMutations

func (b *BufferedKVStoreAccess) ClearMutations()

func (*BufferedKVStoreAccess) Copy

func (b *BufferedKVStoreAccess) Copy() *BufferedKVStoreAccess

func (*BufferedKVStoreAccess) DangerouslyDumpToDict

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

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

func (*BufferedKVStoreAccess) DangerouslyDumpToString

func (b *BufferedKVStoreAccess) DangerouslyDumpToString() string

iterates over all key-value pairs in KVStore

func (*BufferedKVStoreAccess) Del

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

func (*BufferedKVStoreAccess) Get

func (b *BufferedKVStoreAccess) Get(key kv.Key) ([]byte, error)

func (*BufferedKVStoreAccess) Has

func (b *BufferedKVStoreAccess) Has(key kv.Key) (bool, error)

func (*BufferedKVStoreAccess) Iterate

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

func (*BufferedKVStoreAccess) IterateKeys

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

func (*BufferedKVStoreAccess) IterateKeysSorted

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

func (*BufferedKVStoreAccess) IterateSorted

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

func (*BufferedKVStoreAccess) MustGet

func (b *BufferedKVStoreAccess) MustGet(key kv.Key) []byte

func (*BufferedKVStoreAccess) MustHas

func (b *BufferedKVStoreAccess) MustHas(key kv.Key) bool

func (*BufferedKVStoreAccess) MustIterate

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

func (*BufferedKVStoreAccess) MustIterateKeys

func (b *BufferedKVStoreAccess) MustIterateKeys(prefix kv.Key, f func(key kv.Key) bool)

func (*BufferedKVStoreAccess) MustIterateKeysSorted

func (b *BufferedKVStoreAccess) MustIterateKeysSorted(prefix kv.Key, f func(key kv.Key) bool)

func (*BufferedKVStoreAccess) MustIterateSorted

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

func (*BufferedKVStoreAccess) Mutations

func (b *BufferedKVStoreAccess) Mutations() *Mutations

func (*BufferedKVStoreAccess) Set

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

type Mutations

type Mutations struct {
	Sets map[kv.Key][]byte
	Dels map[kv.Key]struct{}
	// contains filtered or unexported fields
}

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

func NewMutations

func NewMutations() *Mutations

func (*Mutations) Apply

func (ms *Mutations) Apply(kvw kv.KVWriter)

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

func (ms *Mutations) IsModified() bool

func (*Mutations) Read

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

func (*Mutations) ResetModified

func (ms *Mutations) ResetModified()

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