Versions in this module Expand all Collapse all v1 v1.1.66 Jun 17, 2021 v1.1.65 Jun 17, 2021 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 NewAccountWrapMock(adr []byte) *AccountWrapMock + 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() data.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) SetCode(code []byte) + func (awm *AccountWrapMock) SetCodeHash(codeHash []byte) + func (awm *AccountWrapMock) SetCodeMetadata(codeMetadata []byte) + func (awm *AccountWrapMock) SetDataTrie(trie data.Trie) + func (awm *AccountWrapMock) SetOwnerAddress([]byte) + func (awm *AccountWrapMock) SetRootHash(rootHash []byte) + func (awm *AccountWrapMock) SetUserName(_ []byte) + func (awm *AccountWrapMock) SubFromBalance(_ *big.Int) error + type AccountsFactoryStub struct + CreateAccountCalled func(address []byte) (state.AccountHandler, error) + func (afs *AccountsFactoryStub) CreateAccount(address []byte) (state.AccountHandler, error) + func (afs *AccountsFactoryStub) IsInterfaceNil() bool + type AccountsStub struct + CancelPruneCalled func(rootHash []byte, identifier data.TriePruningIdentifier) + CommitCalled func() ([]byte, error) + GetAllLeavesCalled func(rootHash []byte) (chan core.KeyValueHolder, error) + GetCodeCalled func([]byte) []byte + GetExistingAccountCalled func(addressContainer []byte) (state.AccountHandler, error) + GetNumCheckpointsCalled func() uint32 + IsPruningEnabledCalled func() bool + JournalLenCalled func() int + LoadAccountCalled func(container []byte) (state.AccountHandler, error) + PruneTrieCalled func(rootHash []byte, identifier data.TriePruningIdentifier) + RecreateAllTriesCalled func(rootHash []byte) (map[string]data.Trie, error) + RecreateTrieCalled func(rootHash []byte) error + RemoveAccountCalled func(addressContainer []byte) error + RevertToSnapshotCalled func(snapshot int) error + RootHashCalled func() ([]byte, error) + SaveAccountCalled func(account state.AccountHandler) error + SetStateCheckpointCalled func(rootHash []byte) + SnapshotStateCalled func(rootHash []byte) + func (as *AccountsStub) CancelPrune(rootHash []byte, identifier data.TriePruningIdentifier) + func (as *AccountsStub) Commit() ([]byte, error) + func (as *AccountsStub) GetAllLeaves(rootHash []byte, _ context.Context) (chan core.KeyValueHolder, error) + func (as *AccountsStub) GetCode(codeHash []byte) []byte + func (as *AccountsStub) GetExistingAccount(addressContainer []byte) (state.AccountHandler, error) + func (as *AccountsStub) GetNumCheckpoints() uint32 + func (as *AccountsStub) IsInterfaceNil() bool + func (as *AccountsStub) IsPruningEnabled() bool + func (as *AccountsStub) JournalLen() int + func (as *AccountsStub) LoadAccount(address []byte) (state.AccountHandler, error) + func (as *AccountsStub) PruneTrie(rootHash []byte, identifier data.TriePruningIdentifier) + func (as *AccountsStub) RecreateAllTries(rootHash []byte, _ context.Context) (map[string]data.Trie, error) + func (as *AccountsStub) RecreateTrie(rootHash []byte) error + func (as *AccountsStub) RemoveAccount(addressContainer []byte) error + func (as *AccountsStub) RevertToSnapshot(snapshot int) error + func (as *AccountsStub) RootHash() ([]byte, error) + func (as *AccountsStub) SaveAccount(account state.AccountHandler) error + func (as *AccountsStub) SetStateCheckpoint(rootHash []byte, _ context.Context) + func (as *AccountsStub) SnapshotState(rootHash []byte, _ context.Context) + type AppStatusHandlerStub struct + AddUint64Handler func(key string, value uint64) + CloseHandler func() + DecrementHandler func(key string) + IncrementHandler func(key string) + SetInt64ValueHandler func(key string, value int64) + SetStringValueHandler func(key string, value string) + SetUInt64ValueHandler func(key string, value uint64) + func (ashs *AppStatusHandlerStub) AddUint64(key string, value uint64) + func (ashs *AppStatusHandlerStub) Close() + func (ashs *AppStatusHandlerStub) Decrement(key string) + func (ashs *AppStatusHandlerStub) Increment(key string) + func (ashs *AppStatusHandlerStub) IsInterfaceNil() bool + func (ashs *AppStatusHandlerStub) SetInt64Value(key string, value int64) + func (ashs *AppStatusHandlerStub) SetStringValue(key string, value string) + func (ashs *AppStatusHandlerStub) SetUInt64Value(key string, value uint64) + type BlockChainMock struct + CreateNewHeaderCalled func() data.HeaderHandler + GetCurrentBlockHeaderCalled func() data.HeaderHandler + GetCurrentBlockHeaderHashCalled func() []byte + GetGenesisHeaderCalled func() data.HeaderHandler + GetGenesisHeaderHashCalled func() []byte + GetLocalHeightCalled func() int64 + GetNetworkHeightCalled func() int64 + HasBadBlockCalled func([]byte) bool + PutBadBlockCalled func([]byte) + SetCurrentBlockHeaderCalled func(data.HeaderHandler) error + SetCurrentBlockHeaderHashCalled func([]byte) + SetGenesisHeaderCalled func(handler data.HeaderHandler) error + SetGenesisHeaderHashCalled func([]byte) + SetLocalHeightCalled func(int64) + SetNetworkHeightCalled func(int64) + func (bc *BlockChainMock) CreateNewHeader() data.HeaderHandler + func (bc *BlockChainMock) GetCurrentBlockHeader() data.HeaderHandler + func (bc *BlockChainMock) GetCurrentBlockHeaderHash() []byte + func (bc *BlockChainMock) GetGenesisHeader() data.HeaderHandler + func (bc *BlockChainMock) GetGenesisHeaderHash() []byte + func (bc *BlockChainMock) IsInterfaceNil() bool + func (bc *BlockChainMock) SetCurrentBlockHeader(header data.HeaderHandler) error + func (bc *BlockChainMock) SetCurrentBlockHeaderHash(hash []byte) + func (bc *BlockChainMock) SetGenesisHeader(genesisBlock data.HeaderHandler) error + func (bc *BlockChainMock) SetGenesisHeaderHash(hash []byte) + 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 + 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 + PruneStateOnRollbackCalled func(currHeader data.HeaderHandler, prevHeader data.HeaderHandler) + RestoreBlockIntoPoolsCalled func(header data.HeaderHandler, body data.BodyHandler) error + RevertAccountStateCalled func(header data.HeaderHandler) + RevertIndexedBlockCalled func(header data.HeaderHandler) + RevertStateToBlockCalled func(header data.HeaderHandler) error + SetOnRequestTransactionCalled func(f func(destShardID uint32, txHash []byte)) + func (bps *BlockProcessorStub) AddLastNotarizedHdr(shardId uint32, processedHdr data.HeaderHandler) + func (bps *BlockProcessorStub) ApplyProcessedMiniBlocks(_ *processedMb.ProcessedMiniBlockTracker) + 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 + 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) PruneStateOnRollback(currHeader data.HeaderHandler, prevHeader data.HeaderHandler) + func (bps *BlockProcessorStub) RestoreBlockIntoPools(header data.HeaderHandler, body data.BodyHandler) error + func (bps *BlockProcessorStub) RestoreLastNotarizedHrdsToGenesis() + func (bps *BlockProcessorStub) RevertAccountState(header data.HeaderHandler) + func (bps *BlockProcessorStub) RevertIndexedBlock(header data.HeaderHandler) + func (bps *BlockProcessorStub) RevertStateToBlock(header data.HeaderHandler) 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 + CheckBlockAgainstRounderCalled 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 + 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) CheckBlockAgainstRounder(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 + type BoostrapStorerMock struct + GetCalled func(round int64) (bootstrapStorage.BootstrapData, error) + GetHighestRoundCalled func() int64 + PutCalled func(round int64, bootData bootstrapStorage.BootstrapData) error + func (bsm *BoostrapStorerMock) Get(round int64) (bootstrapStorage.BootstrapData, error) + func (bsm *BoostrapStorerMock) GetHighestRound() int64 + func (bsm *BoostrapStorerMock) IsInterfaceNil() bool + func (bsm *BoostrapStorerMock) Put(round int64, bootData bootstrapStorage.BootstrapData) error + func (bsm *BoostrapStorerMock) SaveLastRound(round int64) error + type ChainHandlerStub struct + CreateNewHeaderCalled func() data.HeaderHandler + GetGenesisHeaderCalled func() data.HeaderHandler + GetGenesisHeaderHashCalled func() []byte + SetCurrentBlockHeaderCalled func(bh data.HeaderHandler) error + SetGenesisHeaderCalled func(gb data.HeaderHandler) error + SetGenesisHeaderHashCalled func(hash []byte) + func (chs *ChainHandlerStub) CreateNewHeader() data.HeaderHandler + func (chs *ChainHandlerStub) GetCurrentBlockHeader() data.HeaderHandler + func (chs *ChainHandlerStub) GetCurrentBlockHeaderHash() []byte + func (chs *ChainHandlerStub) GetGenesisHeader() data.HeaderHandler + func (chs *ChainHandlerStub) GetGenesisHeaderHash() []byte + func (chs *ChainHandlerStub) IsInterfaceNil() bool + func (chs *ChainHandlerStub) SetCurrentBlockHeader(bh data.HeaderHandler) error + func (chs *ChainHandlerStub) SetCurrentBlockHeaderHash(_ []byte) + func (chs *ChainHandlerStub) SetGenesisHeader(gb data.HeaderHandler) error + func (chs *ChainHandlerStub) SetGenesisHeaderHash(hash []byte) + 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) + 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) 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(epoch uint32) + type DelegatedListProcessorStub struct + GetDelegatorsListCalled func() ([]*api.Delegator, error) + func (dlps *DelegatedListProcessorStub) GetDelegatorsList() ([]*api.Delegator, error) + func (dlps *DelegatedListProcessorStub) IsInterfaceNil() bool + type DirectStakedListProcessorStub struct + GetDirectStakedListCalled func() ([]*api.DirectStakedValue, error) + func (dslps *DirectStakedListProcessorStub) GetDirectStakedList() ([]*api.DirectStakedValue, error) + func (dslps *DirectStakedListProcessorStub) IsInterfaceNil() bool + type EpochStartNotifierStub struct + NotifyAllCalled func(hdr data.HeaderHandler) + NotifyAllPrepareCalled func(hdr data.HeaderHandler, body data.BodyHandler) + 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) 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 FeeHandlerStub struct + CheckValidityTxValuesCalled func(tx process.TransactionWithFeeHandler) error + ComputeFeeForProcessingCalled func(tx process.TransactionWithFeeHandler, gasToUse uint64) *big.Int + ComputeGasLimitCalled func(tx process.TransactionWithFeeHandler) uint64 + ComputeMoveBalanceFeeCalled func(tx process.TransactionWithFeeHandler) *big.Int + ComputeTxFeeCalled func(tx process.TransactionWithFeeHandler) *big.Int + DeveloperPercentageCalled func() float64 + GasPriceModifierCalled func() float64 + GenesisTotalSupplyCalled func() *big.Int + MaxGasLimitPerBlockCalled func() uint64 + MinGasPriceCalled func() uint64 + SetMinGasLimitCalled func(minGasLimit uint64) + SetMinGasPriceCalled func(minasPrice uint64) + func (fhs *FeeHandlerStub) CheckValidityTxValues(tx process.TransactionWithFeeHandler) error + func (fhs *FeeHandlerStub) ComputeFeeForProcessing(tx process.TransactionWithFeeHandler, gasToUse uint64) *big.Int + func (fhs *FeeHandlerStub) ComputeGasLimit(tx process.TransactionWithFeeHandler) uint64 + func (fhs *FeeHandlerStub) ComputeMoveBalanceFee(tx process.TransactionWithFeeHandler) *big.Int + func (fhs *FeeHandlerStub) ComputeTxFee(tx process.TransactionWithFeeHandler) *big.Int + func (fhs *FeeHandlerStub) DeveloperPercentage() float64 + func (fhs *FeeHandlerStub) GasPriceModifier() float64 + func (fhs *FeeHandlerStub) GenesisTotalSupply() *big.Int + func (fhs *FeeHandlerStub) IsInterfaceNil() bool + func (fhs *FeeHandlerStub) MaxGasLimitPerBlock(uint32) uint64 + func (fhs *FeeHandlerStub) MinGasPrice() 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 GeneratorSuite struct + CreateKeyStub func(cipher.Stream) crypto.Scalar + func (gs *GeneratorSuite) CreateKey(c cipher.Stream) crypto.Scalar + type HardforkTriggerStub struct + AddCloserCalled func(closer update.Closer) error + CreateDataCalled func() []byte + IsSelfTriggerCalled func() bool + NotifyTriggerReceivedCalled func() <-chan struct{} + RecordedTriggerMessageCalled func() ([]byte, bool) + TriggerCalled func(epoch uint32, withEarlyEndOfEpoch bool) error + TriggerReceivedCalled func(payload []byte, data []byte, pkBytes []byte) (bool, error) + func (hts *HardforkTriggerStub) AddCloser(closer update.Closer) error + func (hts *HardforkTriggerStub) CreateData() []byte + func (hts *HardforkTriggerStub) IsInterfaceNil() bool + func (hts *HardforkTriggerStub) IsSelfTrigger() bool + func (hts *HardforkTriggerStub) NotifyTriggerReceived() <-chan struct{} + func (hts *HardforkTriggerStub) RecordedTriggerMessage() ([]byte, bool) + func (hts *HardforkTriggerStub) Trigger(epoch uint32, withEarlyEndOfEpoch bool) error + func (hts *HardforkTriggerStub) TriggerReceived(payload []byte, data []byte, pkBytes []byte) (bool, error) + 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 + 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 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) + func (im *IndexerStub) UpdateTPS(_ statistics.TPSBenchmark) + type InterceptorStub struct + ProcessReceivedMessageCalled func(message p2p.MessageP2P) error + SetInterceptedDebugHandlerCalled func(handler process.InterceptedDebugger) error + func (is *InterceptorStub) IsInterfaceNil() bool + func (is *InterceptorStub) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error + func (is *InterceptorStub) RegisterHandler(_ func(topic string, hash []byte, data interface{})) + func (is *InterceptorStub) SetInterceptedDebugHandler(handler process.InterceptedDebugger) error + type InterceptorsContainerStub struct + GetCalled func(string) (process.Interceptor, error) + IterateCalled func(handler func(key string, interceptor process.Interceptor) bool) + func (ics *InterceptorsContainerStub) Add(_ string, _ process.Interceptor) error + func (ics *InterceptorsContainerStub) AddMultiple(_ []string, _ []process.Interceptor) error + func (ics *InterceptorsContainerStub) Get(topic string) (process.Interceptor, error) + func (ics *InterceptorsContainerStub) IsInterfaceNil() bool + func (ics *InterceptorsContainerStub) Iterate(handler func(key string, interceptor process.Interceptor) bool) + func (ics *InterceptorsContainerStub) Len() int + func (ics *InterceptorsContainerStub) Remove(_ string) + func (ics *InterceptorsContainerStub) Replace(_ string, _ process.Interceptor) error + type IntermProcessorContainerStub struct + GetCalled func(key block.Type) (process.IntermediateTransactionHandler, error) + KeysCalled func() []block.Type + func (ipcm *IntermProcessorContainerStub) Add(_ block.Type, _ process.IntermediateTransactionHandler) error + func (ipcm *IntermProcessorContainerStub) AddMultiple(_ []block.Type, _ []process.IntermediateTransactionHandler) error + func (ipcm *IntermProcessorContainerStub) Get(key block.Type) (process.IntermediateTransactionHandler, error) + func (ipcm *IntermProcessorContainerStub) IsInterfaceNil() bool + func (ipcm *IntermProcessorContainerStub) Keys() []block.Type + func (ipcm *IntermProcessorContainerStub) Len() int + func (ipcm *IntermProcessorContainerStub) Remove(_ block.Type) + func (ipcm *IntermProcessorContainerStub) Replace(_ block.Type, _ process.IntermediateTransactionHandler) error + type IntermediateTransactionHandlerStub struct + AddIntermediateTransactionsCalled func(txs []data.TransactionHandler) error + CreateAllInterMiniBlocksCalled func() []*block.MiniBlock + CreateBlockStartedCalled func() + CreateMarshalizedDataCalled func(txHashes [][]byte) ([][]byte, error) + GetAllCurrentFinishedTxsCalled func() map[string]data.TransactionHandler + GetNumOfCrossInterMbsAndTxsCalled func() (int, int) + RemoveProcessedResultsForCalled func(txHashes [][]byte) + SaveCurrentIntermediateTxToStorageCalled func() error + VerifyInterMiniBlocksCalled func(body *block.Body) error + func (ith *IntermediateTransactionHandlerStub) AddIntermediateTransactions(txs []data.TransactionHandler) error + func (ith *IntermediateTransactionHandlerStub) CreateAllInterMiniBlocks() []*block.MiniBlock + func (ith *IntermediateTransactionHandlerStub) CreateBlockStarted() + func (ith *IntermediateTransactionHandlerStub) CreateMarshalizedData(txHashes [][]byte) ([][]byte, error) + func (ith *IntermediateTransactionHandlerStub) GetAllCurrentFinishedTxs() map[string]data.TransactionHandler + func (ith *IntermediateTransactionHandlerStub) GetCreatedInShardMiniBlock() *block.MiniBlock + func (ith *IntermediateTransactionHandlerStub) GetIntermediateTransactions() []data.TransactionHandler + func (ith *IntermediateTransactionHandlerStub) GetNumOfCrossInterMbsAndTxs() (int, int) + func (ith *IntermediateTransactionHandlerStub) IsInterfaceNil() bool + func (ith *IntermediateTransactionHandlerStub) RemoveProcessedResultsFor(txHashes [][]byte) + func (ith *IntermediateTransactionHandlerStub) SaveCurrentIntermediateTxToStorage() error + func (ith *IntermediateTransactionHandlerStub) VerifyInterMiniBlocks(body *block.Body) error + 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 MessengerStub struct + BootstrapCalled func() error + BroadcastCalled func(topic string, buff []byte) + BroadcastOnChannelBlockingCalled func(channel string, topic string, buff []byte) error + BroadcastOnChannelCalled func(channel string, topic string, buff []byte) + CloseCalled func() error + CreateTopicCalled func(name string, createChannelForTopic bool) error + HasTopicCalled func(name string) bool + HasTopicValidatorCalled func(name string) bool + IDCalled func() core.PeerID + IsConnectedToTheNetworkCalled func() bool + PeerAddressesCalled func(pid core.PeerID) []string + PeersCalled func() []core.PeerID + RegisterMessageProcessorCalled func(topic string, handler p2p.MessageProcessor) error + func (ms *MessengerStub) Bootstrap() error + func (ms *MessengerStub) Broadcast(topic string, buff []byte) + func (ms *MessengerStub) BroadcastOnChannel(channel string, topic string, buff []byte) + func (ms *MessengerStub) BroadcastOnChannelBlocking(channel string, topic string, buff []byte) error + func (ms *MessengerStub) Close() error + func (ms *MessengerStub) CreateTopic(name string, createChannelForTopic bool) error + func (ms *MessengerStub) HasTopic(name string) bool + func (ms *MessengerStub) HasTopicValidator(name string) bool + func (ms *MessengerStub) ID() core.PeerID + func (ms *MessengerStub) IsConnectedToTheNetwork() bool + func (ms *MessengerStub) IsInterfaceNil() bool + func (ms *MessengerStub) PeerAddresses(pid core.PeerID) []string + func (ms *MessengerStub) Peers() []core.PeerID + func (ms *MessengerStub) RegisterMessageProcessor(topic string, handler p2p.MessageProcessor) error + 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 MultisignMock struct + func (mm *MultisignMock) AggregateCommitments(_ []byte) error + func (mm *MultisignMock) AggregateSigs(_ []byte) ([]byte, error) + func (mm *MultisignMock) Commitment(_ uint16) ([]byte, error) + func (mm *MultisignMock) CommitmentHash(_ uint16) ([]byte, error) + func (mm *MultisignMock) Create(_ []string, _ uint16) (crypto.MultiSigner, error) + func (mm *MultisignMock) CreateCommitment() (commSecret []byte, commitment []byte) + func (mm *MultisignMock) CreateSignatureShare(_ []byte, _ []byte) ([]byte, error) + func (mm *MultisignMock) IsInterfaceNil() bool + func (mm *MultisignMock) Reset(_ []string, _ uint16) error + func (mm *MultisignMock) SetAggregatedSig([]byte) error + func (mm *MultisignMock) SignatureShare(_ uint16) ([]byte, error) + func (mm *MultisignMock) StoreCommitment(_ uint16, _ []byte) error + func (mm *MultisignMock) StoreCommitmentHash(_ uint16, _ []byte) error + func (mm *MultisignMock) StoreSignatureShare(_ uint16, _ []byte) error + func (mm *MultisignMock) Verify(_ []byte, _ []byte) error + func (mm *MultisignMock) VerifySignatureShare(_ uint16, _ []byte, _ []byte, _ []byte) error + type NetworkShardingCollectorStub struct + GetPeerInfoCalled func(pid core.PeerID) core.P2PPeerInfo + UpdatePeerIdPublicKeyCalled func(pid core.PeerID, pk []byte) + UpdatePeerIdShardIdCalled func(pid core.PeerID, shardId uint32) + UpdatePublicKeyShardIdCalled func(pk []byte, shardId uint32) + func (nscs *NetworkShardingCollectorStub) GetPeerInfo(pid core.PeerID) core.P2PPeerInfo + func (nscs *NetworkShardingCollectorStub) IsInterfaceNil() bool + func (nscs *NetworkShardingCollectorStub) UpdatePeerIdPublicKey(pid core.PeerID, pk []byte) + func (nscs *NetworkShardingCollectorStub) UpdatePeerIdShardId(pid core.PeerID, shardId uint32) + func (nscs *NetworkShardingCollectorStub) UpdatePublicKeyShardId(pk []byte, shardId uint32) + 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 NodesCoordinatorMock struct + ComputeValidatorsGroupCalled func(randomness []byte, round uint64, shardId uint32, epoch uint32) ([]sharding.Validator, error) + GetAllEligibleValidatorsPublicKeysCalled func() (map[uint32][][]byte, error) + GetValidatorsPublicKeysCalled func(randomness []byte, round uint64, shardId uint32, epoch uint32) ([]string, error) + GetValidatorsRewardsAddressesCalled func(randomness []byte, round uint64, shardId uint32, epoch uint32) ([]string, error) + func (ncm *NodesCoordinatorMock) ComputeAdditionalLeaving([]*state.ShardValidatorInfo) (map[uint32][]sharding.Validator, error) + func (ncm *NodesCoordinatorMock) ComputeConsensusGroup(randomness []byte, round uint64, shardId uint32, epoch uint32) (validatorsGroup []sharding.Validator, err error) + func (ncm *NodesCoordinatorMock) ConsensusGroupSize(uint32) int + func (ncm *NodesCoordinatorMock) GetAllEligibleValidatorsPublicKeys(_ uint32) (map[uint32][][]byte, error) + func (ncm *NodesCoordinatorMock) GetAllLeavingValidatorsPublicKeys(_ uint32) (map[uint32][][]byte, error) + func (ncm *NodesCoordinatorMock) GetAllWaitingValidatorsPublicKeys(_ uint32) (map[uint32][][]byte, error) + func (ncm *NodesCoordinatorMock) GetChance(uint32) uint32 + func (ncm *NodesCoordinatorMock) GetConsensusValidatorsPublicKeys(randomness []byte, round uint64, shardId uint32, epoch uint32) ([]string, error) + func (ncm *NodesCoordinatorMock) GetConsensusWhitelistedNodes(_ uint32) (map[string]struct{}, error) + func (ncm *NodesCoordinatorMock) GetNumTotalEligible() uint64 + func (ncm *NodesCoordinatorMock) GetOwnPublicKey() []byte + func (ncm *NodesCoordinatorMock) GetSavedStateKey() []byte + func (ncm *NodesCoordinatorMock) GetSelectedPublicKeys(_ []byte, _ uint32, _ uint32) (publicKeys []string, err error) + func (ncm *NodesCoordinatorMock) GetValidatorWithPublicKey(_ []byte) (sharding.Validator, uint32, error) + func (ncm *NodesCoordinatorMock) GetValidatorsIndexes(_ []string, _ uint32) ([]uint64, error) + func (ncm *NodesCoordinatorMock) IsInterfaceNil() bool + func (ncm *NodesCoordinatorMock) LoadState(_ []byte) error + func (ncm *NodesCoordinatorMock) SetConsensusGroupSize(_ int) error + func (ncm *NodesCoordinatorMock) SetNodesPerShards(_ map[uint32][]sharding.Validator, _ map[uint32][]sharding.Validator, _ uint32) error + func (ncm *NodesCoordinatorMock) ShardIdForEpoch(_ uint32) (uint32, error) + func (ncm *NodesCoordinatorMock) ShuffleOutForEpoch(_ uint32) + func (ncm *NodesCoordinatorMock) ValidatorsWeights(validators []sharding.Validator) ([]uint32, error) + 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 + 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) IsInterfaceNil() bool + func (p2pahs *P2PAntifloodHandlerStub) ResetForTopic(_ string) + func (p2pahs *P2PAntifloodHandlerStub) SetMaxMessagesForTopic(_ string, _ uint32) + 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 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 + QueryCalled func(search string) []string + func (qhs *QueryHandlerStub) IsInterfaceNil() bool + func (qhs *QueryHandlerStub) Query(search string) []string + type RequestHandlerStub struct + GetNumPeersToQueryCalled func(key string) (int, int, error) + RequestMetaHeaderByNonceCalled func(nonce uint64) + RequestMetaHeaderCalled func(hash []byte) + RequestMiniBlockHandlerCalled func(destShardID uint32, miniblockHash []byte) + RequestMiniBlocksHandlerCalled func(destShardID uint32, miniblocksHashes [][]byte) + RequestRewardTxHandlerCalled func(destShardID uint32, txHashes [][]byte) + RequestScrHandlerCalled func(destShardID uint32, txHashes [][]byte) + RequestShardHeaderByNonceCalled func(shardID uint32, nonce uint64) + RequestShardHeaderCalled func(shardID uint32, hash []byte) + RequestStartOfEpochMetaBlockCalled func(epoch uint32) + RequestTransactionHandlerCalled func(destShardID uint32, txHashes [][]byte) + RequestTrieNodesCalled func(destShardID uint32, hashes [][]byte, topic string) + SetNumPeersToQueryCalled func(key string, intra int, cross int) error + func (rhs *RequestHandlerStub) GetNumPeersToQuery(key string) (int, int, error) + func (rhs *RequestHandlerStub) IsInterfaceNil() bool + func (rhs *RequestHandlerStub) RequestInterval() time.Duration + func (rhs *RequestHandlerStub) RequestMetaHeader(hash []byte) + func (rhs *RequestHandlerStub) RequestMetaHeaderByNonce(nonce uint64) + func (rhs *RequestHandlerStub) RequestMiniBlock(destShardID uint32, miniblockHash []byte) + func (rhs *RequestHandlerStub) RequestMiniBlocks(destShardID uint32, miniblocksHashes [][]byte) + func (rhs *RequestHandlerStub) RequestRewardTransactions(destShardID uint32, txHashes [][]byte) + func (rhs *RequestHandlerStub) RequestShardHeader(shardID uint32, hash []byte) + func (rhs *RequestHandlerStub) RequestShardHeaderByNonce(shardID uint32, nonce uint64) + func (rhs *RequestHandlerStub) RequestStartOfEpochMetaBlock(epoch uint32) + func (rhs *RequestHandlerStub) RequestTransaction(destShardID uint32, txHashes [][]byte) + func (rhs *RequestHandlerStub) RequestTrieNodes(destShardID uint32, hashes [][]byte, topic string) + func (rhs *RequestHandlerStub) RequestUnsignedTransactions(destShardID uint32, txHashes [][]byte) + func (rhs *RequestHandlerStub) SetEpoch(_ uint32) + func (rhs *RequestHandlerStub) SetNumPeersToQuery(key string, intra int, cross int) error + type ResolversFinderStub struct + AddCalled func(key string, val dataRetriever.Resolver) 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) 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 RounderMock 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 *RounderMock) BeforeGenesis() bool + func (rndm *RounderMock) Index() int64 + func (rndm *RounderMock) IsInterfaceNil() bool + func (rndm *RounderMock) RemainingTime(startTime time.Time, maxTime time.Duration) time.Duration + func (rndm *RounderMock) TimeDuration() time.Duration + func (rndm *RounderMock) TimeStamp() time.Time + func (rndm *RounderMock) UpdateRound(genesisRoundTimeStamp time.Time, timeStamp time.Time) + type SCQueryServiceStub struct + ComputeScCallGasLimitHandler func(tx *transaction.Transaction) (uint64, error) + ExecuteQueryCalled func(*process.SCQuery) (*vmcommon.VMOutput, 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) IsInterfaceNil() bool + func (scm ShardCoordinatorMock) CommunicationIdentifier(destShardID uint32) string + func (scm ShardCoordinatorMock) ComputeId(addr []byte) uint32 + 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() (*api.StakeValues, error) + func (svps *StakeValuesProcessorStub) GetTotalStakedValue() (*api.StakeValues, error) + func (svps *StakeValuesProcessorStub) IsInterfaceNil() bool + type StatusMetricsStub struct + ConfigMetricsCalled func() map[string]interface{} + EconomicsMetricsCalled func() map[string]interface{} + NetworkMetricsCalled func() map[string]interface{} + StatusMetricsMapWithoutP2PCalled func() map[string]interface{} + StatusMetricsWithoutP2PPrometheusStringCalled func() string + StatusP2pMetricsMapCalled func() map[string]interface{} + func (sms *StatusMetricsStub) ConfigMetrics() map[string]interface{} + func (sms *StatusMetricsStub) EconomicsMetrics() map[string]interface{} + func (sms *StatusMetricsStub) IsInterfaceNil() bool + func (sms *StatusMetricsStub) NetworkMetrics() map[string]interface{} + func (sms *StatusMetricsStub) StatusMetricsMapWithoutP2P() map[string]interface{} + func (sms *StatusMetricsStub) StatusMetricsWithoutP2PPrometheusString() string + func (sms *StatusMetricsStub) StatusP2pMetricsMap() map[string]interface{} + type StorageManagerStub struct + CancelPruneCalled func(rootHash []byte, identifier data.TriePruningIdentifier) + DatabaseCalled func() data.DBWriteCacher + EnterPruningBufferingModeCalled func() + ExitPruningBufferingModeCalled func() + GetDbThatContainsHashCalled func([]byte) data.DBWriteCacher + GetSnapshotThatContainsHashCalled func(rootHash []byte) data.SnapshotDbHandler + IsInterfaceNilCalled func() bool + IsPruningEnabledCalled func() bool + MarkForEvictionCalled func([]byte, data.ModifiedHashes) error + PruneCalled func(rootHash []byte, identifier data.TriePruningIdentifier) + SetCheckpointCalled func([]byte) + TakeSnapshotCalled func([]byte) + func (sms *StorageManagerStub) CancelPrune(rootHash []byte, identifier data.TriePruningIdentifier) + func (sms *StorageManagerStub) Database() data.DBWriteCacher + func (sms *StorageManagerStub) EnterPruningBufferingMode() + func (sms *StorageManagerStub) ExitPruningBufferingMode() + func (sms *StorageManagerStub) GetSnapshotDbBatchDelay() int + func (sms *StorageManagerStub) GetSnapshotThatContainsHash(d []byte) data.SnapshotDbHandler + func (sms *StorageManagerStub) IsInterfaceNil() bool + func (sms *StorageManagerStub) IsPruningEnabled() bool + func (sms *StorageManagerStub) MarkForEviction(d []byte, m data.ModifiedHashes) error + func (sms *StorageManagerStub) Prune(rootHash []byte, identifier data.TriePruningIdentifier) + func (sms *StorageManagerStub) SetCheckpoint(rootHash []byte) + func (sms *StorageManagerStub) TakeSnapshot(rootHash []byte) + type StorerMock struct + func NewStorerMock() *StorerMock + func (sm *StorerMock) ClearCache() + func (sm *StorerMock) Close() error + func (sm *StorerMock) DestroyUnit() error + func (sm *StorerMock) Get(key []byte) ([]byte, error) + func (sm *StorerMock) GetBulkFromEpoch(keys [][]byte, _ uint32) (map[string][]byte, error) + func (sm *StorerMock) GetFromEpoch(key []byte, _ uint32) ([]byte, error) + func (sm *StorerMock) Has(_ []byte) error + func (sm *StorerMock) HasInEpoch(_ []byte, _ uint32) error + func (sm *StorerMock) IsInterfaceNil() bool + func (sm *StorerMock) Put(key, data []byte) error + func (sm *StorerMock) PutInEpoch(key, data []byte, _ uint32) error + func (sm *StorerMock) RangeKeys(_ func(_ []byte, _ []byte) bool) + func (sm *StorerMock) Remove(_ []byte) error + func (sm *StorerMock) SearchFirst(_ []byte) ([]byte, error) + type StorerStub struct + ClearCacheCalled func() + DestroyUnitCalled func() error + GetBulkFromEpochCalled func(keys [][]byte, epoch uint32) (map[string][]byte, error) + GetCalled func(key []byte) ([]byte, error) + GetFromEpochCalled func(key []byte, epoch uint32) ([]byte, error) + HasCalled func(key []byte) error + HasInEpochCalled func(key []byte, epoch uint32) error + PutCalled func(key, data []byte) error + PutInEpochCalled func(key, data []byte, epoch uint32) error + RangeKeysCalled func(handler func(key []byte, val []byte) bool) + RemoveCalled func(key []byte) error + SearchFirstCalled func(key []byte) ([]byte, error) + func (ss *StorerStub) ClearCache() + func (ss *StorerStub) Close() error + func (ss *StorerStub) DestroyUnit() error + func (ss *StorerStub) Get(key []byte) ([]byte, error) + func (ss *StorerStub) GetBulkFromEpoch(keys [][]byte, epoch uint32) (map[string][]byte, error) + func (ss *StorerStub) GetFromEpoch(key []byte, epoch uint32) ([]byte, error) + func (ss *StorerStub) Has(key []byte) error + func (ss *StorerStub) HasInEpoch(key []byte, epoch uint32) error + func (ss *StorerStub) IsInterfaceNil() bool + func (ss *StorerStub) Put(key, data []byte) error + func (ss *StorerStub) PutInEpoch(key, data []byte, epoch uint32) error + func (ss *StorerStub) RangeKeys(handler func(key []byte, val []byte) bool) + func (ss *StorerStub) Remove(key []byte) error + func (ss *StorerStub) SearchFirst(key []byte) ([]byte, 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 TimeCacheStub struct + AddCalled func(key string) error + HasCalled func(key string) bool + LenCalled func() int + SweepCalled func() + UpsertCalled func(key string, span time.Duration) error + func (tcs *TimeCacheStub) Add(key string) error + func (tcs *TimeCacheStub) Has(key string) bool + func (tcs *TimeCacheStub) IsInterfaceNil() bool + func (tcs *TimeCacheStub) Len() int + func (tcs *TimeCacheStub) Sweep() + func (tcs *TimeCacheStub) Upsert(key string, span time.Duration) 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 TrieStub struct + AppendToOldHashesCalled func([][]byte) + CommitCalled func() error + DeleteCalled func(key []byte) error + GetAllHashesCalled func() ([][]byte, error) + GetAllLeavesOnChannelCalled func(rootHash []byte) (chan core.KeyValueHolder, error) + GetCalled func(key []byte) ([]byte, error) + GetNumNodesCalled func() data.NumNodesDTO + GetProofCalled func(key []byte) ([][]byte, error) + GetSerializedNodeCalled func(bytes []byte) ([]byte, error) + GetSerializedNodesCalled func([]byte, uint64) ([][]byte, uint64, error) + GetStorageManagerCalled func() data.StorageManager + RecreateCalled func(root []byte) (data.Trie, error) + ResetOldHashesCalled func() [][]byte + RootCalled func() ([]byte, error) + UpdateCalled func(key, value []byte) error + VerifyProofCalled func(key []byte, proof [][]byte) (bool, error) + func (ts *TrieStub) AppendToOldHashes(hashes [][]byte) + func (ts *TrieStub) ClosePersister() error + func (ts *TrieStub) Commit() error + func (ts *TrieStub) Delete(key []byte) error + func (ts *TrieStub) Get(key []byte) ([]byte, error) + func (ts *TrieStub) GetAllHashes() ([][]byte, error) + func (ts *TrieStub) GetAllLeavesOnChannel(rootHash []byte, _ context.Context) (chan core.KeyValueHolder, error) + func (ts *TrieStub) GetDirtyHashes() (data.ModifiedHashes, error) + func (ts *TrieStub) GetNumNodes() data.NumNodesDTO + func (ts *TrieStub) GetProof(key []byte) ([][]byte, error) + func (ts *TrieStub) GetSerializedNode(bytes []byte) ([]byte, error) + func (ts *TrieStub) GetSerializedNodes(hash []byte, maxBuffToSend uint64) ([][]byte, uint64, error) + func (ts *TrieStub) GetStorageManager() data.StorageManager + func (ts *TrieStub) IsInterfaceNil() bool + func (ts *TrieStub) Recreate(root []byte) (data.Trie, error) + func (ts *TrieStub) ResetOldHashes() [][]byte + func (ts *TrieStub) RootHash() ([]byte, error) + func (ts *TrieStub) SetNewHashes(_ data.ModifiedHashes) + func (ts *TrieStub) String() string + func (ts *TrieStub) Update(key, value []byte) error + func (ts *TrieStub) VerifyProof(key []byte, proof [][]byte) (bool, error) + type TxProcessorStub struct + ProcessTransactionCalled func(transaction *transaction.Transaction) (vmcommon.ReturnCode, error) + func (tps *TxProcessorStub) IsInterfaceNil() bool + func (tps *TxProcessorStub) ProcessTransaction(transaction *transaction.Transaction) (vmcommon.ReturnCode, error) + type ValidatorMock struct + func NewValidatorMock(pubKey []byte, chances uint32, index uint32) *ValidatorMock + func (vm *ValidatorMock) Chances() uint32 + func (vm *ValidatorMock) Index() uint32 + func (vm *ValidatorMock) PubKey() []byte + func (vm *ValidatorMock) Size() int + 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.HeaderHandler) error + RootHashCalled func() ([]byte, error) + SaveNodesCoordinatorUpdatesCalled func(epoch uint32) (bool, error) + UpdatePeerStateCalled func(header data.HeaderHandler) ([]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.HeaderHandler) 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.HeaderHandler, _ 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.HeaderHandler) error + RootHashCalled func() ([]byte, error) + SaveNodesCoordinatorUpdatesCalled func(epoch uint32) (bool, error) + UpdatePeerStateCalled func(header data.HeaderHandler) ([]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.HeaderHandler) 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.HeaderHandler, _ map[string]data.HeaderHandler) ([]byte, error) + type ValidatorsProviderStub struct + GetLatestValidatorsCalled func() map[string]*state.ValidatorApiResponse + func (vp *ValidatorsProviderStub) GetLatestValidators() map[string]*state.ValidatorApiResponse + func (vp *ValidatorsProviderStub) 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) + type WhiteListHandlerStub struct + AddCalled func(keys [][]byte) + IsForCurrentShardCalled func(interceptedData process.InterceptedData) bool + IsWhiteListedCalled func(interceptedData process.InterceptedData) bool + RemoveCalled func(keys [][]byte) + func (w *WhiteListHandlerStub) Add(keys [][]byte) + func (w *WhiteListHandlerStub) IsForCurrentShard(interceptedData process.InterceptedData) bool + func (w *WhiteListHandlerStub) IsInterfaceNil() bool + func (w *WhiteListHandlerStub) IsWhiteListed(interceptedData process.InterceptedData) bool + func (w *WhiteListHandlerStub) Remove(keys [][]byte)