Versions in this module Expand all Collapse all v0 v0.0.2 Oct 31, 2023 Changes in this version + var ErrEmptyExportFolderPath = errors.New("empty export folder path") + var ErrExpectedOneMetablock = errors.New("expected one metablock") + var ErrImportingData = errors.New("error importing data") + var ErrKeyTypeMismatch = errors.New("key type mismatch while importing") + var ErrNilGenesisNodesSetupHandler = errors.New("nil genesis nodes setup handler") + var ErrNilHardforkStorer = errors.New("nil hardfork storer") + var ErrNilPubKeyConverter = errors.New("nil public key converter") + var ErrNilRounder = errors.New("nil rounder") + type GenesisNodesSetupHandler interface + GetAdaptivity func() bool + GetChainId func() string + GetHysteresis func() float32 + GetMetaConsensusGroupSize func() uint32 + GetMinTransactionVersion func() uint32 + GetRoundDuration func() uint64 + GetShardConsensusGroupSize func() uint32 + GetStartTime func() int64 + InitialNodesInfo func() (map[uint32][]sharding.GenesisNodeInfoHandler, ...) + InitialNodesInfoForShard func(shardId uint32) ([]sharding.GenesisNodeInfoHandler, []sharding.GenesisNodeInfoHandler, error) + IsInterfaceNil func() bool + MinNumberOfMetaNodes func() uint32 + MinNumberOfNodes func() uint32 + MinNumberOfShardNodes func() uint32 + NumberOfShards func() uint32 + type HardforkStorer interface + Close func() error + FinishedIdentifier func(identifier string) error + Get func(identifier string, key []byte) ([]byte, error) + IsInterfaceNil func() bool + RangeKeys func(handler func(identifier string, keys [][]byte) bool) + Write func(identifier string, key []byte, value []byte) error v0.0.1 Oct 30, 2023 Changes in this version + var ErrContainerKeyAlreadyExists = errors.New("provided key already exists in container") + var ErrEmptyChainID = errors.New("empty chain ID") + var ErrEmptyVersionString = errors.New("empty version string") + var ErrEndOfFile = errors.New("end of file") + var ErrIncorrectHardforkMessage = errors.New("incorrect hardfork message") + var ErrInvalidContainerKey = errors.New("element does not exist in container") + var ErrInvalidEpoch = errors.New("invalid epoch") + var ErrInvalidFolderName = errors.New("invalid folder name") + var ErrInvalidTimeToWaitAfterHardfork = errors.New("invalid time to wait after hard fork") + var ErrInvalidValue = errors.New("invalid value") + var ErrInvalidWaitTime = errors.New("invalid wait time") + var ErrLenMismatch = errors.New("lengths mismatch") + var ErrNilAccounts = errors.New("nil accounts") + var ErrNilAccountsDBSyncContainer = errors.New("nil accounts db sync container") + var ErrNilAntiFloodHandler = errors.New("nil anti flood handler") + var ErrNilArgumentParser = errors.New("nil argument parser") + var ErrNilBlockKeyGen = errors.New("nil block key gen") + var ErrNilBlockSigner = errors.New("nil block signer") + var ErrNilCacher = errors.New("nil cacher") + var ErrNilChanStopNodeProcess = errors.New("nil channel to stop node") + var ErrNilCloser = errors.New("nil closer instance") + var ErrNilContainerElement = errors.New("element cannot be nil") + var ErrNilDataPoolHolder = errors.New("nil data pool holder") + var ErrNilDataReader = errors.New("nil data reader") + var ErrNilDataTrieContainer = errors.New("nil data trie container") + var ErrNilDataWriter = errors.New("nil data writer") + var ErrNilEpochConfirmedNotifier = errors.New("nil epoch confirmed notifier") + var ErrNilEpochHandler = errors.New("nil epoch handler") + var ErrNilExportFactoryHandler = errors.New("nil export factory handler") + var ErrNilHardForkBlockProcessor = errors.New("nil hard fork block processor") + var ErrNilHasher = errors.New("nil Hasher") + var ErrNilHeaderIntegrityVerifier = errors.New("nil header integrity verifier") + var ErrNilHeaderSigVerifier = errors.New("nil header sig verifier") + var ErrNilHeaderSyncHandler = errors.New("nil header sync handler") + var ErrNilHeaderValidator = errors.New("nil header validator") + var ErrNilImportHandler = errors.New("nil import handler") + var ErrNilImportStartHandler = errors.New("nil import start handler") + var ErrNilInterceptorsContainer = errors.New("nil interceptors container") + var ErrNilKeyGenerator = errors.New("nil key generator") + var ErrNilMarshalizer = errors.New("nil Marshalizer") + var ErrNilMessenger = errors.New("nil Messenger") + var ErrNilMiniBlocksSyncHandler = errors.New("nil miniblocks sync handler") + var ErrNilMultiFileReader = errors.New("nil multi file reader") + var ErrNilMultiSigner = errors.New("nil multi signer") + var ErrNilNodesCoordinator = errors.New("nil nodes coordinator") + var ErrNilPendingTxProcessor = errors.New("nil pending tx processor") + var ErrNilPubkeyConverter = errors.New("nil public key converter") + var ErrNilRequestHandler = errors.New("nil request handler") + var ErrNilResolverContainer = errors.New("nil resolver container") + var ErrNilRwdTxProcessor = errors.New("nil reward transaction processor") + var ErrNilSCRProcessor = errors.New("nil smart contract result processor") + var ErrNilShardCoordinator = errors.New("nil shard coordinator") + var ErrNilSingleSigner = errors.New("nil single signer") + var ErrNilStateSyncer = errors.New("nil state syncer") + var ErrNilStorage = errors.New("nil storage") + var ErrNilStorageManager = errors.New("nil trie storage manager") + var ErrNilTimeCache = errors.New("nil time cache") + var ErrNilTransactionsSyncHandler = errors.New("nil transaction sync handler") + var ErrNilTrieDataGetter = errors.New("nil trie data getter provided") + var ErrNilTrieStorageManagers = errors.New("nil trie storage managers") + var ErrNilTrieSyncers = errors.New("nil trie syncers") + var ErrNilTxCoordinator = errors.New("nil tx coordinator") + var ErrNilTxProcessor = errors.New("nil transaction processor") + var ErrNilUint64Converter = errors.New("unit64converter is nil") + var ErrNilValidityAttester = errors.New("nil validity attester") + var ErrNilWhiteListHandler = errors.New("nil white list handler") + var ErrNoFileToImport = errors.New("no files to import") + var ErrNotEpochStartBlock = errors.New("not epoch start block") + var ErrNotSynced = errors.New("not synced") + var ErrTimeIsOut = errors.New("time is out") + var ErrTriggerAlreadyInAction = errors.New("trigger already in action") + var ErrTriggerNotEnabled = errors.New("trigger is not enabled") + var ErrTriggerPubKeyMismatch = errors.New("trigger public key mismatch") + var ErrUnknownType = errors.New("unknown type") + var ErrWrongTypeAssertion = errors.New("wrong type assertion") + var ErrWrongTypeInContainer = errors.New("wrong type of object inside container") + var ErrWrongUnfinishedMetaHdrsMap = errors.New("wrong unfinished meta headers map") + type AccountsDBSyncContainer interface + Add func(key string, val AccountsDBSyncer) error + AddMultiple func(keys []string, values []AccountsDBSyncer) error + Get func(key string) (AccountsDBSyncer, error) + IsInterfaceNil func() bool + Len func() int + Remove func(key string) + Replace func(key string, val AccountsDBSyncer) error + type AccountsDBSyncer interface + GetSyncedTries func() map[string]data.Trie + IsInterfaceNil func() bool + SyncAccounts func(rootHash []byte) error + type Closer interface + Close func() error + IsInterfaceNil func() bool + type DataReader interface + Err func() error + Scan func() bool + Text func() string + type DataWriter interface + Flush func() error + WriteString func(s string) (int, error) + type EpochChangeConfirmedNotifier interface + IsInterfaceNil func() bool + RegisterForEpochChangeConfirmed func(handler func(epoch uint32)) + type EpochHandler interface + IsInterfaceNil func() bool + MetaEpoch func() uint32 + type EpochStartPendingMiniBlocksSyncHandler interface + GetMiniBlocks func() (map[string]*block.MiniBlock, error) + IsInterfaceNil func() bool + SyncPendingMiniBlocksFromMeta func(epochStart *block.MetaBlock, unFinished map[string]*block.MetaBlock, ...) error + type EpochStartTriesSyncHandler interface + GetTries func() (map[string]data.Trie, error) + IsInterfaceNil func() bool + SyncTriesFrom func(meta *block.MetaBlock, waitTime time.Duration) error + type EpochStartVerifier interface + Epoch func() uint32 + EpochStartMetaHdrHash func() []byte + IsEpochStart func() bool + IsInterfaceNil func() bool + type ExportFactoryHandler interface + Create func() (ExportHandler, error) + IsInterfaceNil func() bool + type ExportHandler interface + ExportAll func(epoch uint32) error + IsInterfaceNil func() bool + type HardForkBlockProcessor interface + CreateNewBlock func(chainID string, round uint64, nonce uint64, epoch uint32) (data.HeaderHandler, data.BodyHandler, error) + IsInterfaceNil func() bool + type HeaderSyncHandler interface + GetEpochStartMetaBlock func() (*block.MetaBlock, error) + GetUnfinishedMetaBlocks func() (map[string]*block.MetaBlock, error) + IsInterfaceNil func() bool + SyncUnFinishedMetaHeaders func(epoch uint32) error + type HistoryStorer interface + ClearCache func() + DestroyUnit func() error + Get func(key []byte) ([]byte, error) + GetFromEpoch func(key []byte, epoch uint32) ([]byte, error) + Has func(key []byte) error + HasInEpoch func(key []byte, epoch uint32) error + IsInterfaceNil func() bool + Put func(key, data []byte) error + Remove func(key []byte) error + type ImportHandler interface + GetAccountsDBForShard func(shardID uint32) state.AccountsAdapter + GetHardForkMetaBlock func() *block.MetaBlock + GetMiniBlocks func() map[string]*block.MiniBlock + GetTransactions func() map[string]data.TransactionHandler + GetValidatorAccountsDB func() state.AccountsAdapter + ImportAll func() error + IsInterfaceNil func() bool + type ImportStartHandler interface + IsAfterExportBeforeImport func() bool + IsInterfaceNil func() bool + ResetStartImport func() error + SetStartImport func() error + ShouldStartImport func() bool + type MissingHeadersByHashSyncer interface + ClearFields func() + GetHeaders func() (map[string]data.HeaderHandler, error) + IsInterfaceNil func() bool + SyncMissingHeadersByHash func(shardIDs []uint32, headersHashes [][]byte, ctx context.Context) error + type MultiFileReader interface + CloseFile func(fileName string) + Finish func() + GetFileNames func() []string + IsInterfaceNil func() bool + ReadNextItem func(fileName string) (string, []byte, error) + type MultiFileWriter interface + CloseFile func(fileName string) + Finish func() + IsInterfaceNil func() bool + NewFile func(name string) error + Write func(fileName string, key string, value []byte) error + type PendingTransactionProcessor interface + IsInterfaceNil func() bool + ProcessTransactionsDstMe func(mapTxs map[string]data.TransactionHandler) (block.MiniBlockSlice, error) + RootHash func() ([]byte, error) + type PendingTransactionsSyncHandler interface + GetTransactions func() (map[string]data.TransactionHandler, error) + IsInterfaceNil func() bool + SyncPendingTransactionsFor func(miniBlocks map[string]*block.MiniBlock, epoch uint32, ctx context.Context) error + type RequestHandler interface + GetNumPeersToQuery func(key string) (int, int, error) + IsInterfaceNil func() bool + RequestInterval func() time.Duration + RequestMetaHeader func(hash []byte) + RequestMetaHeaderByNonce func(nonce uint64) + RequestMiniBlock func(shardId uint32, miniblockHash []byte) + RequestRewardTransactions func(destShardID uint32, txHashes [][]byte) + RequestShardHeader func(shardId uint32, hash []byte) + RequestShardHeaderByNonce func(shardId uint32, nonce uint64) + RequestStartOfEpochMetaBlock func(epoch uint32) + RequestTransaction func(shardId uint32, txHashes [][]byte) + RequestTrieNodes func(destShardID uint32, hashes [][]byte, topic string) + RequestUnsignedTransactions func(destShardID uint32, scrHashes [][]byte) + SetNumPeersToQuery func(key string, intra int, cross int) error + type SigVerifier interface + IsInterfaceNil func() bool + Verify func(message []byte, sig []byte, pk []byte) error + type StateSyncer interface + GetAllMiniBlocks func() (map[string]*block.MiniBlock, error) + GetAllTransactions func() (map[string]data.TransactionHandler, error) + GetAllTries func() (map[string]data.Trie, error) + GetEpochStartMetaBlock func() (*block.MetaBlock, error) + GetUnfinishedMetaBlocks func() (map[string]*block.MetaBlock, error) + IsInterfaceNil func() bool + SyncAllState func(epoch uint32) error + type TrieSyncContainer interface + Add func(key string, val TrieSyncer) error + AddMultiple func(keys []string, interceptors []TrieSyncer) error + Get func(key string) (TrieSyncer, error) + IsInterfaceNil func() bool + Len func() int + Remove func(key string) + Replace func(key string, val TrieSyncer) error + type TrieSyncer interface + IsInterfaceNil func() bool + StartSyncing func(rootHash []byte, ctx context.Context) error + Trie func() data.Trie + type WhiteListHandler interface + Add func(keys [][]byte) + IsInterfaceNil func() bool + IsWhiteListed func(interceptedData process.InterceptedData) bool + Remove func(keys [][]byte)