Versions in this module Expand all Collapse all v1 v1.999.0 Nov 17, 2022 Changes in this version + func NewFullHistoryTriePruningStorer(args *FullHistoryStorerArgs) (*fullHistoryTriePruningStorer, error) + func NewTriePruningStorer(args *StorerArgs) (*triePruningStorer, error) + type DbFactoryHandler interface + Create func(filePath string) (storage.Persister, error) + CreateDisabled func() storage.Persister + IsInterfaceNil func() bool + type EpochStartNotifier interface + IsInterfaceNil func() bool + RegisterHandler func(handler epochStart.ActionHandler) + type FullHistoryPruningStorer struct + func NewFullHistoryPruningStorer(args *FullHistoryStorerArgs) (*FullHistoryPruningStorer, error) + func NewShardedFullHistoryPruningStorer(args *FullHistoryStorerArgs, shardID uint32) (*FullHistoryPruningStorer, error) + func (fhps *FullHistoryPruningStorer) Close() error + func (fhps *FullHistoryPruningStorer) GetBulkFromEpoch(keys [][]byte, epoch uint32) ([]storageCore.KeyValuePair, error) + func (fhps *FullHistoryPruningStorer) GetFromEpoch(key []byte, epoch uint32) ([]byte, error) + func (fhps *FullHistoryPruningStorer) PutInEpoch(key []byte, data []byte, epoch uint32) error + type FullHistoryStorerArgs struct + NumOfOldActivePersisters uint32 + type PruningStorer struct + func NewPruningStorer(args *StorerArgs) (*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) GetBulkFromEpoch(keys [][]byte, epoch uint32) ([]storageCore.KeyValuePair, error) + func (ps *PruningStorer) GetFromEpoch(key []byte, epoch uint32) ([]byte, error) + func (ps *PruningStorer) GetOldestEpoch() (uint32, error) + func (ps *PruningStorer) Has(key []byte) error + func (ps *PruningStorer) IsInterfaceNil() bool + func (ps *PruningStorer) Put(key, data []byte) error + func (ps *PruningStorer) PutInEpoch(key, data []byte, epoch uint32) error + func (ps *PruningStorer) RangeKeys(_ func(key []byte, val []byte) bool) + func (ps *PruningStorer) Remove(key []byte) error + func (ps *PruningStorer) RemoveFromCurrentEpoch(key []byte) error + func (ps *PruningStorer) SearchFirst(key []byte) ([]byte, error) + func (ps *PruningStorer) SetEpochForPutOperation(epoch uint32) + type StorerArgs struct + CacheConf storageUnit.CacheConfig + CustomDatabaseRemover storage.CustomDatabaseRemoverHandler + DbPath string + EnabledDbLookupExtensions bool + Identifier string + MaxBatchSize int + Notifier EpochStartNotifier + NumOfActivePersisters uint32 + NumOfEpochsToKeep uint32 + OldDataCleanerProvider clean.OldDataCleanerProvider + PathManager storage.PathManagerHandler + PersisterFactory DbFactoryHandler + PruningEnabled bool + ShardCoordinator storage.ShardCoordinator + StartingEpoch uint32