Documentation
¶
Index ¶
- func GetBloomFromConfig(cfg config.BloomFilterConfig) storageUnit.BloomConfig
- func GetCacherFromConfig(cfg config.CacheConfig) storageUnit.CacheConfig
- func GetDBFromConfig(cfg config.DBConfig) storageUnit.DBConfig
- func NewBootstrapDataProvider(marshalizer marshal.Marshalizer) (*bootstrapDataProvider, error)
- func NewDirectoryReader() *directoryReader
- func NewStorageUnitOpenHandler(args ArgsNewOpenStorageUnits) (*openStorageUnits, error)
- type ArgsNewOpenStorageUnits
- type BootstrapDataProviderHandler
- type PersisterFactory
- type StorageServiceFactory
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetBloomFromConfig ¶
func GetBloomFromConfig(cfg config.BloomFilterConfig) storageUnit.BloomConfig
GetBloomFromConfig will return the bloom config needed for storage unit from a config came from the toml file
func GetCacherFromConfig ¶
func GetCacherFromConfig(cfg config.CacheConfig) storageUnit.CacheConfig
GetCacherFromConfig will return the cache config needed for storage unit from a config came from the toml file
func GetDBFromConfig ¶
func GetDBFromConfig(cfg config.DBConfig) storageUnit.DBConfig
GetDBFromConfig will return the db config needed for storage unit from a config came from the toml file
func NewBootstrapDataProvider ¶
func NewBootstrapDataProvider(marshalizer marshal.Marshalizer) (*bootstrapDataProvider, error)
NewBootstrapDataProvider returns a new instance of bootstrapDataProvider
func NewDirectoryReader ¶
func NewDirectoryReader() *directoryReader
NewDirectoryReader returns a new instance of directoryReader
func NewStorageUnitOpenHandler ¶
func NewStorageUnitOpenHandler(args ArgsNewOpenStorageUnits) (*openStorageUnits, error)
NewStorageUnitOpenHandler creates an openStorageUnits component
Types ¶
type ArgsNewOpenStorageUnits ¶
type ArgsNewOpenStorageUnits struct {
GeneralConfig config.Config
Marshalizer marshal.Marshalizer
BootstrapDataProvider BootstrapDataProviderHandler
LatestStorageDataProvider storage.LatestStorageDataProviderHandler
WorkingDir string
ChainID string
DefaultDBPath string
DefaultEpochString string
DefaultShardString string
}
ArgsNewOpenStorageUnits defines the arguments in order to open a set of storage units from disk
type BootstrapDataProviderHandler ¶
type BootstrapDataProviderHandler interface {
LoadForPath(persisterFactory storage.PersisterFactory, path string) (*bootstrapStorage.BootstrapData, storage.Storer, error)
GetStorer(storer storage.Storer) (process.BootStorer, error)
IsInterfaceNil() bool
}
BootstrapDataProviderHandler defines which actions should be done for loading bootstrap data from the boot storer
type PersisterFactory ¶
type PersisterFactory struct {
// contains filtered or unexported fields
}
PersisterFactory is the factory which will handle creating new databases
func NewPersisterFactory ¶
func NewPersisterFactory(config config.DBConfig) *PersisterFactory
NewPersisterFactory will return a new instance of a PersisterFactory
func (*PersisterFactory) Create ¶
func (pf *PersisterFactory) Create(path string) (storage.Persister, error)
Create will return a new instance of a DB with a given path
func (*PersisterFactory) CreateDisabled ¶
func (pf *PersisterFactory) CreateDisabled() storage.Persister
CreateDisabled will return a new disabled persister
func (*PersisterFactory) IsInterfaceNil ¶
func (pf *PersisterFactory) IsInterfaceNil() bool
IsInterfaceNil returns true if there is no value under the interface
type StorageServiceFactory ¶
type StorageServiceFactory struct {
// contains filtered or unexported fields
}
StorageServiceFactory handles the creation of storage services for both meta and shards
func NewStorageServiceFactory ¶
func NewStorageServiceFactory( config *config.Config, shardCoordinator storage.ShardCoordinator, pathManager storage.PathManagerHandler, epochStartNotifier storage.EpochStartNotifier, currentEpoch uint32, ) (*StorageServiceFactory, error)
NewStorageServiceFactory will return a new instance of StorageServiceFactory
func (*StorageServiceFactory) CreateForMeta ¶
func (psf *StorageServiceFactory) CreateForMeta() (dataRetriever.StorageService, error)
CreateForMeta will return the storage service which contains all storers needed for metachain
func (*StorageServiceFactory) CreateForShard ¶
func (psf *StorageServiceFactory) CreateForShard() (dataRetriever.StorageService, error)
CreateForShard will return the storage service which contains all storers needed for a shard
Source Files