Versions in this module Expand all Collapse all v0 v0.0.1 Oct 26, 2023 Changes in this version + type AdaptedSizedLRUCache interface + AddSizedAndReturnEvicted func(key, value interface{}, sizeInBytes int64) map[interface{}]interface{} + IsInterfaceNil func() bool + type Batcher interface + Delete func(key []byte) error + Get func(key []byte) []byte + IsInterfaceNil func() bool + IsRemoved func(key []byte) bool + Put func(key []byte, val []byte) error + Reset func() + type Cacher interface + Clear func() + Close func() error + Get func(key []byte) (value interface{}, ok bool) + Has func(key []byte) bool + HasOrAdd func(key []byte, value interface{}, sizeInBytes int) (has, added bool) + IsInterfaceNil func() bool + Keys func() [][]byte + Len func() int + MaxSize func() int + Peek func(key []byte) (value interface{}, ok bool) + Put func(key []byte, value interface{}, sizeInBytes int) (evicted bool) + RegisterHandler func(handler func(key []byte, value interface{}), id string) + Remove func(key []byte) + SizeInBytesContained func() uint64 + UnRegisterHandler func(id string) + type CustomDatabaseRemoverHandler interface + IsInterfaceNil func() bool + ShouldRemove func(dbIdentifier string, epoch uint32) bool + type DirectoryReaderHandler interface + IsInterfaceNil func() bool + ListAllAsString func(directoryPath string) ([]string, error) + ListDirectoriesAsString func(directoryPath string) ([]string, error) + ListFilesAsString func(directoryPath string) ([]string, error) + type EvictionHandler interface + Evicted func(key []byte) + type ForEachItem func(key []byte, value interface{}) + type LRUCacheHandler interface + Add func(key, value interface{}) bool + Contains func(key interface{}) (ok bool) + ContainsOrAdd func(key, value interface{}) (ok, evicted bool) + Get func(key interface{}) (value interface{}, ok bool) + Keys func() []interface{} + Len func() int + Peek func(key interface{}) (value interface{}, ok bool) + Purge func() + Remove func(key interface{}) bool + type LatestDataFromStorage struct + Epoch uint32 + EpochStartRound uint64 + LastRound int64 + ShardID uint32 + type LatestStorageDataProviderHandler interface + Get func() (LatestDataFromStorage, error) + GetParentDirAndLastEpoch func() (string, uint32, error) + GetParentDirectory func() string + GetShardsFromDirectory func(path string) ([]string, error) + IsInterfaceNil func() bool + type Persister interface + Close func() error + Destroy func() error + DestroyClosed func() error + Get func(key []byte) ([]byte, error) + Has func(key []byte) error + IsInterfaceNil func() bool + Put func(key, val []byte) error + RangeKeys func(handler func(key []byte, val []byte) bool) + Remove func(key []byte) error + type PersisterFactory interface + Create func(path string) (Persister, error) + IsInterfaceNil func() bool + type SerializedStoredData interface + GetSerialized func() []byte + SetSerialized func([]byte) + type ShardCoordinator interface + CommunicationIdentifier func(destShardID uint32) string + ComputeId func(address []byte) uint32 + IsInterfaceNil func() bool + NumberOfShards func() uint32 + SameShard func(firstAddress, secondAddress []byte) bool + SelfId func() uint32 + type SizedLRUCacheHandler interface + AddSized func(key, value interface{}, sizeInBytes int64) bool + AddSizedIfMissing func(key, value interface{}, sizeInBytes int64) (ok, evicted bool) + Contains func(key interface{}) (ok bool) + Get func(key interface{}) (value interface{}, ok bool) + Keys func() []interface{} + Len func() int + Peek func(key interface{}) (value interface{}, ok bool) + Purge func() + Remove func(key interface{}) bool + SizeInBytesContained func() uint64 + type StoredDataFactory interface + CreateEmpty func() interface{} + IsInterfaceNil func() bool + type Storer interface + ClearCache func() + Close func() error + DestroyUnit func() error + Get func(key []byte) ([]byte, error) + GetBulkFromEpoch func(keys [][]byte, epoch uint32) ([]storage.KeyValuePair, error) + GetFromEpoch func(key []byte, epoch uint32) ([]byte, error) + GetOldestEpoch func() (uint32, error) + Has func(key []byte) error + IsInterfaceNil func() bool + Put func(key, data []byte) error + PutInEpoch func(key, data []byte, epoch uint32) error + RangeKeys func(handler func(key []byte, val []byte) bool) + Remove func(key []byte) error + RemoveFromCurrentEpoch func(key []byte) error + SearchFirst func(key []byte) ([]byte, error) + type StorerWithPutInEpoch interface + SetEpochForPutOperation func(epoch uint32) + type TimeCacher interface + Add func(key string) error + Has func(key string) bool + IsInterfaceNil func() bool + Sweep func() + Upsert func(key string, span time.Duration) error