Versions in this module Expand all Collapse all v1 v1.999.0 Nov 17, 2022 Changes in this version + func NewAccumulatorMock() *accumulatorMock + func NewMultiShardsCoordinatorMock(nrShard uint32) *multipleShardsCoordinatorMock + func NewNonceHashConverterMock() *nonceHashConverterMock + func NewOneShardCoordinatorMock() *oneShardCoordinatorMock + type AccountWrapMock struct + MockValue int + SetCodeHashWithJournalCalled func(codeHash []byte) error + SetCodeWithJournalCalled func(codeHash []byte) error + SetNonceWithJournalCalled func(nonce uint64) error + func (awm *AccountWrapMock) AddToBalance(_ *big.Int) error + func (awm *AccountWrapMock) AddToDeveloperReward(*big.Int) + func (awm *AccountWrapMock) AddressBytes() []byte + func (awm *AccountWrapMock) ChangeOwnerAddress([]byte, []byte) error + func (awm *AccountWrapMock) ClaimDeveloperRewards([]byte) (*big.Int, error) + func (awm *AccountWrapMock) DataTrie() common.Trie + func (awm *AccountWrapMock) DataTrieTracker() state.DataTrieTracker + func (awm *AccountWrapMock) GetBalance() *big.Int + func (awm *AccountWrapMock) GetCodeHash() []byte + func (awm *AccountWrapMock) GetCodeMetadata() []byte + func (awm *AccountWrapMock) GetDeveloperReward() *big.Int + func (awm *AccountWrapMock) GetNonce() uint64 + func (awm *AccountWrapMock) GetOwnerAddress() []byte + func (awm *AccountWrapMock) GetRootHash() []byte + func (awm *AccountWrapMock) GetUserName() []byte + func (awm *AccountWrapMock) HasNewCode() bool + func (awm *AccountWrapMock) IncreaseNonce(val uint64) + func (awm *AccountWrapMock) IsInterfaceNil() bool + func (awm *AccountWrapMock) RetrieveValueFromDataTrieTracker(key []byte) ([]byte, error) + func (awm *AccountWrapMock) SetCode(code []byte) + func (awm *AccountWrapMock) SetCodeHash(codeHash []byte) + func (awm *AccountWrapMock) SetCodeMetadata(codeMetadata []byte) + func (awm *AccountWrapMock) SetDataTrie(trie common.Trie) + func (awm *AccountWrapMock) SetOwnerAddress([]byte) + func (awm *AccountWrapMock) SetRootHash(rootHash []byte) + func (awm *AccountWrapMock) SetTrackableDataTrie(tdt state.DataTrieTracker) + func (awm *AccountWrapMock) SetUserName(_ []byte) + func (awm *AccountWrapMock) SubFromBalance(_ *big.Int) error + 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 BlockAPIHandlerStub struct + GetBlockByHashCalled func(hash []byte, options api.BlockQueryOptions) (*api.Block, error) + GetBlockByNonceCalled func(nonce uint64, options api.BlockQueryOptions) (*api.Block, error) + GetBlockByRoundCalled func(round uint64, options api.BlockQueryOptions) (*api.Block, error) + func (bah *BlockAPIHandlerStub) GetBlockByHash(hash []byte, options api.BlockQueryOptions) (*api.Block, error) + func (bah *BlockAPIHandlerStub) GetBlockByNonce(nonce uint64, options api.BlockQueryOptions) (*api.Block, error) + func (bah *BlockAPIHandlerStub) GetBlockByRound(round uint64, options api.BlockQueryOptions) (*api.Block, error) + func (bah *BlockAPIHandlerStub) 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() + RevertIndexedBlockCalled func(header data.HeaderHandler) + 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) RevertIndexedBlock(header data.HeaderHandler) + 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 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 CloserStub struct + CloseCalled func() error + func (c *CloserStub) Close() error + type DelegatedListProcessorStub struct + GetDelegatorsListCalled func(ctx context.Context) ([]*api.Delegator, error) + func (dlps *DelegatedListProcessorStub) GetDelegatorsList(ctx context.Context) ([]*api.Delegator, error) + func (dlps *DelegatedListProcessorStub) IsInterfaceNil() bool + type DirectStakedListProcessorStub struct + GetDirectStakedListCalled func(ctx context.Context) ([]*api.DirectStakedValue, error) + func (dslps *DirectStakedListProcessorStub) GetDirectStakedList(ctx context.Context) ([]*api.DirectStakedValue, error) + func (dslps *DirectStakedListProcessorStub) IsInterfaceNil() bool + type EconomicsHandlerStub struct + CheckValidityTxValuesCalled func(tx data.TransactionWithFeeHandler) error + ComputeFeeForProcessingCalled func(tx data.TransactionWithFeeHandler, gasToUse uint64) *big.Int + ComputeGasLimitBasedOnBalanceCalled func(tx data.TransactionWithFeeHandler, balance *big.Int) (uint64, error) + ComputeGasLimitCalled func(tx data.TransactionWithFeeHandler) uint64 + ComputeGasUsedAndFeeBasedOnRefundValueCalled func(tx data.TransactionWithFeeHandler, refundValue *big.Int) (uint64, *big.Int) + ComputeMoveBalanceFeeCalled func(tx data.TransactionWithFeeHandler) *big.Int + ComputeTxFeeBasedOnGasUsedCalled func(tx data.TransactionWithFeeHandler, gasUsed uint64) *big.Int + ComputeTxFeeCalled func(tx data.TransactionWithFeeHandler) *big.Int + DeveloperPercentageCalled func() float64 + GasPriceForMoveCalled func(tx data.TransactionWithFeeHandler) uint64 + GasPriceForProcessingCalled func(tx data.TransactionWithFeeHandler) uint64 + GasPriceModifierCalled func() float64 + GenesisTotalSupplyCalled func() *big.Int + LeaderPercentageCalled func() float64 + MaxGasLimitPerBlockCalled func() uint64 + MaxGasLimitPerBlockForSafeCrossShardCalled func() uint64 + MaxGasLimitPerMiniBlockCalled func() uint64 + MaxGasLimitPerMiniBlockForSafeCrossShardCalled func() uint64 + MaxGasLimitPerTxCalled func() uint64 + MaxInflationRateCalled func(year uint32) float64 + MinGasPriceCalled func() uint64 + MinGasPriceForProcessingCalled func() uint64 + MinInflationRateCalled func() float64 + ProtocolSustainabilityAddressCalled func() string + ProtocolSustainabilityPercentageCalled func() float64 + RewardsTopUpFactorCalled func() float64 + RewardsTopUpGradientPointCalled func() *big.Int + SetMinGasLimitCalled func(minGasLimit uint64) + SetMinGasPriceCalled func(minGasPrice uint64) + SplitTxGasInCategoriesCalled func(tx data.TransactionWithFeeHandler) (uint64, uint64) + func (ehs *EconomicsHandlerStub) CheckValidityTxValues(tx data.TransactionWithFeeHandler) error + func (ehs *EconomicsHandlerStub) ComputeFeeForProcessing(tx data.TransactionWithFeeHandler, gasToUse uint64) *big.Int + func (ehs *EconomicsHandlerStub) ComputeGasLimit(tx data.TransactionWithFeeHandler) uint64 + func (ehs *EconomicsHandlerStub) ComputeGasLimitBasedOnBalance(tx data.TransactionWithFeeHandler, balance *big.Int) (uint64, error) + func (ehs *EconomicsHandlerStub) ComputeGasUsedAndFeeBasedOnRefundValue(tx data.TransactionWithFeeHandler, refundValue *big.Int) (uint64, *big.Int) + func (ehs *EconomicsHandlerStub) ComputeMoveBalanceFee(tx data.TransactionWithFeeHandler) *big.Int + func (ehs *EconomicsHandlerStub) ComputeTxFee(tx data.TransactionWithFeeHandler) *big.Int + func (ehs *EconomicsHandlerStub) ComputeTxFeeBasedOnGasUsed(tx data.TransactionWithFeeHandler, gasUsed uint64) *big.Int + func (ehs *EconomicsHandlerStub) DeveloperPercentage() float64 + func (ehs *EconomicsHandlerStub) GasPerDataByte() uint64 + func (ehs *EconomicsHandlerStub) GasPriceForMove(tx data.TransactionWithFeeHandler) uint64 + func (ehs *EconomicsHandlerStub) GasPriceForProcessing(tx data.TransactionWithFeeHandler) uint64 + func (ehs *EconomicsHandlerStub) GasPriceModifier() float64 + func (ehs *EconomicsHandlerStub) GenesisTotalSupply() *big.Int + func (ehs *EconomicsHandlerStub) IsInterfaceNil() bool + func (ehs *EconomicsHandlerStub) LeaderPercentage() float64 + func (ehs *EconomicsHandlerStub) MaxGasLimitPerBlock(uint32) uint64 + func (ehs *EconomicsHandlerStub) MaxGasLimitPerBlockForSafeCrossShard() uint64 + func (ehs *EconomicsHandlerStub) MaxGasLimitPerMiniBlock(uint32) uint64 + func (ehs *EconomicsHandlerStub) MaxGasLimitPerMiniBlockForSafeCrossShard() uint64 + func (ehs *EconomicsHandlerStub) MaxGasLimitPerTx() uint64 + func (ehs *EconomicsHandlerStub) MaxInflationRate(year uint32) float64 + func (ehs *EconomicsHandlerStub) MinGasLimit() uint64 + func (ehs *EconomicsHandlerStub) MinGasPrice() uint64 + func (ehs *EconomicsHandlerStub) MinGasPriceForProcessing() uint64 + func (ehs *EconomicsHandlerStub) MinInflationRate() float64 + func (ehs *EconomicsHandlerStub) ProtocolSustainabilityAddress() string + func (ehs *EconomicsHandlerStub) ProtocolSustainabilityPercentage() float64 + func (ehs *EconomicsHandlerStub) RewardsTopUpFactor() float64 + func (ehs *EconomicsHandlerStub) RewardsTopUpGradientPoint() *big.Int + func (ehs *EconomicsHandlerStub) SplitTxGasInCategories(tx data.TransactionWithFeeHandler) (uint64, uint64) + 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) 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) 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) SetFinalityAttestingRound(_ uint64) + func (e *EpochStartTriggerStub) SetProcessed(header data.HeaderHandler, _ data.BodyHandler) + func (e *EpochStartTriggerStub) Update(round uint64, nonce uint64) + type EsdtStorageHandlerStub struct + AddToLiquiditySystemAccCalled func(esdtTokenKey []byte, nonce uint64, transferValue *big.Int) error + GetESDTNFTTokenOnDestinationCalled func(acnt vmcommon.UserAccountHandler, esdtTokenKey []byte, nonce uint64) (*esdt.ESDigitalToken, bool, error) + GetESDTNFTTokenOnSenderCalled func(acnt vmcommon.UserAccountHandler, esdtTokenKey []byte, nonce uint64) (*esdt.ESDigitalToken, error) + SaveESDTNFTTokenCalled func(senderAddress []byte, acnt vmcommon.UserAccountHandler, esdtTokenKey []byte, ...) ([]byte, error) + SaveNFTMetaDataToSystemAccountCalled func(tx data.TransactionHandler) error + WasAlreadySentToDestinationShardAndUpdateStateCalled func(tickerID []byte, nonce uint64, dstAddress []byte) (bool, error) + func (e *EsdtStorageHandlerStub) AddToLiquiditySystemAcc(esdtTokenKey []byte, nonce uint64, transferValue *big.Int) error + func (e *EsdtStorageHandlerStub) GetESDTNFTTokenOnDestination(acnt vmcommon.UserAccountHandler, esdtTokenKey []byte, nonce uint64) (*esdt.ESDigitalToken, bool, error) + func (e *EsdtStorageHandlerStub) GetESDTNFTTokenOnSender(acnt vmcommon.UserAccountHandler, esdtTokenKey []byte, nonce uint64) (*esdt.ESDigitalToken, error) + func (e *EsdtStorageHandlerStub) IsInterfaceNil() bool + func (e *EsdtStorageHandlerStub) SaveESDTNFTToken(senderAddress []byte, acnt vmcommon.UserAccountHandler, esdtTokenKey []byte, ...) ([]byte, error) + func (e *EsdtStorageHandlerStub) SaveNFTMetaDataToSystemAccount(tx data.TransactionHandler) error + func (e *EsdtStorageHandlerStub) WasAlreadySentToDestinationShardAndUpdateState(tickerID []byte, nonce uint64, dstAddress []byte) (bool, error) + 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 GeneratorSuite struct + CreateKeyStub func(cipher.Stream) crypto.Scalar + func (gs *GeneratorSuite) CreateKey(c cipher.Stream) crypto.Scalar + type HasherFake struct + func (HasherFake) Size() int + func (sha *HasherFake) IsInterfaceNil() bool + func (sha HasherFake) Compute(s string) []byte + func (sha HasherFake) EmptyHash() []byte + type HasherMock struct + ComputeCalled func(s string) []byte + EmptyHashCalled func() []byte + func (HasherMock) Size() int + func (hash HasherMock) Compute(s string) []byte + func (hash HasherMock) EmptyHash() []byte + func (hash HasherMock) IsInterfaceNil() bool + 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 + CloseCalled func() error + 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) Close() 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 HeadersCacherStub struct + AddCalled func(headerHash []byte, header data.HeaderHandler) + ClearCalled func() + GetHeaderByHashCalled func(hash []byte) (data.HeaderHandler, error) + GetHeaderByNonceAndShardIdCalled func(hdrNonce uint64, shardId uint32) ([]data.HeaderHandler, [][]byte, error) + GetNumHeadersCalled func(shardId uint32) int + LenCalled func() int + MaxSizeCalled func() int + NoncesCalled func(shardId uint32) []uint64 + RegisterHandlerCalled func(handler func(header data.HeaderHandler, shardHeaderHash []byte)) + RemoveHeaderByHashCalled func(headerHash []byte) + RemoveHeaderByNonceAndShardIdCalled func(hdrNonce uint64, shardId uint32) + func (hcs *HeadersCacherStub) AddHeader(headerHash []byte, header data.HeaderHandler) + func (hcs *HeadersCacherStub) Clear() + func (hcs *HeadersCacherStub) GetHeaderByHash(hash []byte) (data.HeaderHandler, error) + func (hcs *HeadersCacherStub) GetHeadersByNonceAndShardId(hdrNonce uint64, shardId uint32) ([]data.HeaderHandler, [][]byte, error) + func (hcs *HeadersCacherStub) GetNumHeaders(shardId uint32) int + func (hcs *HeadersCacherStub) IsInterfaceNil() bool + func (hcs *HeadersCacherStub) Len() int + func (hcs *HeadersCacherStub) MaxSize() int + func (hcs *HeadersCacherStub) Nonces(shardId uint32) []uint64 + func (hcs *HeadersCacherStub) RegisterHandler(handler func(header data.HeaderHandler, shardHeaderHash []byte)) + func (hcs *HeadersCacherStub) RemoveHeaderByHash(headerHash []byte) + func (hcs *HeadersCacherStub) RemoveHeaderByNonceAndShardId(hdrNonce uint64, shardId uint32) + 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 InternalBlockApiHandlerStub struct + GetInternalMetaBlockByHashCalled func(format common.ApiOutputFormat, hash []byte) (interface{}, error) + GetInternalMetaBlockByNonceCalled func(format common.ApiOutputFormat, nonce uint64) (interface{}, error) + GetInternalMetaBlockByRoundCalled func(format common.ApiOutputFormat, round uint64) (interface{}, error) + GetInternalMiniBlockCalled func(format common.ApiOutputFormat, hash []byte, epoch uint32) (interface{}, error) + GetInternalShardBlockByHashCalled func(format common.ApiOutputFormat, hash []byte) (interface{}, error) + GetInternalShardBlockByNonceCalled func(format common.ApiOutputFormat, nonce uint64) (interface{}, error) + GetInternalShardBlockByRoundCalled func(format common.ApiOutputFormat, round uint64) (interface{}, error) + GetInternalStartOfEpochMetaBlockCalled func(format common.ApiOutputFormat, epoch uint32) (interface{}, error) + func (ibah *InternalBlockApiHandlerStub) GetInternalMetaBlockByHash(format common.ApiOutputFormat, hash []byte) (interface{}, error) + func (ibah *InternalBlockApiHandlerStub) GetInternalMetaBlockByNonce(format common.ApiOutputFormat, nonce uint64) (interface{}, error) + func (ibah *InternalBlockApiHandlerStub) GetInternalMetaBlockByRound(format common.ApiOutputFormat, round uint64) (interface{}, error) + func (ibah *InternalBlockApiHandlerStub) GetInternalMiniBlock(format common.ApiOutputFormat, hash []byte, epoch uint32) (interface{}, error) + func (ibah *InternalBlockApiHandlerStub) GetInternalShardBlockByHash(format common.ApiOutputFormat, hash []byte) (interface{}, error) + func (ibah *InternalBlockApiHandlerStub) GetInternalShardBlockByNonce(format common.ApiOutputFormat, nonce uint64) (interface{}, error) + func (ibah *InternalBlockApiHandlerStub) GetInternalShardBlockByRound(format common.ApiOutputFormat, round uint64) (interface{}, error) + func (ibah *InternalBlockApiHandlerStub) GetInternalStartOfEpochMetaBlock(format common.ApiOutputFormat, epoch uint32) (interface{}, error) + func (ibah *InternalBlockApiHandlerStub) IsInterfaceNil() bool + 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 MarshalizerFake struct + Fail bool + func (mm *MarshalizerFake) IsInterfaceNil() bool + func (mm *MarshalizerFake) Marshal(obj interface{}) ([]byte, error) + func (mm *MarshalizerFake) Unmarshal(obj interface{}, buff []byte) error + type MarshalizerMock struct + MarshalHandler func(obj interface{}) ([]byte, error) + UnmarshalHandler func(obj interface{}, buff []byte) error + func (j *MarshalizerMock) IsInterfaceNil() bool + func (j MarshalizerMock) Marshal(obj interface{}) ([]byte, error) + func (j MarshalizerMock) Unmarshal(obj interface{}, buff []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 MiniBlocksResolverStub struct + NumPeersToQueryCalled func() (int, int) + ProcessReceivedMessageCalled func(message p2p.MessageP2P) error + RequestDataFromHashArrayCalled func(hashes [][]byte, epoch uint32) error + RequestDataFromHashCalled func(hash []byte, epoch uint32) error + SetNumPeersToQueryCalled func(intra int, cross int) + SetResolverDebugHandlerCalled func(handler dataRetriever.ResolverDebugHandler) error + func (mbrs *MiniBlocksResolverStub) IsInterfaceNil() bool + func (mbrs *MiniBlocksResolverStub) NumPeersToQuery() (int, int) + func (mbrs *MiniBlocksResolverStub) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error + func (mbrs *MiniBlocksResolverStub) RequestDataFromHash(hash []byte, epoch uint32) error + func (mbrs *MiniBlocksResolverStub) RequestDataFromHashArray(hashes [][]byte, epoch uint32) error + func (mbrs *MiniBlocksResolverStub) SetNumPeersToQuery(intra int, cross int) + func (mbrs *MiniBlocksResolverStub) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error + type NodeRedundancyHandlerStub 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 (nrhs *NodeRedundancyHandlerStub) AdjustInactivityIfNeeded(selfPubKey string, consensusPubKeys []string, roundIndex int64) + func (nrhs *NodeRedundancyHandlerStub) IsInterfaceNil() bool + func (nrhs *NodeRedundancyHandlerStub) IsMainMachineActive() bool + func (nrhs *NodeRedundancyHandlerStub) IsRedundancyNode() bool + func (nrhs *NodeRedundancyHandlerStub) ObserverPrivateKey() crypto.PrivateKey + func (nrhs *NodeRedundancyHandlerStub) ResetInactivityIfNeeded(selfPubKey string, consensusMsgPubKey string, consensusMsgPeerID core.PeerID) + type NodeWrapperStub struct + AddQueryHandlerCalled func(name string, handler debug.QueryHandler) error + func (nws *NodeWrapperStub) AddQueryHandler(name string, handler debug.QueryHandler) error + func (nws *NodeWrapperStub) IsInterfaceNil() bool + 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 P2PMessageStub struct + DataField []byte + FromField []byte + KeyField []byte + PeerField core.PeerID + SeqNoField []byte + SignatureField []byte + TopicsField []string + func (msg *P2PMessageStub) Data() []byte + func (msg *P2PMessageStub) From() []byte + func (msg *P2PMessageStub) IsInterfaceNil() bool + func (msg *P2PMessageStub) Key() []byte + func (msg *P2PMessageStub) Peer() core.PeerID + func (msg *P2PMessageStub) SeqNo() []byte + func (msg *P2PMessageStub) Signature() []byte + func (msg *P2PMessageStub) Topics() []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 PeerDenialEvaluatorStub struct + IsDeniedCalled func(pid core.PeerID) bool + UpsertPeerIDCalled func(pid core.PeerID, duration time.Duration) error + func (pdes *PeerDenialEvaluatorStub) IsDenied(pid core.PeerID) bool + func (pdes *PeerDenialEvaluatorStub) IsInterfaceNil() bool + func (pdes *PeerDenialEvaluatorStub) UpsertPeerID(pid core.PeerID, duration time.Duration) error + 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 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 PubkeyConverterMock struct + func NewPubkeyConverterMock(addressLen int) *PubkeyConverterMock + func (pcm *PubkeyConverterMock) Decode(humanReadable string) ([]byte, error) + func (pcm *PubkeyConverterMock) Encode(pkBytes []byte) string + func (pcm *PubkeyConverterMock) IsInterfaceNil() bool + func (pcm *PubkeyConverterMock) Len() int + 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 QueryHandlerStub struct + CloseCalled func() error + QueryCalled func(search string) []string + func (qhs *QueryHandlerStub) Close() error + func (qhs *QueryHandlerStub) IsInterfaceNil() bool + func (qhs *QueryHandlerStub) Query(search string) []string + 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 + BeforeGenesisCalled func() bool + IndexCalled func() int64 + RemainingTimeCalled func(startTime time.Time, maxTime time.Duration) time.Duration + TimeDurationCalled func() time.Duration + TimeStampCalled func() time.Time + UpdateRoundCalled func(time.Time, time.Time) + func (rndm *RoundHandlerMock) BeforeGenesis() bool + func (rndm *RoundHandlerMock) Index() int64 + func (rndm *RoundHandlerMock) IsInterfaceNil() bool + func (rndm *RoundHandlerMock) RemainingTime(startTime time.Time, maxTime 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 SCQueryServiceStub struct + CloseCalled func() error + ComputeScCallGasLimitHandler func(tx *transaction.Transaction) (uint64, error) + ExecuteQueryCalled func(*process.SCQuery) (*vmcommon.VMOutput, error) + func (serviceStub *SCQueryServiceStub) Close() error + func (serviceStub *SCQueryServiceStub) ComputeScCallGasLimit(tx *transaction.Transaction) (uint64, error) + func (serviceStub *SCQueryServiceStub) ExecuteQuery(query *process.SCQuery) (*vmcommon.VMOutput, error) + func (serviceStub *SCQueryServiceStub) IsInterfaceNil() bool + type ShardCoordinatorMock struct + ComputeIdCalled func([]byte) uint32 + SelfShardId uint32 + func (scm *ShardCoordinatorMock) CommunicationIdentifier(destShardID uint32) string + func (scm *ShardCoordinatorMock) ComputeId(addr []byte) uint32 + func (scm *ShardCoordinatorMock) IsInterfaceNil() bool + func (scm *ShardCoordinatorMock) NumberOfShards() uint32 + func (scm *ShardCoordinatorMock) SameShard(_, _ []byte) bool + func (scm *ShardCoordinatorMock) SelfId() uint32 + func (scm *ShardCoordinatorMock) SetSelfShardId(shardId uint32) error + type SingleSignerMock struct + SignStub func(private crypto.PrivateKey, msg []byte) ([]byte, error) + VerifyStub func(public crypto.PublicKey, msg []byte, sig []byte) error + func (s *SingleSignerMock) IsInterfaceNil() bool + func (s *SingleSignerMock) Sign(private crypto.PrivateKey, msg []byte) ([]byte, error) + func (s *SingleSignerMock) Verify(public crypto.PublicKey, msg []byte, sig []byte) error + 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 StakeValuesProcessorStub struct + GetTotalStakedValueCalled func(ctx context.Context) (*api.StakeValues, error) + func (svps *StakeValuesProcessorStub) GetTotalStakedValue(ctx context.Context) (*api.StakeValues, error) + func (svps *StakeValuesProcessorStub) IsInterfaceNil() bool + type StatusComputerStub struct + func (scs *StatusComputerStub) ComputeStatusWhenInStorageKnowingMiniblock(_ block.Type, _ *transaction.ApiTransactionResult) (transaction.TxStatus, error) + func (scs *StatusComputerStub) ComputeStatusWhenInStorageNotKnowingMiniblock(_ uint32, _ *transaction.ApiTransactionResult) (transaction.TxStatus, error) + func (scs *StatusComputerStub) SetStatusIfIsRewardReverted(_ *transaction.ApiTransactionResult, _ block.Type, _ uint64, _ []byte) (bool, error) + type Streamer struct + func NewStreamer() *Streamer + func (stream *Streamer) XORKeyStream(dst, src []byte) + type SuiteMock struct + CreatePointForScalarStub func(scalar crypto.Scalar) crypto.Point + CreatePointStub func() crypto.Point + CreateScalarStub func() crypto.Scalar + GetUnderlyingSuiteStub func() interface{} + PointLenStub func() int + RandomStreamStub func() cipher.Stream + ScalarLenStub func() int + StringStub func() string + func (s *SuiteMock) CreatePoint() crypto.Point + func (s *SuiteMock) CreateScalar() crypto.Scalar + func (s *SuiteMock) GetUnderlyingSuite() interface{} + func (s *SuiteMock) IsInterfaceNil() bool + func (s *SuiteMock) PointLen() int + func (s *SuiteMock) RandomStream() cipher.Stream + func (s *SuiteMock) ScalarLen() int + func (s *SuiteMock) String() string + type SyncTimerStub struct + func (sts *SyncTimerStub) ClockOffset() time.Duration + func (sts *SyncTimerStub) Close() error + func (sts *SyncTimerStub) CurrentTime() time.Time + func (sts *SyncTimerStub) FormattedCurrentTime() string + func (sts *SyncTimerStub) IsInterfaceNil() bool + func (sts *SyncTimerStub) StartSyncingTime() + type ThrottlerStub struct + CanProcessCalled func() bool + EndProcessingCalled func() + EndWasCalled bool + StartProcessingCalled func() + StartWasCalled bool + func (ts *ThrottlerStub) CanProcess() bool + func (ts *ThrottlerStub) EndProcessing() + func (ts *ThrottlerStub) IsInterfaceNil() bool + func (ts *ThrottlerStub) StartProcessing() + type TransactionAPIHandlerStub struct + GetLastPoolNonceForSenderCalled func(sender string) (uint64, error) + GetTransactionCalled func(hash string, withResults bool) (*transaction.ApiTransactionResult, error) + GetTransactionsPoolCalled func(fields string) (*common.TransactionsPoolAPIResponse, error) + GetTransactionsPoolForSenderCalled func(sender, fields string) (*common.TransactionsPoolForSenderApiResponse, error) + GetTransactionsPoolNonceGapsForSenderCalled func(sender string) (*common.TransactionsPoolNonceGapsForSenderApiResponse, error) + PopulateComputedFieldsCalled func(tx *transaction.ApiTransactionResult) + UnmarshalReceiptCalled func(receiptBytes []byte) (*transaction.ApiReceipt, error) + UnmarshalTransactionCalled func(txBytes []byte, txType transaction.TxType) (*transaction.ApiTransactionResult, error) + func (tas *TransactionAPIHandlerStub) GetLastPoolNonceForSender(sender string) (uint64, error) + func (tas *TransactionAPIHandlerStub) GetTransaction(hash string, withResults bool) (*transaction.ApiTransactionResult, error) + func (tas *TransactionAPIHandlerStub) GetTransactionsPool(fields string) (*common.TransactionsPoolAPIResponse, error) + func (tas *TransactionAPIHandlerStub) GetTransactionsPoolForSender(sender, fields string) (*common.TransactionsPoolForSenderApiResponse, error) + func (tas *TransactionAPIHandlerStub) GetTransactionsPoolNonceGapsForSender(sender string) (*common.TransactionsPoolNonceGapsForSenderApiResponse, error) + func (tas *TransactionAPIHandlerStub) IsInterfaceNil() bool + func (tas *TransactionAPIHandlerStub) PopulateComputedFields(tx *transaction.ApiTransactionResult) + func (tas *TransactionAPIHandlerStub) UnmarshalReceipt(receiptBytes []byte) (*transaction.ApiReceipt, error) + func (tas *TransactionAPIHandlerStub) UnmarshalTransaction(txBytes []byte, txType transaction.TxType) (*transaction.ApiTransactionResult, error) + type TransactionCostEstimatorMock struct + ComputeTransactionGasLimitCalled func(tx *transaction.Transaction) (*transaction.CostResponse, error) + func (tcem *TransactionCostEstimatorMock) ComputeTransactionGasLimit(tx *transaction.Transaction) (*transaction.CostResponse, error) + func (tcem *TransactionCostEstimatorMock) IsInterfaceNil() bool + 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 VMContainerMock struct + AddCalled func(key []byte, val vmcommon.VMExecutionHandler) error + AddMultipleCalled func(keys [][]byte, preprocessors []vmcommon.VMExecutionHandler) error + CloseCalled func() error + GetCalled func(key []byte) (vmcommon.VMExecutionHandler, error) + KeysCalled func() [][]byte + LenCalled func() int + RemoveCalled func(key []byte) + ReplaceCalled func(key []byte, val vmcommon.VMExecutionHandler) error + func (v *VMContainerMock) Add(key []byte, val vmcommon.VMExecutionHandler) error + func (v *VMContainerMock) AddMultiple(keys [][]byte, vms []vmcommon.VMExecutionHandler) error + func (v *VMContainerMock) Close() error + func (v *VMContainerMock) Get(key []byte) (vmcommon.VMExecutionHandler, error) + func (v *VMContainerMock) IsInterfaceNil() bool + func (v *VMContainerMock) Keys() [][]byte + func (v *VMContainerMock) Len() int + func (v *VMContainerMock) Remove(key []byte) + func (v *VMContainerMock) Replace(key []byte, val vmcommon.VMExecutionHandler) error + type VMExecutionHandlerStub struct + GasScheduleChangeCalled func(newGasSchedule map[string]map[string]uint64) + GetVersionCalled func() string + RunSmartContractCallCalled func(input *vmcommon.ContractCallInput) (*vmcommon.VMOutput, error) + RunSmartContractCreateCalled func(input *vmcommon.ContractCreateInput) (*vmcommon.VMOutput, error) + func (vm *VMExecutionHandlerStub) Close() error + func (vm *VMExecutionHandlerStub) GasScheduleChange(newGasSchedule map[string]map[string]uint64) + func (vm *VMExecutionHandlerStub) GetVersion() string + func (vm *VMExecutionHandlerStub) IsInterfaceNil() bool + func (vm *VMExecutionHandlerStub) RunSmartContractCall(input *vmcommon.ContractCallInput) (*vmcommon.VMOutput, error) + func (vm *VMExecutionHandlerStub) RunSmartContractCreate(input *vmcommon.ContractCreateInput) (*vmcommon.VMOutput, error) + type ValidatorStatisticsProcessorMock struct + CommitCalled func() ([]byte, error) + GetPeerAccountCalled func(address []byte) (state.PeerAccountHandler, error) + GetValidatorInfoForRootHashCalled func(rootHash []byte) (map[uint32][]*state.ValidatorInfo, error) + IsInterfaceNilCalled func() bool + 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 *ValidatorStatisticsProcessorMock) Commit() ([]byte, error) + func (vsp *ValidatorStatisticsProcessorMock) DisplayRatings(_ uint32) + func (vsp *ValidatorStatisticsProcessorMock) GetExistingPeerAccount(address []byte) (state.PeerAccountHandler, error) + func (vsp *ValidatorStatisticsProcessorMock) GetValidatorInfoForRootHash(rootHash []byte) (map[uint32][]*state.ValidatorInfo, error) + func (vsp *ValidatorStatisticsProcessorMock) IsInterfaceNil() bool + func (vsp *ValidatorStatisticsProcessorMock) LastFinalizedRootHash() []byte + func (vsp *ValidatorStatisticsProcessorMock) PeerAccountToValidatorInfo(peerAccount state.PeerAccountHandler) *state.ValidatorInfo + func (vsp *ValidatorStatisticsProcessorMock) Process(validatorInfo data.ShardValidatorInfoHandler) error + func (vsp *ValidatorStatisticsProcessorMock) ProcessRatingsEndOfEpoch(validatorInfos map[uint32][]*state.ValidatorInfo, epoch uint32) error + func (vsp *ValidatorStatisticsProcessorMock) ResetValidatorStatisticsAtNewEpoch(vInfos map[uint32][]*state.ValidatorInfo) error + func (vsp *ValidatorStatisticsProcessorMock) RevertPeerState(header data.MetaHeaderHandler) error + func (vsp *ValidatorStatisticsProcessorMock) RootHash() ([]byte, error) + func (vsp *ValidatorStatisticsProcessorMock) SaveNodesCoordinatorUpdates(epoch uint32) (bool, error) + func (vsp *ValidatorStatisticsProcessorMock) SetLastFinalizedRootHash(_ []byte) + func (vsp *ValidatorStatisticsProcessorMock) UpdatePeerState(header data.MetaHeaderHandler, _ map[string]data.HeaderHandler) ([]byte, error) + 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) GetExistingPeerAccount(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 + type VmMachinesContainerFactoryMock struct + func (v *VmMachinesContainerFactoryMock) BlockChainHookImpl() process.BlockChainHookHandler + func (v *VmMachinesContainerFactoryMock) Close() error + func (v *VmMachinesContainerFactoryMock) Create() (process.VirtualMachinesContainer, error) + func (v *VmMachinesContainerFactoryMock) IsInterfaceNil() bool + type WatchdogMock struct + func (w *WatchdogMock) IsInterfaceNil() bool + func (w *WatchdogMock) Reset(_ string) + func (w *WatchdogMock) Set(_ func(alarmID string), _ time.Duration, _ string) + func (w *WatchdogMock) SetDefault(_ time.Duration, _ string) + func (w *WatchdogMock) Stop(_ string)