Versions in this module Expand all Collapse all v0 v0.0.1 Nov 7, 2024 Changes in this version + func NewFullHistoryTriePruningStorer(args FullHistoryStorerArgs) (*fullHistoryTriePruningStorer, error) + func NewPersistersTracker(args EpochArgs) *normalPersistersTracker + func NewTriePersisterTracker(args EpochArgs) *triePersistersTracker + func NewTriePruningStorer(args StorerArgs) (*triePruningStorer, error) + type DbFactoryHandler interface + Create func(filePath string) (storage.Persister, error) + CreateDisabled func() storage.Persister + IsInterfaceNil func() bool + type EpochArgs struct + NumOfActivePersisters uint32 + NumOfEpochsToKeep uint32 + StartingEpoch uint32 + 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) ([]data.KeyValuePair, error) + func (fhps *FullHistoryPruningStorer) GetFromEpoch(key []byte, epoch uint32) ([]byte, error) + func (fhps *FullHistoryPruningStorer) IsInterfaceNil() bool + func (fhps *FullHistoryPruningStorer) PutInEpoch(key []byte, data []byte, epoch uint32) error + type FullHistoryStorerArgs struct + NumOfOldActivePersisters uint32 + type PersistersTracker interface + CollectPersisterData func(p storage.Persister) + HasInitializedEnoughPersisters func(epoch int64) bool + IsInterfaceNil func() bool + ShouldClosePersister func(epoch int64) bool + 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) ([]data.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 + EpochsData EpochArgs + Identifier string + MaxBatchSize int + Notifier EpochStartNotifier + OldDataCleanerProvider clean.OldDataCleanerProvider + PathManager storage.PathManagerHandler + PersisterFactory DbFactoryHandler + PersistersTracker PersistersTracker + PruningEnabled bool + ShardCoordinator storage.ShardCoordinator + StateStatsHandler common.StateStatisticsHandler
Go to main page