cachekv

Documentation

Index

• type PreChangesHandler
• type Store
  • func NewStore(parent types.KVStore) *Store
  • func NewStoreWithPreChangeHandler(parent types.KVStore, preChangesHandler PreChangesHandler) *Store
  • func (store *Store) CacheWrap() types.CacheWrap
  • func (store *Store) CacheWrapWithTrace(w io.Writer, tc types.TraceContext) types.CacheWrap
  • func (store *Store) Clear()
  • func (store *Store) CopyRWSet(rw types.CacheKVRWSet)
  • func (store *Store) Delete(key []byte)
  • func (store *Store) DisableCacheReadList()
  • func (store *Store) EndTiming(tag string)
  • func (store *Store) Get(key []byte) (value []byte)
  • func (store *Store) GetRWSet(mp types.MsRWSet)
  • func (store *Store) GetStoreType() types.StoreType
  • func (store *Store) Has(key []byte) bool
  • func (store *Store) Iterator(start, end []byte) types.Iterator
  • func (store *Store) IteratorCache(isdirty bool, ...) bool
  • func (store *Store) Reset(parent types.KVStore)
  • func (store *Store) ReverseIterator(start, end []byte) types.Iterator
  • func (store *Store) RevertDBWithSnapshotRWSet(set types.SnapshotWSet)
  • func (store *Store) Set(key []byte, value []byte)
  • func (store *Store) StartTiming()
  • func (store *Store) Write()
  • func (store *Store) WriteWithSnapshotWSet() types.SnapshotWSet

Types

type PreChangesHandler

type PreChangesHandler func(keys []string, setOrDel []byte)

type Store

type Store struct {
	trace.StatisticsCell
	// contains filtered or unexported fields
}

Store wraps an in-memory cache around an underlying types.KVStore.

func NewStore

func NewStore(parent types.KVStore) *Store

func NewStoreWithPreChangeHandler

func NewStoreWithPreChangeHandler(parent types.KVStore, preChangesHandler PreChangesHandler) *Store

func (*Store) CacheWrap

func (store *Store) CacheWrap() types.CacheWrap

Implements CacheWrapper.

func (*Store) CacheWrapWithTrace

func (store *Store) CacheWrapWithTrace(w io.Writer, tc types.TraceContext) types.CacheWrap

CacheWrapWithTrace implements the CacheWrapper interface.

func (*Store) Clear

func (store *Store) Clear()

Clear will clear all internal data without writing to the parent.

func (*Store) CopyRWSet

func (store *Store) CopyRWSet(rw types.CacheKVRWSet)

func (*Store) Delete

func (store *Store) Delete(key []byte)

Implements types.KVStore.

func (*Store) DisableCacheReadList

func (store *Store) DisableCacheReadList()

func (*Store) EndTiming

func (store *Store) EndTiming(tag string)

func (*Store) Get

func (store *Store) Get(key []byte) (value []byte)

Implements types.KVStore.

func (*Store) GetRWSet

func (store *Store) GetRWSet(mp types.MsRWSet)

func (*Store) GetStoreType

func (store *Store) GetStoreType() types.StoreType

Implements Store.

func (*Store) Has

func (store *Store) Has(key []byte) bool

Implements types.KVStore.

func (*Store) Iterator

func (store *Store) Iterator(start, end []byte) types.Iterator

Implements types.KVStore.

func (*Store) IteratorCache

func (store *Store) IteratorCache(isdirty bool, cb func(key string, value []byte, isDirty bool, isDelete bool, sKey types.StoreKey) bool, sKey types.StoreKey) bool

func (*Store) Reset

func (store *Store) Reset(parent types.KVStore)

Reset will clear all internal data without writing to the parent and set the new parent.

func (*Store) ReverseIterator

func (store *Store) ReverseIterator(start, end []byte) types.Iterator

Implements types.KVStore.

func (*Store) RevertDBWithSnapshotRWSet

func (store *Store) RevertDBWithSnapshotRWSet(set types.SnapshotWSet)

Implements Cachetypes.KVStore.

func (*Store) Set

func (store *Store) Set(key []byte, value []byte)

Implements types.KVStore.

func (*Store) StartTiming

func (store *Store) StartTiming()

func (*Store) Write

func (store *Store) Write()

Implements Cachetypes.KVStore.

func (*Store) WriteWithSnapshotWSet

func (store *Store) WriteWithSnapshotWSet() types.SnapshotWSet

Implements Cachetypes.KVStore.