Versions in this module Expand all Collapse all v0 v0.0.2 Oct 31, 2023 Changes in this version type PruningStorer + func (ps *PruningStorer) GetBulkFromEpoch(keys [][]byte, epoch uint32) (map[string][]byte, error) + func (ps *PruningStorer) RangeKeys(_ func(key []byte, val []byte) bool) v0.0.1 Oct 30, 2023 Changes in this version + type DbFactoryHandler interface + Create func(filePath string) (storage.Persister, error) + IsInterfaceNil func() bool + type EpochStartNotifier interface + IsInterfaceNil func() bool + RegisterHandler func(handler epochStart.ActionHandler) + UnregisterHandler func(handler epochStart.ActionHandler) + type PruningStorer struct + func NewPruningStorer(args *StorerArgs) (*PruningStorer, error) + func NewShardedPruningStorer(args *StorerArgs, shardID uint32) (*PruningStorer, error) + func (ps *PruningStorer) ClearCache() + func (ps *PruningStorer) Close() error + func (ps *PruningStorer) DestroyUnit() error + func (ps *PruningStorer) Get(key []byte) ([]byte, error) + func (ps *PruningStorer) GetFromEpoch(key []byte, epoch uint32) ([]byte, error) + func (ps *PruningStorer) Has(key []byte) error + func (ps *PruningStorer) HasInEpoch(key []byte, epoch uint32) error + func (ps *PruningStorer) IsInterfaceNil() bool + func (ps *PruningStorer) Put(key, data []byte) error + func (ps *PruningStorer) Remove(key []byte) error + func (ps *PruningStorer) SearchFirst(key []byte) ([]byte, error) + func (ps *PruningStorer) SetEpochForPutOperation(epoch uint32) + type StorerArgs struct + BloomFilterConf storageUnit.BloomConfig + CacheConf storageUnit.CacheConfig + CleanOldEpochsData bool + DbPath string + Identifier string + MaxBatchSize int + Notifier EpochStartNotifier + NumOfActivePersisters uint32 + NumOfEpochsToKeep uint32 + PathManager storage.PathManagerHandler + PersisterFactory DbFactoryHandler + PruningEnabled bool + ShardCoordinator storage.ShardCoordinator + StartingEpoch uint32