Versions in this module Expand all Collapse all v1 v1.999.0 Nov 17, 2022 Changes in this version + var ErrMockMarshalizer = errors.New("MarshalizerMock generic error") + func ShardIdToString(shardId uint32) string + type AccountsFactoryStub struct + CreateAccountCalled func(address []byte) (vmcommon.AccountHandler, error) + func (afs *AccountsFactoryStub) CreateAccount(address []byte) (vmcommon.AccountHandler, error) + func (afs *AccountsFactoryStub) IsInterfaceNil() bool + type AccountsParserStub struct + GenerateInitialTransactionsCalled func(shardCoordinator sharding.Coordinator, ...) ([]*block.MiniBlock, map[uint32]*indexer.Pool, error) + GetInitialAccountsForDelegatedCalled func(addressBytes []byte) []genesis.InitialAccountHandler + GetTotalStakedForDelegationAddressCalled func(delegationAddress string) *big.Int + InitialAccountsCalled func() []genesis.InitialAccountHandler + InitialAccountsSplitOnAddressesShardsCalled func(shardCoordinator sharding.Coordinator) (map[uint32][]genesis.InitialAccountHandler, error) + InitialAccountsSplitOnDelegationAddressesShardsCalled func(shardCoordinator sharding.Coordinator) (map[uint32][]genesis.InitialAccountHandler, error) + func (aps *AccountsParserStub) GenerateInitialTransactions(shardCoordinator sharding.Coordinator, ...) ([]*block.MiniBlock, map[uint32]*indexer.Pool, error) + func (aps *AccountsParserStub) GetInitialAccountsForDelegated(addressBytes []byte) []genesis.InitialAccountHandler + func (aps *AccountsParserStub) GetTotalStakedForDelegationAddress(delegationAddress string) *big.Int + func (aps *AccountsParserStub) InitialAccounts() []genesis.InitialAccountHandler + func (aps *AccountsParserStub) InitialAccountsSplitOnAddressesShards(shardCoordinator sharding.Coordinator) (map[uint32][]genesis.InitialAccountHandler, error) + func (aps *AccountsParserStub) InitialAccountsSplitOnDelegationAddressesShards(shardCoordinator sharding.Coordinator) (map[uint32][]genesis.InitialAccountHandler, error) + func (aps *AccountsParserStub) IsInterfaceNil() bool + type BlockProcessorStub struct + AddLastNotarizedHdrCalled func(shardId uint32, processedHdr data.HeaderHandler) + CommitBlockCalled func(header data.HeaderHandler, body data.BodyHandler) error + CreateBlockCalled func(initialHdrData data.HeaderHandler, haveTime func() bool) (data.HeaderHandler, data.BodyHandler, error) + CreateGenesisBlockCalled func(balances map[string]*big.Int) (data.HeaderHandler, error) + CreateNewHeaderCalled func(round uint64, nonce uint64) (data.HeaderHandler, error) + DecodeBlockBodyCalled func(dta []byte) data.BodyHandler + DecodeBlockHeaderCalled func(dta []byte) data.HeaderHandler + MarshalizedDataToBroadcastCalled func(header data.HeaderHandler, body data.BodyHandler) (map[uint32][]byte, map[string][][]byte, error) + ProcessBlockCalled func(header data.HeaderHandler, body data.BodyHandler, ...) error + ProcessScheduledBlockCalled func(header data.HeaderHandler, body data.BodyHandler, ...) error + PruneStateOnRollbackCalled func(currHeader data.HeaderHandler, currHeaderHash []byte, ...) + RestoreBlockBodyIntoPoolsCalled func(body data.BodyHandler) error + RestoreBlockIntoPoolsCalled func(header data.HeaderHandler, body data.BodyHandler) error + RevertCurrentBlockCalled func() + RevertStateToBlockCalled func(header data.HeaderHandler, rootHash []byte) error + SetOnRequestTransactionCalled func(f func(destShardID uint32, txHash []byte)) + func (bps *BlockProcessorStub) AddLastNotarizedHdr(shardId uint32, processedHdr data.HeaderHandler) + func (bps *BlockProcessorStub) Close() error + func (bps *BlockProcessorStub) CommitBlock(header data.HeaderHandler, body data.BodyHandler) error + func (bps *BlockProcessorStub) CreateBlock(initialHdrData data.HeaderHandler, haveTime func() bool) (data.HeaderHandler, data.BodyHandler, error) + func (bps *BlockProcessorStub) CreateGenesisBlock(balances map[string]*big.Int) (data.HeaderHandler, error) + func (bps *BlockProcessorStub) CreateNewHeader(round uint64, nonce uint64) (data.HeaderHandler, error) + func (bps *BlockProcessorStub) DecodeBlockBody(dta []byte) data.BodyHandler + func (bps *BlockProcessorStub) DecodeBlockHeader(dta []byte) data.HeaderHandler + func (bps *BlockProcessorStub) IsInterfaceNil() bool + func (bps *BlockProcessorStub) MarshalizedDataToBroadcast(header data.HeaderHandler, body data.BodyHandler) (map[uint32][]byte, map[string][][]byte, error) + func (bps *BlockProcessorStub) ProcessBlock(header data.HeaderHandler, body data.BodyHandler, ...) error + func (bps *BlockProcessorStub) ProcessScheduledBlock(header data.HeaderHandler, body data.BodyHandler, ...) error + func (bps *BlockProcessorStub) PruneStateOnRollback(currHeader data.HeaderHandler, currHeaderHash []byte, ...) + func (bps *BlockProcessorStub) RestoreBlockBodyIntoPools(body data.BodyHandler) error + func (bps *BlockProcessorStub) RestoreBlockIntoPools(header data.HeaderHandler, body data.BodyHandler) error + func (bps *BlockProcessorStub) RestoreLastNotarizedHrdsToGenesis() + func (bps *BlockProcessorStub) RevertCurrentBlock() + func (bps *BlockProcessorStub) RevertStateToBlock(header data.HeaderHandler, rootHash []byte) error + func (bps *BlockProcessorStub) SetNumProcessedObj(_ uint64) + type BlockTrackerStub struct + AddCrossNotarizedHeaderCalled func(shardID uint32, crossNotarizedHeader data.HeaderHandler, ...) + AddSelfNotarizedHeaderCalled func(shardID uint32, selfNotarizedHeader data.HeaderHandler, ...) + AddTrackedHeaderCalled func(header data.HeaderHandler, hash []byte) + CheckBlockAgainstFinalCalled func(headerHandler data.HeaderHandler) error + CheckBlockAgainstRoundHandlerCalled func(headerHandler data.HeaderHandler) error + CheckBlockAgainstWhitelistCalled func(interceptedData process.InterceptedData) bool + CleanupHeadersBehindNonceCalled func(shardID uint32, selfNotarizedNonce uint64, crossNotarizedNonce uint64) + ComputeLongestChainCalled func(shardID uint32, header data.HeaderHandler) ([]data.HeaderHandler, [][]byte) + ComputeLongestMetaChainFromLastNotarizedCalled func() ([]data.HeaderHandler, [][]byte, error) + ComputeLongestShardsChainsFromLastNotarizedCalled func() ([]data.HeaderHandler, [][]byte, map[uint32][]data.HeaderHandler, error) + DisplayTrackedHeadersCalled func() + GetCrossNotarizedHeaderCalled func(shardID uint32, offset uint64) (data.HeaderHandler, []byte, error) + GetLastCrossNotarizedHeaderCalled func(shardID uint32) (data.HeaderHandler, []byte, error) + GetLastCrossNotarizedHeadersForAllShardsCalled func() (map[uint32]data.HeaderHandler, error) + GetLastSelfNotarizedHeaderCalled func(shardID uint32) (data.HeaderHandler, []byte, error) + GetSelfNotarizedHeaderCalled func(shardID uint32, offset uint64) (data.HeaderHandler, []byte, error) + GetTrackedHeadersCalled func(shardID uint32) ([]data.HeaderHandler, [][]byte) + GetTrackedHeadersForAllShardsCalled func() map[uint32][]data.HeaderHandler + GetTrackedHeadersWithNonceCalled func(shardID uint32, nonce uint64) ([]data.HeaderHandler, [][]byte) + IsShardStuckCalled func(shardId uint32) bool + RegisterCrossNotarizedHeadersHandlerCalled func(...) + RegisterFinalMetachainHeadersHandlerCalled func(...) + RegisterSelfNotarizedFromCrossHeadersHandlerCalled func(...) + RegisterSelfNotarizedHeadersHandlerCalled func(...) + RemoveLastNotarizedHeadersCalled func() + RestoreToGenesisCalled func() + ShouldAddHeaderCalled func(headerHandler data.HeaderHandler) bool + ShouldSkipMiniBlocksCreationFromSelfCalled func() bool + func (bts *BlockTrackerStub) AddCrossNotarizedHeader(shardID uint32, crossNotarizedHeader data.HeaderHandler, ...) + func (bts *BlockTrackerStub) AddSelfNotarizedHeader(shardID uint32, selfNotarizedHeader data.HeaderHandler, ...) + func (bts *BlockTrackerStub) AddTrackedHeader(header data.HeaderHandler, hash []byte) + func (bts *BlockTrackerStub) CheckBlockAgainstFinal(headerHandler data.HeaderHandler) error + func (bts *BlockTrackerStub) CheckBlockAgainstRoundHandler(headerHandler data.HeaderHandler) error + func (bts *BlockTrackerStub) CheckBlockAgainstWhitelist(interceptedData process.InterceptedData) bool + func (bts *BlockTrackerStub) CleanupHeadersBehindNonce(shardID uint32, selfNotarizedNonce uint64, crossNotarizedNonce uint64) + func (bts *BlockTrackerStub) CleanupInvalidCrossHeaders(_ uint32, _ uint64) + func (bts *BlockTrackerStub) ComputeLongestChain(shardID uint32, header data.HeaderHandler) ([]data.HeaderHandler, [][]byte) + func (bts *BlockTrackerStub) ComputeLongestMetaChainFromLastNotarized() ([]data.HeaderHandler, [][]byte, error) + func (bts *BlockTrackerStub) ComputeLongestShardsChainsFromLastNotarized() ([]data.HeaderHandler, [][]byte, map[uint32][]data.HeaderHandler, error) + func (bts *BlockTrackerStub) DisplayTrackedHeaders() + func (bts *BlockTrackerStub) GetCrossNotarizedHeader(shardID uint32, offset uint64) (data.HeaderHandler, []byte, error) + func (bts *BlockTrackerStub) GetLastCrossNotarizedHeader(shardID uint32) (data.HeaderHandler, []byte, error) + func (bts *BlockTrackerStub) GetLastCrossNotarizedHeadersForAllShards() (map[uint32]data.HeaderHandler, error) + func (bts *BlockTrackerStub) GetLastSelfNotarizedHeader(shardID uint32) (data.HeaderHandler, []byte, error) + func (bts *BlockTrackerStub) GetSelfNotarizedHeader(shardID uint32, offset uint64) (data.HeaderHandler, []byte, error) + func (bts *BlockTrackerStub) GetTrackedHeaders(shardID uint32) ([]data.HeaderHandler, [][]byte) + func (bts *BlockTrackerStub) GetTrackedHeadersForAllShards() map[uint32][]data.HeaderHandler + func (bts *BlockTrackerStub) GetTrackedHeadersWithNonce(shardID uint32, nonce uint64) ([]data.HeaderHandler, [][]byte) + func (bts *BlockTrackerStub) IsInterfaceNil() bool + func (bts *BlockTrackerStub) IsShardStuck(shardId uint32) bool + func (bts *BlockTrackerStub) RegisterCrossNotarizedHeadersHandler(...) + func (bts *BlockTrackerStub) RegisterFinalMetachainHeadersHandler(...) + func (bts *BlockTrackerStub) RegisterSelfNotarizedFromCrossHeadersHandler(...) + func (bts *BlockTrackerStub) RegisterSelfNotarizedHeadersHandler(...) + func (bts *BlockTrackerStub) RemoveLastNotarizedHeaders() + func (bts *BlockTrackerStub) RestoreToGenesis() + func (bts *BlockTrackerStub) ShouldAddHeader(headerHandler data.HeaderHandler) bool + func (bts *BlockTrackerStub) ShouldSkipMiniBlocksCreationFromSelf() bool + type BoostrapStorerStub struct + GetCalled func(round int64) (bootstrapStorage.BootstrapData, error) + GetHighestRoundCalled func() int64 + PutCalled func(round int64, bootData bootstrapStorage.BootstrapData) error + func (bsm *BoostrapStorerStub) Get(round int64) (bootstrapStorage.BootstrapData, error) + func (bsm *BoostrapStorerStub) GetHighestRound() int64 + func (bsm *BoostrapStorerStub) IsInterfaceNil() bool + func (bsm *BoostrapStorerStub) Put(round int64, bootData bootstrapStorage.BootstrapData) error + func (bsm *BoostrapStorerStub) SaveLastRound(_ int64) error + type BootstrapStorerMock struct + GetCalled func(round int64) (bootstrapStorage.BootstrapData, error) + GetHighestRoundCalled func() int64 + PutCalled func(round int64, bootData bootstrapStorage.BootstrapData) error + func (bsm *BootstrapStorerMock) Get(round int64) (bootstrapStorage.BootstrapData, error) + func (bsm *BootstrapStorerMock) GetHighestRound() int64 + func (bsm *BootstrapStorerMock) IsInterfaceNil() bool + func (bsm *BootstrapStorerMock) Put(round int64, bootData bootstrapStorage.BootstrapData) error + func (bsm *BootstrapStorerMock) SaveLastRound(_ int64) error + type ChainStorerMock struct + AddStorerCalled func(key dataRetriever.UnitType, s storage.Storer) + CloseAllCalled func() error + DestroyCalled func() error + GetAllCalled func(unitType dataRetriever.UnitType, keys [][]byte) (map[string][]byte, error) + GetAllStorersCalled func() map[dataRetriever.UnitType]storage.Storer + GetCalled func(unitType dataRetriever.UnitType, key []byte) ([]byte, error) + GetStorerCalled func(unitType dataRetriever.UnitType) storage.Storer + HasCalled func(unitType dataRetriever.UnitType, key []byte) error + PutCalled func(unitType dataRetriever.UnitType, key []byte, value []byte) error + func (bc *ChainStorerMock) AddStorer(key dataRetriever.UnitType, s storage.Storer) + func (bc *ChainStorerMock) CloseAll() error + func (bc *ChainStorerMock) Destroy() error + func (bc *ChainStorerMock) Get(unitType dataRetriever.UnitType, key []byte) ([]byte, error) + func (bc *ChainStorerMock) GetAll(unitType dataRetriever.UnitType, keys [][]byte) (map[string][]byte, error) + func (bc *ChainStorerMock) GetAllStorers() map[dataRetriever.UnitType]storage.Storer + func (bc *ChainStorerMock) GetStorer(unitType dataRetriever.UnitType) storage.Storer + func (bc *ChainStorerMock) Has(unitType dataRetriever.UnitType, key []byte) error + func (bc *ChainStorerMock) IsInterfaceNil() bool + func (bc *ChainStorerMock) Put(unitType dataRetriever.UnitType, key []byte, value []byte) error + func (bc *ChainStorerMock) SetEpochForPutOperation(_ uint32) + type ChainStorerStub struct + AddStorerCalled func(key dataRetriever.UnitType, s storage.Storer) + CloseAllCalled func() error + DestroyCalled func() error + GetAllCalled func(unitType dataRetriever.UnitType, keys [][]byte) (map[string][]byte, error) + GetAllStorersCalled func() map[dataRetriever.UnitType]storage.Storer + GetCalled func(unitType dataRetriever.UnitType, key []byte) ([]byte, error) + GetStorerCalled func(unitType dataRetriever.UnitType) storage.Storer + HasCalled func(unitType dataRetriever.UnitType, key []byte) error + PutCalled func(unitType dataRetriever.UnitType, key []byte, value []byte) error + func (bc *ChainStorerStub) AddStorer(key dataRetriever.UnitType, s storage.Storer) + func (bc *ChainStorerStub) CloseAll() error + func (bc *ChainStorerStub) Destroy() error + func (bc *ChainStorerStub) Get(unitType dataRetriever.UnitType, key []byte) ([]byte, error) + func (bc *ChainStorerStub) GetAll(unitType dataRetriever.UnitType, keys [][]byte) (map[string][]byte, error) + func (bc *ChainStorerStub) GetAllStorers() map[dataRetriever.UnitType]storage.Storer + func (bc *ChainStorerStub) GetStorer(unitType dataRetriever.UnitType) storage.Storer + func (bc *ChainStorerStub) Has(unitType dataRetriever.UnitType, key []byte) error + func (bc *ChainStorerStub) IsInterfaceNil() bool + func (bc *ChainStorerStub) Put(unitType dataRetriever.UnitType, key []byte, value []byte) error + func (bc *ChainStorerStub) SetEpochForPutOperation(_ uint32) + type CoreComponentsMock struct + APIEconomicsHandler process.EconomicsDataHandler + AddrPubKeyConv core.PubkeyConverter + AlarmSch core.TimersScheduler + AppStatusHdl core.AppStatusHandler + ArwenChangeLockerInternal common.Locker + ChainIdCalled func() string + ChanStopProcess chan endProcess.ArgEndProcess + EconomicsHandler process.EconomicsDataHandler + EpochChangeNotifier process.EpochNotifier + EpochNotifierWithConfirm factory.EpochStartNotifierWithConfirm + GenesisBlockTime time.Time + HardforkTriggerPubKeyField []byte + Hash hashing.Hasher + IntMarsh marshal.Marshalizer + MinTransactionVersionCalled func() uint32 + NodeTypeProviderField core.NodeTypeProviderHandler + NodesConfig sharding.GenesisNodesSetupHandler + NtpSyncTimer ntp.SyncTimer + PathHdl storage.PathManagerHandler + ProcessStatusHandlerInternal common.ProcessStatusHandler + RatingHandler sharding.PeerAccountListAndRatingHandler + RatingsConfig process.RatingsInfoHandler + RoundChangeNotifier process.RoundNotifier + RoundHandlerField consensus.RoundHandler + Shuffler nodesCoordinator.NodesShuffler + StartTime time.Time + StatusHdlUtils nodeFactory.StatusHandlersUtils + TxMarsh marshal.Marshalizer + TxSignHasherField hashing.Hasher + TxVersionCheckHandler process.TxVersionCheckerHandler + UInt64ByteSliceConv typeConverters.Uint64ByteSliceConverter + ValPubKeyConv core.PubkeyConverter + VmMarsh marshal.Marshalizer + WatchdogTimer core.WatchdogTimer + func (ccm *CoreComponentsMock) APIEconomicsData() process.EconomicsDataHandler + func (ccm *CoreComponentsMock) AddressPubKeyConverter() core.PubkeyConverter + func (ccm *CoreComponentsMock) AlarmScheduler() core.TimersScheduler + func (ccm *CoreComponentsMock) ArwenChangeLocker() common.Locker + func (ccm *CoreComponentsMock) ChainID() string + func (ccm *CoreComponentsMock) ChanStopNodeProcess() chan endProcess.ArgEndProcess + func (ccm *CoreComponentsMock) EconomicsData() process.EconomicsDataHandler + func (ccm *CoreComponentsMock) EncodedAddressLen() uint32 + func (ccm *CoreComponentsMock) EpochNotifier() process.EpochNotifier + func (ccm *CoreComponentsMock) EpochStartNotifierWithConfirm() factory.EpochStartNotifierWithConfirm + func (ccm *CoreComponentsMock) GenesisNodesSetup() sharding.GenesisNodesSetupHandler + func (ccm *CoreComponentsMock) GenesisTime() time.Time + func (ccm *CoreComponentsMock) HardforkTriggerPubKey() []byte + func (ccm *CoreComponentsMock) Hasher() hashing.Hasher + func (ccm *CoreComponentsMock) InternalMarshalizer() marshal.Marshalizer + func (ccm *CoreComponentsMock) IsInterfaceNil() bool + func (ccm *CoreComponentsMock) MinTransactionVersion() uint32 + func (ccm *CoreComponentsMock) NodeTypeProvider() core.NodeTypeProviderHandler + func (ccm *CoreComponentsMock) NodesShuffler() nodesCoordinator.NodesShuffler + func (ccm *CoreComponentsMock) PathHandler() storage.PathManagerHandler + func (ccm *CoreComponentsMock) ProcessStatusHandler() common.ProcessStatusHandler + func (ccm *CoreComponentsMock) Rater() sharding.PeerAccountListAndRatingHandler + func (ccm *CoreComponentsMock) RatingsData() process.RatingsInfoHandler + func (ccm *CoreComponentsMock) RoundHandler() consensus.RoundHandler + func (ccm *CoreComponentsMock) RoundNotifier() process.RoundNotifier + func (ccm *CoreComponentsMock) SetInternalMarshalizer(m marshal.Marshalizer) error + func (ccm *CoreComponentsMock) StatusHandler() core.AppStatusHandler + func (ccm *CoreComponentsMock) StatusHandlerUtils() nodeFactory.StatusHandlersUtils + func (ccm *CoreComponentsMock) SyncTimer() ntp.SyncTimer + func (ccm *CoreComponentsMock) TxMarshalizer() marshal.Marshalizer + func (ccm *CoreComponentsMock) TxSignHasher() hashing.Hasher + func (ccm *CoreComponentsMock) TxVersionChecker() process.TxVersionCheckerHandler + func (ccm *CoreComponentsMock) Uint64ByteSliceConverter() typeConverters.Uint64ByteSliceConverter + func (ccm *CoreComponentsMock) ValidatorPubKeyConverter() core.PubkeyConverter + func (ccm *CoreComponentsMock) VmMarshalizer() marshal.Marshalizer + func (ccm *CoreComponentsMock) Watchdog() core.WatchdogTimer + type CryptoComponentsMock struct + BlKeyGen crypto.KeyGenerator + BlockSig crypto.SingleSigner + MsgSigVerifier vm.MessageSignVerifier + MultiSig crypto.MultiSigner + PeerSignHandler crypto.PeerSignatureHandler + PrivKey crypto.PrivateKey + PrivKeyBytes []byte + PubKey crypto.PublicKey + PubKeyBytes []byte + PubKeyString string + TxKeyGen crypto.KeyGenerator + TxSig crypto.SingleSigner + func (ccm *CryptoComponentsMock) BlockSignKeyGen() crypto.KeyGenerator + func (ccm *CryptoComponentsMock) BlockSigner() crypto.SingleSigner + func (ccm *CryptoComponentsMock) Clone() interface{} + func (ccm *CryptoComponentsMock) IsInterfaceNil() bool + func (ccm *CryptoComponentsMock) MessageSignVerifier() vm.MessageSignVerifier + func (ccm *CryptoComponentsMock) MultiSigner() crypto.MultiSigner + func (ccm *CryptoComponentsMock) PeerSignatureHandler() crypto.PeerSignatureHandler + func (ccm *CryptoComponentsMock) PrivateKey() crypto.PrivateKey + func (ccm *CryptoComponentsMock) PrivateKeyBytes() []byte + func (ccm *CryptoComponentsMock) PublicKey() crypto.PublicKey + func (ccm *CryptoComponentsMock) PublicKeyBytes() []byte + func (ccm *CryptoComponentsMock) PublicKeyString() string + func (ccm *CryptoComponentsMock) SetMultiSigner(ms crypto.MultiSigner) error + func (ccm *CryptoComponentsMock) TxSignKeyGen() crypto.KeyGenerator + func (ccm *CryptoComponentsMock) TxSingleSigner() crypto.SingleSigner + type DataComponentsMock struct + Blkc data.ChainHandler + DataPool dataRetriever.PoolsHolder + EconomicsData factory.EconomicsHandler + MiniBlockProvider factory.MiniBlockProvider + Storage dataRetriever.StorageService + func (dcm *DataComponentsMock) Blockchain() data.ChainHandler + func (dcm *DataComponentsMock) Clone() interface{} + func (dcm *DataComponentsMock) Datapool() dataRetriever.PoolsHolder + func (dcm *DataComponentsMock) EconomicsHandler() factory.EconomicsHandler + func (dcm *DataComponentsMock) IsInterfaceNil() bool + func (dcm *DataComponentsMock) MiniBlocksProvider() factory.MiniBlockProvider + func (dcm *DataComponentsMock) SetBlockchain(chain data.ChainHandler) + func (dcm *DataComponentsMock) StorageService() dataRetriever.StorageService + type EpochStartNotifierStub struct + NotifyAllCalled func(hdr data.HeaderHandler) + NotifyAllPrepareCalled func(hdr data.HeaderHandler, body data.BodyHandler) + NotifyEpochChangeConfirmedCalled func(epoch uint32) + RegisterHandlerCalled func(handler epochStart.ActionHandler) + UnregisterHandlerCalled func(handler epochStart.ActionHandler) + func (esnm *EpochStartNotifierStub) IsInterfaceNil() bool + func (esnm *EpochStartNotifierStub) NotifyAll(hdr data.HeaderHandler) + func (esnm *EpochStartNotifierStub) NotifyAllPrepare(metaHdr data.HeaderHandler, body data.BodyHandler) + func (esnm *EpochStartNotifierStub) NotifyEpochChangeConfirmed(epoch uint32) + func (esnm *EpochStartNotifierStub) RegisterHandler(handler epochStart.ActionHandler) + func (esnm *EpochStartNotifierStub) UnregisterHandler(handler epochStart.ActionHandler) + type EpochStartTriggerStub struct + EpochCalled func() uint32 + EpochStartRoundCalled func() uint64 + ForceEpochStartCalled func(round uint64) + IsEpochStartCalled func() bool + MetaEpochCalled func() uint32 + ProcessedCalled func(header data.HeaderHandler) + ReceivedHeaderCalled func(handler data.HeaderHandler) + UpdateCalled func(round uint64, nonce uint64) + func (e *EpochStartTriggerStub) Close() error + func (e *EpochStartTriggerStub) Epoch() uint32 + func (e *EpochStartTriggerStub) EpochFinalityAttestingRound() uint64 + func (e *EpochStartTriggerStub) EpochStartMetaHdrHash() []byte + func (e *EpochStartTriggerStub) EpochStartRound() uint64 + func (e *EpochStartTriggerStub) ForceEpochStart(round uint64) + func (e *EpochStartTriggerStub) GetRoundsPerEpoch() uint64 + func (e *EpochStartTriggerStub) GetSavedStateKey() []byte + func (e *EpochStartTriggerStub) IsEpochStart() bool + func (e *EpochStartTriggerStub) IsInterfaceNil() bool + func (e *EpochStartTriggerStub) LoadState(_ []byte) error + func (e *EpochStartTriggerStub) MetaEpoch() uint32 + func (e *EpochStartTriggerStub) NotifyAll(_ data.HeaderHandler) + func (e *EpochStartTriggerStub) ReceivedHeader(header data.HeaderHandler) + func (e *EpochStartTriggerStub) RequestEpochStartIfNeeded(_ data.HeaderHandler) + func (e *EpochStartTriggerStub) Revert(_ data.HeaderHandler) + func (e *EpochStartTriggerStub) RevertStateToBlock(_ data.HeaderHandler) error + func (e *EpochStartTriggerStub) SetAppStatusHandler(_ core.AppStatusHandler) error + func (e *EpochStartTriggerStub) SetCurrentEpochStartRound(_ uint64) + func (e *EpochStartTriggerStub) SetEpoch(_ uint32) + func (e *EpochStartTriggerStub) SetFinalityAttestingRound(_ uint64) + func (e *EpochStartTriggerStub) SetProcessed(header data.HeaderHandler, _ data.BodyHandler) + func (e *EpochStartTriggerStub) SetRoundsPerEpoch(_ uint64) + func (e *EpochStartTriggerStub) SetTrigger(_ epochStart.TriggerHandler) + func (e *EpochStartTriggerStub) Update(round uint64, nonce uint64) + type ForkDetectorMock struct + AddHeaderCalled func(header data.HeaderHandler, hash []byte, state process.BlockHeaderState, ...) error + CheckForkCalled func() *process.ForkInfo + GetHighestFinalBlockHashCalled func() []byte + GetHighestFinalBlockNonceCalled func() uint64 + GetNotarizedHeaderHashCalled func(nonce uint64) []byte + ProbableHighestNonceCalled func() uint64 + RemoveHeaderCalled func(nonce uint64, hash []byte) + ResetForkCalled func() + ResetProbableHighestNonceCalled func() + RestoreToGenesisCalled func() + SetFinalToLastCheckpointCalled func() + SetRollBackNonceCalled func(nonce uint64) + func (fdm *ForkDetectorMock) AddHeader(header data.HeaderHandler, hash []byte, state process.BlockHeaderState, ...) error + func (fdm *ForkDetectorMock) CheckFork() *process.ForkInfo + func (fdm *ForkDetectorMock) GetHighestFinalBlockHash() []byte + func (fdm *ForkDetectorMock) GetHighestFinalBlockNonce() uint64 + func (fdm *ForkDetectorMock) GetNotarizedHeaderHash(nonce uint64) []byte + func (fdm *ForkDetectorMock) IsInterfaceNil() bool + func (fdm *ForkDetectorMock) ProbableHighestNonce() uint64 + func (fdm *ForkDetectorMock) RemoveHeader(nonce uint64, hash []byte) + func (fdm *ForkDetectorMock) ResetFork() + func (fdm *ForkDetectorMock) ResetProbableHighestNonce() + func (fdm *ForkDetectorMock) RestoreToGenesis() + func (fdm *ForkDetectorMock) SetFinalToLastCheckpoint() + func (fdm *ForkDetectorMock) SetRollBackNonce(nonce uint64) + type ForkDetectorStub struct + AddHeaderCalled func(header data.HeaderHandler, hash []byte, state process.BlockHeaderState, ...) error + CheckForkCalled func() *process.ForkInfo + GetHighestFinalBlockHashCalled func() []byte + GetHighestFinalBlockNonceCalled func() uint64 + GetNotarizedHeaderHashCalled func(nonce uint64) []byte + ProbableHighestNonceCalled func() uint64 + RemoveHeaderCalled func(nonce uint64, hash []byte) + ResetForkCalled func() + ResetProbableHighestNonceCalled func() + RestoreToGenesisCalled func() + SetFinalToLastCheckpointCalled func() + SetRollBackNonceCalled func(nonce uint64) + func (fdm *ForkDetectorStub) AddHeader(header data.HeaderHandler, hash []byte, state process.BlockHeaderState, ...) error + func (fdm *ForkDetectorStub) CheckFork() *process.ForkInfo + func (fdm *ForkDetectorStub) GetHighestFinalBlockHash() []byte + func (fdm *ForkDetectorStub) GetHighestFinalBlockNonce() uint64 + func (fdm *ForkDetectorStub) GetNotarizedHeaderHash(nonce uint64) []byte + func (fdm *ForkDetectorStub) IsInterfaceNil() bool + func (fdm *ForkDetectorStub) ProbableHighestNonce() uint64 + func (fdm *ForkDetectorStub) RemoveHeader(nonce uint64, hash []byte) + func (fdm *ForkDetectorStub) ResetFork() + func (fdm *ForkDetectorStub) ResetProbableHighestNonce() + func (fdm *ForkDetectorStub) RestoreToGenesis() + func (fdm *ForkDetectorStub) SetFinalToLastCheckpoint() + func (fdm *ForkDetectorStub) SetRollBackNonce(nonce uint64) + type HeaderIntegrityVerifierStub struct + GetVersionCalled func(epoch uint32) string + VerifyCalled func(header data.HeaderHandler) error + func (h *HeaderIntegrityVerifierStub) GetVersion(epoch uint32) string + func (h *HeaderIntegrityVerifierStub) IsInterfaceNil() bool + func (h *HeaderIntegrityVerifierStub) Verify(header data.HeaderHandler) error + type HeaderResolverStub struct + NumPeersToQueryCalled func() (int, int) + ProcessReceivedMessageCalled func(message p2p.MessageP2P) error + RequestDataFromEpochCalled func(identifier []byte) error + RequestDataFromHashCalled func(hash []byte, epoch uint32) error + RequestDataFromNonceCalled func(nonce uint64, epoch uint32) error + SetEpochHandlerCalled func(epochHandler dataRetriever.EpochHandler) error + SetNumPeersToQueryCalled func(intra int, cross int) + SetResolverDebugHandlerCalled func(handler dataRetriever.ResolverDebugHandler) error + func (hrs *HeaderResolverStub) IsInterfaceNil() bool + func (hrs *HeaderResolverStub) NumPeersToQuery() (int, int) + func (hrs *HeaderResolverStub) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error + func (hrs *HeaderResolverStub) RequestDataFromEpoch(identifier []byte) error + func (hrs *HeaderResolverStub) RequestDataFromHash(hash []byte, epoch uint32) error + func (hrs *HeaderResolverStub) RequestDataFromNonce(nonce uint64, epoch uint32) error + func (hrs *HeaderResolverStub) SetEpochHandler(epochHandler dataRetriever.EpochHandler) error + func (hrs *HeaderResolverStub) SetNumPeersToQuery(intra int, cross int) + func (hrs *HeaderResolverStub) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error + type HeaderSigVerifierStub struct + VerifyLeaderSignatureCalled func(header data.HeaderHandler) error + VerifyRandSeedAndLeaderSignatureCalled func(header data.HeaderHandler) error + VerifyRandSeedCalled func(header data.HeaderHandler) error + VerifySignatureCalled func(header data.HeaderHandler) error + func (hsvm *HeaderSigVerifierStub) IsInterfaceNil() bool + func (hsvm *HeaderSigVerifierStub) VerifyLeaderSignature(header data.HeaderHandler) error + func (hsvm *HeaderSigVerifierStub) VerifyRandSeed(header data.HeaderHandler) error + func (hsvm *HeaderSigVerifierStub) VerifyRandSeedAndLeaderSignature(header data.HeaderHandler) error + func (hsvm *HeaderSigVerifierStub) VerifySignature(header data.HeaderHandler) error + type HeaderValidatorStub struct + IsHeaderConstructionValidCalled func(currHdr, prevHdr data.HeaderHandler) error + func (hvs *HeaderValidatorStub) IsHeaderConstructionValid(currHdr, prevHdr data.HeaderHandler) error + func (hvs *HeaderValidatorStub) IsInterfaceNil() bool + type HeartbeatComponentsStub struct + MessageHandlerField heartbeat.MessageHandler + MonitorField factory.HeartbeatMonitor + SenderField factory.HeartbeatSender + StorerField factory.HeartbeatStorer + func (hbc *HeartbeatComponentsStub) CheckSubcomponents() error + func (hbc *HeartbeatComponentsStub) Close() error + func (hbc *HeartbeatComponentsStub) Create() error + func (hbc *HeartbeatComponentsStub) IsInterfaceNil() bool + func (hbc *HeartbeatComponentsStub) MessageHandler() heartbeat.MessageHandler + func (hbc *HeartbeatComponentsStub) Monitor() factory.HeartbeatMonitor + func (hbc *HeartbeatComponentsStub) Sender() factory.HeartbeatSender + func (hbc *HeartbeatComponentsStub) Storer() factory.HeartbeatStorer + func (hbc *HeartbeatComponentsStub) String() string + type HeartbeatV2ComponentsStub struct + MonitorField factory.HeartbeatV2Monitor + func (hbc *HeartbeatV2ComponentsStub) CheckSubcomponents() error + func (hbc *HeartbeatV2ComponentsStub) Close() error + func (hbc *HeartbeatV2ComponentsStub) Create() error + func (hbc *HeartbeatV2ComponentsStub) IsInterfaceNil() bool + func (hbc *HeartbeatV2ComponentsStub) Monitor() factory.HeartbeatV2Monitor + func (hbc *HeartbeatV2ComponentsStub) String() string + type IndexerStub struct + SaveBlockCalled func(args *indexer.ArgsSaveBlockData) + func (im *IndexerStub) Close() error + func (im *IndexerStub) IsInterfaceNil() bool + func (im *IndexerStub) IsNilIndexer() bool + func (im *IndexerStub) RevertIndexedBlock(_ data.HeaderHandler, _ data.BodyHandler) + func (im *IndexerStub) SaveAccounts(_ uint64, _ []state.UserAccountHandler) + func (im *IndexerStub) SaveBlock(args *indexer.ArgsSaveBlockData) + func (im *IndexerStub) SaveRoundsInfo(_ []*indexer.RoundInfo) + func (im *IndexerStub) SaveValidatorsPubKeys(_ map[uint32][][]byte, _ uint32) + func (im *IndexerStub) SaveValidatorsRating(_ string, _ []*indexer.ValidatorRatingInfo) + func (im *IndexerStub) SetTxLogsProcessor(_ process.TransactionLogProcessorDatabase) + type KeyGenMock struct + GeneratePairMock func() (crypto.PrivateKey, crypto.PublicKey) + PrivateKeyFromByteArrayMock func(b []byte) (crypto.PrivateKey, error) + PublicKeyFromByteArrayMock func(b []byte) (crypto.PublicKey, error) + SuiteMock func() crypto.Suite + func (keyGen *KeyGenMock) CheckPublicKeyValid(_ []byte) error + func (keyGen *KeyGenMock) GeneratePair() (crypto.PrivateKey, crypto.PublicKey) + func (keyGen *KeyGenMock) IsInterfaceNil() bool + func (keyGen *KeyGenMock) PrivateKeyFromByteArray(b []byte) (crypto.PrivateKey, error) + func (keyGen *KeyGenMock) PublicKeyFromByteArray(b []byte) (crypto.PublicKey, error) + func (keyGen *KeyGenMock) Suite() crypto.Suite + type KeyLoaderStub struct + LoadKeyCalled func(relativePath string, skIndex int) ([]byte, string, error) + func (kl *KeyLoaderStub) LoadKey(relativePath string, skIndex int) ([]byte, string, error) + type MarshalizerMock struct + Fail bool + func (mm MarshalizerMock) IsInterfaceNil() bool + func (mm MarshalizerMock) Marshal(obj interface{}) ([]byte, error) + func (mm MarshalizerMock) Unmarshal(obj interface{}, buff []byte) error + type MemDbMock struct + func NewMemDbMock() *MemDbMock + func (s *MemDbMock) Close() error + func (s *MemDbMock) Destroy() error + func (s *MemDbMock) DestroyClosed() error + func (s *MemDbMock) Get(key []byte) ([]byte, error) + func (s *MemDbMock) Has(key []byte) error + func (s *MemDbMock) Init() error + func (s *MemDbMock) IsInterfaceNil() bool + func (s *MemDbMock) Put(key, val []byte) error + func (s *MemDbMock) Remove(key []byte) error + type MiniBlocksProviderStub struct + GetMiniBlocksCalled func(hashes [][]byte) ([]*block.MiniblockAndHash, [][]byte) + GetMiniBlocksFromPoolCalled func(hashes [][]byte) ([]*block.MiniblockAndHash, [][]byte) + GetMiniBlocksFromStorerCalled func(hashes [][]byte) ([]*block.MiniblockAndHash, [][]byte) + func (mbps *MiniBlocksProviderStub) GetMiniBlocks(hashes [][]byte) ([]*block.MiniblockAndHash, [][]byte) + func (mbps *MiniBlocksProviderStub) GetMiniBlocksFromPool(hashes [][]byte) ([]*block.MiniblockAndHash, [][]byte) + func (mbps *MiniBlocksProviderStub) GetMiniBlocksFromStorer(hashes [][]byte) ([]*block.MiniblockAndHash, [][]byte) + func (mbps *MiniBlocksProviderStub) IsInterfaceNil() bool + type MultipleShardsCoordinatorMock struct + ComputeIdCalled func(address []byte) uint32 + CurrentShard uint32 + NoShards uint32 + SelfIDCalled func() uint32 + func NewMultiShardsCoordinatorMock(nrShard uint32) *MultipleShardsCoordinatorMock + func (scm *MultipleShardsCoordinatorMock) CommunicationIdentifier(destShardID uint32) string + func (scm *MultipleShardsCoordinatorMock) ComputeId(address []byte) uint32 + func (scm *MultipleShardsCoordinatorMock) IsInterfaceNil() bool + func (scm *MultipleShardsCoordinatorMock) NumberOfShards() uint32 + func (scm *MultipleShardsCoordinatorMock) SameShard(_, _ []byte) bool + func (scm *MultipleShardsCoordinatorMock) SelfId() uint32 + func (scm *MultipleShardsCoordinatorMock) SetNoShards(noShards uint32) + func (scm *MultipleShardsCoordinatorMock) SetSelfId(_ uint32) error + type NetworkComponentsMock struct + InputAntiFlood factory.P2PAntifloodHandler + Messenger p2p.Messenger + OutputAntiFlood factory.P2PAntifloodHandler + PeerBlackList process.PeerBlackListCacher + PeersRatingHandlerField p2p.PeersRatingHandler + PreferredPeersHolder factory.PreferredPeersHolderHandler + func (ncm *NetworkComponentsMock) CheckSubcomponents() error + func (ncm *NetworkComponentsMock) Close() error + func (ncm *NetworkComponentsMock) Create() error + func (ncm *NetworkComponentsMock) InputAntiFloodHandler() factory.P2PAntifloodHandler + func (ncm *NetworkComponentsMock) IsInterfaceNil() bool + func (ncm *NetworkComponentsMock) NetworkMessenger() p2p.Messenger + func (ncm *NetworkComponentsMock) OutputAntiFloodHandler() factory.P2PAntifloodHandler + func (ncm *NetworkComponentsMock) PeerBlackListHandler() process.PeerBlackListCacher + func (ncm *NetworkComponentsMock) PeerHonestyHandler() factory.PeerHonestyHandler + func (ncm *NetworkComponentsMock) PeersRatingHandler() p2p.PeersRatingHandler + func (ncm *NetworkComponentsMock) PreferredPeersHolderHandler() factory.PreferredPeersHolderHandler + func (ncm *NetworkComponentsMock) PubKeyCacher() process.TimeCacher + type NodesSetupStub struct + GetAdaptivityCalled func() bool + GetChainIdCalled func() string + GetHysteresisCalled func() float32 + GetMetaConsensusGroupSizeCalled func() uint32 + GetMinTransactionVersionCalled func() uint32 + GetRoundDurationCalled func() uint64 + GetShardConsensusGroupSizeCalled func() uint32 + GetStartTimeCalled func() int64 + InitialNodesInfoCalled func() (map[uint32][]nodesCoordinator.GenesisNodeInfoHandler, ...) + InitialNodesInfoForShardCalled func(shardId uint32) ([]nodesCoordinator.GenesisNodeInfoHandler, ...) + MinNumberOfMetaNodesCalled func() uint32 + MinNumberOfNodesCalled func() uint32 + MinNumberOfShardNodesCalled func() uint32 + NumberOfShardsCalled func() uint32 + func (n *NodesSetupStub) GetAdaptivity() bool + func (n *NodesSetupStub) GetChainId() string + func (n *NodesSetupStub) GetHysteresis() float32 + func (n *NodesSetupStub) GetMetaConsensusGroupSize() uint32 + func (n *NodesSetupStub) GetMinTransactionVersion() uint32 + func (n *NodesSetupStub) GetRoundDuration() uint64 + func (n *NodesSetupStub) GetShardConsensusGroupSize() uint32 + func (n *NodesSetupStub) GetStartTime() int64 + func (n *NodesSetupStub) InitialNodesInfo() (map[uint32][]nodesCoordinator.GenesisNodeInfoHandler, ...) + func (n *NodesSetupStub) InitialNodesInfoForShard(shardId uint32) ([]nodesCoordinator.GenesisNodeInfoHandler, ...) + func (n *NodesSetupStub) IsInterfaceNil() bool + func (n *NodesSetupStub) MinNumberOfMetaNodes() uint32 + func (n *NodesSetupStub) MinNumberOfNodes() uint32 + func (n *NodesSetupStub) MinNumberOfShardNodes() uint32 + func (n *NodesSetupStub) NumberOfShards() uint32 + type P2PAntifloodHandlerStub struct + ApplyConsensusSizeCalled func(size int) + BlacklistPeerCalled func(peer core.PeerID, reason string, duration time.Duration) + CanProcessMessageCalled func(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + CanProcessMessagesOnTopicCalled func(peer core.PeerID, topic string, numMessages uint32, totalSize uint64, ...) error + IsOriginatorEligibleForTopicCalled func(pid core.PeerID, topic string) error + SetDebuggerCalled func(debugger process.AntifloodDebugger) error + func (p2pahs *P2PAntifloodHandlerStub) ApplyConsensusSize(size int) + func (p2pahs *P2PAntifloodHandlerStub) BlacklistPeer(peer core.PeerID, reason string, duration time.Duration) + func (p2pahs *P2PAntifloodHandlerStub) CanProcessMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + func (p2pahs *P2PAntifloodHandlerStub) CanProcessMessagesOnTopic(peer core.PeerID, topic string, numMessages uint32, totalSize uint64, ...) error + func (p2pahs *P2PAntifloodHandlerStub) Close() error + func (p2pahs *P2PAntifloodHandlerStub) IsInterfaceNil() bool + func (p2pahs *P2PAntifloodHandlerStub) IsOriginatorEligibleForTopic(pid core.PeerID, topic string) error + func (p2pahs *P2PAntifloodHandlerStub) ResetForTopic(_ string) + func (p2pahs *P2PAntifloodHandlerStub) SetDebugger(debugger process.AntifloodDebugger) error + func (p2pahs *P2PAntifloodHandlerStub) SetMaxMessagesForTopic(_ string, _ uint32) + func (p2pahs *P2PAntifloodHandlerStub) SetPeerValidatorMapper(_ process.PeerValidatorMapper) error + func (p2pahs *P2PAntifloodHandlerStub) SetTopicsForAll(_ ...string) + type PeerBlackListHandlerStub struct + HasCalled func(pid core.PeerID) bool + SweepCalled func() + UpsertCalled func(pid core.PeerID, span time.Duration) error + func (pblhs *PeerBlackListHandlerStub) Has(pid core.PeerID) bool + func (pblhs *PeerBlackListHandlerStub) IsInterfaceNil() bool + func (pblhs *PeerBlackListHandlerStub) Sweep() + func (pblhs *PeerBlackListHandlerStub) Upsert(pid core.PeerID, span time.Duration) error + type PeerHonestyHandlerStub struct + ChangeScoreCalled func(pk string, topic string, units int) + func (phhs *PeerHonestyHandlerStub) ChangeScore(pk string, topic string, units int) + func (phhs *PeerHonestyHandlerStub) Close() error + func (phhs *PeerHonestyHandlerStub) IsInterfaceNil() bool + type PeerSignatureHandler struct + func (p *PeerSignatureHandler) GetPeerSignature(_ crypto.PrivateKey, _ []byte) ([]byte, error) + func (p *PeerSignatureHandler) IsInterfaceNil() bool + func (p *PeerSignatureHandler) VerifyPeerSignature(_ []byte, _ core.PeerID, _ []byte) error + type PendingMiniBlocksHandlerStub struct + AddProcessedHeaderCalled func(handler data.HeaderHandler) error + GetPendingMiniBlocksCalled func(shardID uint32) [][]byte + RevertHeaderCalled func(handler data.HeaderHandler) error + SetPendingMiniBlocksCalled func(shardID uint32, mbHashes [][]byte) + func (p *PendingMiniBlocksHandlerStub) AddProcessedHeader(handler data.HeaderHandler) error + func (p *PendingMiniBlocksHandlerStub) GetPendingMiniBlocks(shardID uint32) [][]byte + func (p *PendingMiniBlocksHandlerStub) IsInterfaceNil() bool + func (p *PendingMiniBlocksHandlerStub) RevertHeader(handler data.HeaderHandler) error + func (p *PendingMiniBlocksHandlerStub) SetPendingMiniBlocks(shardID uint32, mbHashes [][]byte) + type PointMock struct + GetUnderlyingObjStub func() interface{} + MarshalBinaryStub func(x, y int) ([]byte, error) + UnmarshalBinaryStub func([]byte) (x, y int, err error) + X int + Y int + func (po *PointMock) Add(_ crypto.Point) (crypto.Point, error) + func (po *PointMock) Base() crypto.Point + func (po *PointMock) Clone() crypto.Point + func (po *PointMock) Equal(p crypto.Point) (bool, error) + func (po *PointMock) GetUnderlyingObj() interface{} + func (po *PointMock) IsInterfaceNil() bool + func (po *PointMock) MarshalBinary() ([]byte, error) + func (po *PointMock) Mul(s crypto.Scalar) (crypto.Point, error) + func (po *PointMock) Neg() crypto.Point + func (po *PointMock) Null() crypto.Point + func (po *PointMock) Pick() (crypto.Point, error) + func (po *PointMock) Set(_ crypto.Point) error + func (po *PointMock) Sub(_ crypto.Point) (crypto.Point, error) + func (po *PointMock) UnmarshalBinary(point []byte) error + type PrivateKeyStub struct + GeneratePublicHandler func() crypto.PublicKey + ScalarHandler func() crypto.Scalar + SuiteHandler func() crypto.Suite + ToByteArrayHandler func() ([]byte, error) + func (sk *PrivateKeyStub) GeneratePublic() crypto.PublicKey + func (sk *PrivateKeyStub) IsInterfaceNil() bool + func (sk *PrivateKeyStub) Scalar() crypto.Scalar + func (sk *PrivateKeyStub) Suite() crypto.Suite + func (sk *PrivateKeyStub) ToByteArray() ([]byte, error) + type ProcessComponentsMock struct + AccountsParserInternal genesis.AccountsParser + BlackListHdl process.TimeCacher + BlockProcess process.BlockProcessor + BlockTrack process.BlockTracker + BootSore process.BootStorer + CurrentEpochProviderInternal process.CurrentNetworkEpochProviderHandler + EpochNotifier factory.EpochStartNotifier + EpochTrigger epochStart.TriggerHandler + FallbackHdrValidator process.FallbackHeaderValidator + ForkDetect process.ForkDetector + HardforkTriggerField factory.HardforkTrigger + HeaderConstructValidator process.HeaderConstructionValidator + HeaderIntegrVerif process.HeaderIntegrityVerifier + HeaderSigVerif process.InterceptedHeaderSigVerifier + HistoryRepositoryInternal dblookupext.HistoryRepository + ImportStartHandlerInternal update.ImportStartHandler + IntContainer process.InterceptorsContainer + NodeRedundancyHandlerInternal consensus.NodeRedundancyHandler + NodesCoord nodesCoordinator.NodesCoordinator + PeerMapper process.NetworkShardingCollector + PendingMiniBlocksHdl process.PendingMiniBlocksHandler + ProcessedMiniBlocksTrackerInternal process.ProcessedMiniBlocksTracker + ReceiptsRepositoryInternal factory.ReceiptsRepository + ReqHandler process.RequestHandler + RequestedItemsHandlerInternal dataRetriever.RequestedItemsHandler + ResFinder dataRetriever.ResolversFinder + RoundHandlerField consensus.RoundHandler + ScheduledTxsExecutionHandlerInternal process.ScheduledTxsExecutionHandler + ShardCoord sharding.Coordinator + TxLogsProcess process.TransactionLogProcessorDatabase + TxSimulatorProcessor factory.TransactionSimulatorProcessor + TxsSenderHandlerField process.TxsSenderHandler + ValidatorProvider process.ValidatorsProvider + ValidatorStatistics process.ValidatorStatisticsProcessor + WhiteListHandlerInternal process.WhiteListHandler + WhiteListerVerifiedTxsInternal process.WhiteListHandler + func (pcm *ProcessComponentsMock) AccountsParser() genesis.AccountsParser + func (pcm *ProcessComponentsMock) BlackListHandler() process.TimeCacher + func (pcm *ProcessComponentsMock) BlockProcessor() process.BlockProcessor + func (pcm *ProcessComponentsMock) BlockTracker() process.BlockTracker + func (pcm *ProcessComponentsMock) BootStorer() process.BootStorer + func (pcm *ProcessComponentsMock) CheckSubcomponents() error + func (pcm *ProcessComponentsMock) Close() error + func (pcm *ProcessComponentsMock) Create() error + func (pcm *ProcessComponentsMock) CurrentEpochProvider() process.CurrentNetworkEpochProviderHandler + func (pcm *ProcessComponentsMock) EpochStartNotifier() factory.EpochStartNotifier + func (pcm *ProcessComponentsMock) EpochStartTrigger() epochStart.TriggerHandler + func (pcm *ProcessComponentsMock) FallbackHeaderValidator() process.FallbackHeaderValidator + func (pcm *ProcessComponentsMock) ForkDetector() process.ForkDetector + func (pcm *ProcessComponentsMock) HardforkTrigger() factory.HardforkTrigger + func (pcm *ProcessComponentsMock) HeaderConstructionValidator() process.HeaderConstructionValidator + func (pcm *ProcessComponentsMock) HeaderIntegrityVerifier() process.HeaderIntegrityVerifier + func (pcm *ProcessComponentsMock) HeaderSigVerifier() process.InterceptedHeaderSigVerifier + func (pcm *ProcessComponentsMock) HistoryRepository() dblookupext.HistoryRepository + func (pcm *ProcessComponentsMock) ImportStartHandler() update.ImportStartHandler + func (pcm *ProcessComponentsMock) InterceptorsContainer() process.InterceptorsContainer + func (pcm *ProcessComponentsMock) IsInterfaceNil() bool + func (pcm *ProcessComponentsMock) NodeRedundancyHandler() consensus.NodeRedundancyHandler + func (pcm *ProcessComponentsMock) NodesCoordinator() nodesCoordinator.NodesCoordinator + func (pcm *ProcessComponentsMock) PeerShardMapper() process.NetworkShardingCollector + func (pcm *ProcessComponentsMock) PendingMiniBlocksHandler() process.PendingMiniBlocksHandler + func (pcm *ProcessComponentsMock) ProcessedMiniBlocksTracker() process.ProcessedMiniBlocksTracker + func (pcm *ProcessComponentsMock) ReceiptsRepository() factory.ReceiptsRepository + func (pcm *ProcessComponentsMock) RequestHandler() process.RequestHandler + func (pcm *ProcessComponentsMock) RequestedItemsHandler() dataRetriever.RequestedItemsHandler + func (pcm *ProcessComponentsMock) ResolversFinder() dataRetriever.ResolversFinder + func (pcm *ProcessComponentsMock) RoundHandler() consensus.RoundHandler + func (pcm *ProcessComponentsMock) ScheduledTxsExecutionHandler() process.ScheduledTxsExecutionHandler + func (pcm *ProcessComponentsMock) ShardCoordinator() sharding.Coordinator + func (pcm *ProcessComponentsMock) String() string + func (pcm *ProcessComponentsMock) TransactionSimulatorProcessor() factory.TransactionSimulatorProcessor + func (pcm *ProcessComponentsMock) TxLogsProcessor() process.TransactionLogProcessorDatabase + func (pcm *ProcessComponentsMock) TxsSenderHandler() process.TxsSenderHandler + func (pcm *ProcessComponentsMock) ValidatorsProvider() process.ValidatorsProvider + func (pcm *ProcessComponentsMock) ValidatorsStatistics() process.ValidatorStatisticsProcessor + func (pcm *ProcessComponentsMock) WhiteListHandler() process.WhiteListHandler + func (pcm *ProcessComponentsMock) WhiteListerVerifiedTxs() process.WhiteListHandler + type PubkeyConverterStub struct + DecodeCalled func(humanReadable string) ([]byte, error) + EncodeCalled func(pkBytes []byte) string + LenCalled func() int + func (pcs *PubkeyConverterStub) Decode(humanReadable string) ([]byte, error) + func (pcs *PubkeyConverterStub) Encode(pkBytes []byte) string + func (pcs *PubkeyConverterStub) IsInterfaceNil() bool + func (pcs *PubkeyConverterStub) Len() int + type PublicKeyMock struct + PointCalled func() crypto.Point + SuiteCalled func() crypto.Suite + ToByteArrayHandler func() ([]byte, error) + func (sspk *PublicKeyMock) IsInterfaceNil() bool + func (sspk *PublicKeyMock) Point() crypto.Point + func (sspk *PublicKeyMock) Suite() crypto.Suite + func (sspk *PublicKeyMock) ToByteArray() ([]byte, error) + type RedundancyHandlerStub struct + AdjustInactivityIfNeededCalled func(selfPubKey string, consensusPubKeys []string, roundIndex int64) + IsMainMachineActiveCalled func() bool + IsRedundancyNodeCalled func() bool + ObserverPrivateKeyCalled func() crypto.PrivateKey + ResetInactivityIfNeededCalled func(selfPubKey string, consensusMsgPubKey string, consensusMsgPeerID core.PeerID) + func (rhs *RedundancyHandlerStub) AdjustInactivityIfNeeded(selfPubKey string, consensusPubKeys []string, roundIndex int64) + func (rhs *RedundancyHandlerStub) IsInterfaceNil() bool + func (rhs *RedundancyHandlerStub) IsMainMachineActive() bool + func (rhs *RedundancyHandlerStub) IsRedundancyNode() bool + func (rhs *RedundancyHandlerStub) ObserverPrivateKey() crypto.PrivateKey + func (rhs *RedundancyHandlerStub) ResetInactivityIfNeeded(selfPubKey string, consensusMsgPubKey string, consensusMsgPeerID core.PeerID) + type ResolversFinderStub struct + AddCalled func(key string, val dataRetriever.Resolver) error + CloseCalled func() error + CrossShardResolverCalled func(baseTopic string, crossShard uint32) (dataRetriever.Resolver, error) + GetCalled func(key string) (dataRetriever.Resolver, error) + IntraShardResolverCalled func(baseTopic string) (dataRetriever.Resolver, error) + IterateCalled func(handler func(key string, resolver dataRetriever.Resolver) bool) + LenCalled func() int + MetaChainResolverCalled func(baseTopic string) (dataRetriever.Resolver, error) + MetaCrossShardResolverCalled func(baseTopic string, crossShard uint32) (dataRetriever.Resolver, error) + RemoveCalled func(key string) + ReplaceCalled func(key string, val dataRetriever.Resolver) error + ResolverKeysCalled func() string + func (rfs *ResolversFinderStub) Add(key string, val dataRetriever.Resolver) error + func (rfs *ResolversFinderStub) AddMultiple(_ []string, _ []dataRetriever.Resolver) error + func (rfs *ResolversFinderStub) Close() error + func (rfs *ResolversFinderStub) CrossShardResolver(baseTopic string, crossShard uint32) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) Get(key string) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) IntraShardResolver(baseTopic string) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) IsInterfaceNil() bool + func (rfs *ResolversFinderStub) Iterate(handler func(key string, resolver dataRetriever.Resolver) bool) + func (rfs *ResolversFinderStub) Len() int + func (rfs *ResolversFinderStub) MetaChainResolver(baseTopic string) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) MetaCrossShardResolver(baseTopic string, crossShard uint32) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) Remove(key string) + func (rfs *ResolversFinderStub) Replace(key string, val dataRetriever.Resolver) error + func (rfs *ResolversFinderStub) ResolverKeys() string + type RoundHandlerMock struct + RoundIndex int64 + RoundTimeDuration time.Duration + RoundTimeStamp time.Time + func (rndm *RoundHandlerMock) BeforeGenesis() bool + func (rndm *RoundHandlerMock) Index() int64 + func (rndm *RoundHandlerMock) IsInterfaceNil() bool + func (rndm *RoundHandlerMock) RemainingTime(_ time.Time, _ time.Duration) time.Duration + func (rndm *RoundHandlerMock) TimeDuration() time.Duration + func (rndm *RoundHandlerMock) TimeStamp() time.Time + func (rndm *RoundHandlerMock) UpdateRound(genesisRoundTimeStamp time.Time, timeStamp time.Time) + type ScalarMock struct + GetUnderlyingObjStub func() interface{} + MarshalBinaryStub func(x int) ([]byte, error) + UnmarshalBinaryStub func([]byte) (int, error) + X int + func (sm *ScalarMock) Add(_ crypto.Scalar) (crypto.Scalar, error) + func (sm *ScalarMock) Clone() crypto.Scalar + func (sm *ScalarMock) Div(_ crypto.Scalar) (crypto.Scalar, error) + func (sm *ScalarMock) Equal(_ crypto.Scalar) (bool, error) + func (sm *ScalarMock) GetUnderlyingObj() interface{} + func (sm *ScalarMock) Inv(_ crypto.Scalar) (crypto.Scalar, error) + func (sm *ScalarMock) IsInterfaceNil() bool + func (sm *ScalarMock) MarshalBinary() ([]byte, error) + func (sm *ScalarMock) Mul(_ crypto.Scalar) (crypto.Scalar, error) + func (sm *ScalarMock) Neg() crypto.Scalar + func (sm *ScalarMock) One() crypto.Scalar + func (sm *ScalarMock) Pick() (crypto.Scalar, error) + func (sm *ScalarMock) Set(_ crypto.Scalar) error + func (sm *ScalarMock) SetBytes([]byte) (crypto.Scalar, error) + func (sm *ScalarMock) SetInt64(_ int64) + func (sm *ScalarMock) Sub(_ crypto.Scalar) (crypto.Scalar, error) + func (sm *ScalarMock) UnmarshalBinary(val []byte) error + func (sm *ScalarMock) Zero() crypto.Scalar + type SinglesignFailMock struct + func (s *SinglesignFailMock) IsInterfaceNil() bool + func (s *SinglesignFailMock) Sign(_ crypto.PrivateKey, _ []byte) ([]byte, error) + func (s *SinglesignFailMock) Verify(_ crypto.PublicKey, _ []byte, _ []byte) error + type SinglesignMock struct + func (s *SinglesignMock) IsInterfaceNil() bool + func (s *SinglesignMock) Sign(_ crypto.PrivateKey, _ []byte) ([]byte, error) + func (s *SinglesignMock) Verify(_ crypto.PublicKey, _ []byte, sig []byte) error + type SinglesignStub struct + SignCalled func(private crypto.PrivateKey, msg []byte) ([]byte, error) + VerifyCalled func(public crypto.PublicKey, msg []byte, sig []byte) error + func (s *SinglesignStub) IsInterfaceNil() bool + func (s *SinglesignStub) Sign(private crypto.PrivateKey, msg []byte) ([]byte, error) + func (s *SinglesignStub) Verify(public crypto.PublicKey, msg []byte, sig []byte) error + type SmartContractParserStub struct + GetDeployedSCAddressesCalled func(scType string) (map[string]struct{}, error) + InitialSmartContractsCalled func() []genesis.InitialSmartContractHandler + InitialSmartContractsSplitOnOwnersShardsCalled func(shardCoordinator sharding.Coordinator) (map[uint32][]genesis.InitialSmartContractHandler, error) + func (scps *SmartContractParserStub) GetDeployedSCAddresses(scType string) (map[string]struct{}, error) + func (scps *SmartContractParserStub) InitialSmartContracts() []genesis.InitialSmartContractHandler + func (scps *SmartContractParserStub) InitialSmartContractsSplitOnOwnersShards(shardCoordinator sharding.Coordinator) (map[uint32][]genesis.InitialSmartContractHandler, error) + func (scps *SmartContractParserStub) IsInterfaceNil() bool + type StateComponentsHolderStub struct + AccountsAdapterAPICalled func() state.AccountsAdapter + AccountsAdapterCalled func() state.AccountsAdapter + AccountsRepositoryCalled func() state.AccountsRepository + PeerAccountsCalled func() state.AccountsAdapter + TrieStorageManagersCalled func() map[string]common.StorageManager + TriesContainerCalled func() common.TriesHolder + func (s *StateComponentsHolderStub) AccountsAdapter() state.AccountsAdapter + func (s *StateComponentsHolderStub) AccountsAdapterAPI() state.AccountsAdapter + func (s *StateComponentsHolderStub) AccountsRepository() state.AccountsRepository + func (s *StateComponentsHolderStub) IsInterfaceNil() bool + func (s *StateComponentsHolderStub) PeerAccounts() state.AccountsAdapter + func (s *StateComponentsHolderStub) TrieStorageManagers() map[string]common.StorageManager + func (s *StateComponentsHolderStub) TriesContainer() common.TriesHolder + type Streamer struct + func NewStreamer() *Streamer + func (stream *Streamer) XORKeyStream(dst, src []byte) + type SuiteStub struct + CreateKeyPairStub func() (crypto.Scalar, crypto.Point) + CreatePointForScalarStub func(scalar crypto.Scalar) (crypto.Point, error) + CreatePointStub func() crypto.Point + CreateScalarStub func() crypto.Scalar + GetUnderlyingSuiteStub func() interface{} + IsPointValidStub func([]byte) error + PointLenStub func() int + RandomStreamStub func() cipher.Stream + ScalarLenStub func() int + StringStub func() string + func (s *SuiteStub) CheckPointValid(pointBytes []byte) error + func (s *SuiteStub) CreateKeyPair() (crypto.Scalar, crypto.Point) + func (s *SuiteStub) CreatePoint() crypto.Point + func (s *SuiteStub) CreatePointForScalar(scalar crypto.Scalar) (crypto.Point, error) + func (s *SuiteStub) CreateScalar() crypto.Scalar + func (s *SuiteStub) GetUnderlyingSuite() interface{} + func (s *SuiteStub) IsInterfaceNil() bool + func (s *SuiteStub) PointLen() int + func (s *SuiteStub) RandomStream() cipher.Stream + func (s *SuiteStub) ScalarLen() int + func (s *SuiteStub) String() string + type TriesHolderStub struct + GetAllCalled func() []common.Trie + GetCalled func([]byte) common.Trie + PutCalled func([]byte, common.Trie) + RemoveCalled func([]byte, common.Trie) + ResetCalled func() + func (ths *TriesHolderStub) Get(key []byte) common.Trie + func (ths *TriesHolderStub) GetAll() []common.Trie + func (ths *TriesHolderStub) IsInterfaceNil() bool + func (ths *TriesHolderStub) Put(key []byte, trie common.Trie) + func (ths *TriesHolderStub) Replace(key []byte, trie common.Trie) + func (ths *TriesHolderStub) Reset() + type TxLogProcessorMock struct + func (t *TxLogProcessorMock) Clean() + func (t *TxLogProcessorMock) EnableLogToBeSavedInCache() + func (t *TxLogProcessorMock) GetLogFromCache(_ []byte) (*data.LogData, bool) + func (t *TxLogProcessorMock) IsInterfaceNil() bool + type ValidatorStatisticsProcessorStub struct + CommitCalled func() ([]byte, error) + GetPeerAccountCalled func(address []byte) (state.PeerAccountHandler, error) + GetValidatorInfoForRootHashCalled func(rootHash []byte) (map[uint32][]*state.ValidatorInfo, error) + PeerAccountToValidatorInfoCalled func(peerAccount state.PeerAccountHandler) *state.ValidatorInfo + ProcessCalled func(validatorInfo data.ShardValidatorInfoHandler) error + ProcessRatingsEndOfEpochCalled func(validatorInfos map[uint32][]*state.ValidatorInfo, epoch uint32) error + ResetValidatorStatisticsAtNewEpochCalled func(vInfos map[uint32][]*state.ValidatorInfo) error + RevertPeerStateCalled func(header data.MetaHeaderHandler) error + RootHashCalled func() ([]byte, error) + SaveNodesCoordinatorUpdatesCalled func(epoch uint32) (bool, error) + UpdatePeerStateCalled func(header data.MetaHeaderHandler) ([]byte, error) + func (vsp *ValidatorStatisticsProcessorStub) Commit() ([]byte, error) + func (vsp *ValidatorStatisticsProcessorStub) DisplayRatings(_ uint32) + func (vsp *ValidatorStatisticsProcessorStub) GetPeerAccount(address []byte) (state.PeerAccountHandler, error) + func (vsp *ValidatorStatisticsProcessorStub) GetValidatorInfoForRootHash(rootHash []byte) (map[uint32][]*state.ValidatorInfo, error) + func (vsp *ValidatorStatisticsProcessorStub) IsInterfaceNil() bool + func (vsp *ValidatorStatisticsProcessorStub) LastFinalizedRootHash() []byte + func (vsp *ValidatorStatisticsProcessorStub) PeerAccountToValidatorInfo(peerAccount state.PeerAccountHandler) *state.ValidatorInfo + func (vsp *ValidatorStatisticsProcessorStub) Process(validatorInfo data.ShardValidatorInfoHandler) error + func (vsp *ValidatorStatisticsProcessorStub) ProcessRatingsEndOfEpoch(validatorInfos map[uint32][]*state.ValidatorInfo, epoch uint32) error + func (vsp *ValidatorStatisticsProcessorStub) ResetValidatorStatisticsAtNewEpoch(vInfos map[uint32][]*state.ValidatorInfo) error + func (vsp *ValidatorStatisticsProcessorStub) RevertPeerState(header data.MetaHeaderHandler) error + func (vsp *ValidatorStatisticsProcessorStub) RootHash() ([]byte, error) + func (vsp *ValidatorStatisticsProcessorStub) SaveNodesCoordinatorUpdates(epoch uint32) (bool, error) + func (vsp *ValidatorStatisticsProcessorStub) SetLastFinalizedRootHash(_ []byte) + func (vsp *ValidatorStatisticsProcessorStub) UpdatePeerState(header data.MetaHeaderHandler, _ map[string]data.HeaderHandler) ([]byte, error) + type ValidatorsProviderStub struct + GetLatestValidatorsCalled func() map[string]*state.ValidatorApiResponse + func (vp *ValidatorsProviderStub) Close() error + func (vp *ValidatorsProviderStub) GetLatestValidators() map[string]*state.ValidatorApiResponse + func (vp *ValidatorsProviderStub) IsInterfaceNil() bool