Versions in this module Expand all Collapse all v1 v1.999.0 Nov 17, 2022 Changes in this version + func NewMultiShardsCoordinatorMock(nrShard uint32) *multipleShardsCoordinatorMock + func NewMultipleShardsCoordinatorMock() *multipleShardsCoordinatorMock + func NewNonceHashConverterMock() *nonceHashConverterMock + func NewOneShardCoordinatorMock() *oneShardCoordinatorMock + type AccountWrapMock struct + AccountDataHandlerCalled func() vmcommon.AccountDataHandler + 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) AccountDataHandler() vmcommon.AccountDataHandler + 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) SetUserName(_ []byte) + func (awm *AccountWrapMock) SubFromBalance(_ *big.Int) error + type AccountsDBSyncerStub struct + GetSyncedTriesCalled func() map[string]common.Trie + SyncAccountsCalled func(rootHash []byte) error + func (a *AccountsDBSyncerStub) GetSyncedTries() map[string]common.Trie + func (a *AccountsDBSyncerStub) IsInterfaceNil() bool + func (a *AccountsDBSyncerStub) SyncAccounts(rootHash []byte) error + type AntifloodDebuggerStub struct + AddDataCalled func(pid core.PeerID, topic string, numRejected uint32, sizeRejected uint64, ...) + CloseCalled func() error + func (ads *AntifloodDebuggerStub) AddData(pid core.PeerID, topic string, numRejected uint32, sizeRejected uint64, ...) + func (ads *AntifloodDebuggerStub) Close() error + func (ads *AntifloodDebuggerStub) IsInterfaceNil() bool + type ArgumentParserMock struct + CreateDataFromStorageUpdateCalled func(storageUpdates []*vmcommon.StorageUpdate) string + GetStorageUpdatesCalled func(data string) ([]*vmcommon.StorageUpdate, error) + ParseArgumentsCalled func(data string) ([][]byte, error) + ParseCallDataCalled func(data string) (string, [][]byte, error) + ParseDeployDataCalled func(data string) (*parsers.DeployArgs, error) + func (ap *ArgumentParserMock) CreateDataFromStorageUpdate(storageUpdates []*vmcommon.StorageUpdate) string + func (ap *ArgumentParserMock) GetStorageUpdates(data string) ([]*vmcommon.StorageUpdate, error) + func (ap *ArgumentParserMock) IsInterfaceNil() bool + func (ap *ArgumentParserMock) ParseArguments(data string) ([][]byte, error) + func (ap *ArgumentParserMock) ParseCallData(data string) (string, [][]byte, error) + func (ap *ArgumentParserMock) ParseDeployData(data string) (*parsers.DeployArgs, error) + type BlockNotarizerHandlerMock struct + AddNotarizedHeaderCalled func(shardID uint32, notarizedHeader data.HeaderHandler, notarizedHeaderHash []byte) + CleanupNotarizedHeadersBehindNonceCalled func(shardID uint32, nonce uint64) + DisplayNotarizedHeadersCalled func(shardID uint32, message string) + GetFirstNotarizedHeaderCalled func(shardID uint32) (data.HeaderHandler, []byte, error) + GetLastNotarizedHeaderCalled func(shardID uint32) (data.HeaderHandler, []byte, error) + GetLastNotarizedHeaderNonceCalled func(shardID uint32) uint64 + GetNotarizedHeaderCalled func(shardID uint32, offset uint64) (data.HeaderHandler, []byte, error) + InitNotarizedHeadersCalled func(startHeaders map[uint32]data.HeaderHandler) error + RemoveLastNotarizedHeaderCalled func() + RestoreNotarizedHeadersToGenesisCalled func() + func (bngm *BlockNotarizerHandlerMock) AddNotarizedHeader(shardID uint32, notarizedHeader data.HeaderHandler, notarizedHeaderHash []byte) + func (bngm *BlockNotarizerHandlerMock) CleanupNotarizedHeadersBehindNonce(shardID uint32, nonce uint64) + func (bngm *BlockNotarizerHandlerMock) DisplayNotarizedHeaders(shardID uint32, message string) + func (bngm *BlockNotarizerHandlerMock) GetFirstNotarizedHeader(shardID uint32) (data.HeaderHandler, []byte, error) + func (bngm *BlockNotarizerHandlerMock) GetLastNotarizedHeader(shardID uint32) (data.HeaderHandler, []byte, error) + func (bngm *BlockNotarizerHandlerMock) GetLastNotarizedHeaderNonce(shardID uint32) uint64 + func (bngm *BlockNotarizerHandlerMock) GetNotarizedHeader(shardID uint32, offset uint64) (data.HeaderHandler, []byte, error) + func (bngm *BlockNotarizerHandlerMock) InitNotarizedHeaders(startHeaders map[uint32]data.HeaderHandler) error + func (bngm *BlockNotarizerHandlerMock) IsInterfaceNil() bool + func (bngm *BlockNotarizerHandlerMock) RemoveLastNotarizedHeader() + func (bngm *BlockNotarizerHandlerMock) RestoreNotarizedHeadersToGenesis() + type BlockNotifierHandlerStub struct + CallHandlersCalled func(shardID uint32, headers []data.HeaderHandler, headersHashes [][]byte) + GetNumRegisteredHandlersCalled func() int + RegisterHandlerCalled func(...) + func (bnhs *BlockNotifierHandlerStub) CallHandlers(shardID uint32, headers []data.HeaderHandler, headersHashes [][]byte) + func (bnhs *BlockNotifierHandlerStub) GetNumRegisteredHandlers() int + func (bnhs *BlockNotifierHandlerStub) IsInterfaceNil() bool + func (bnhs *BlockNotifierHandlerStub) RegisterHandler(...) + type BlockProcessorMock 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 (bpm *BlockProcessorMock) AddLastNotarizedHdr(shardId uint32, processedHdr data.HeaderHandler) + func (bpm *BlockProcessorMock) Close() error + func (bpm *BlockProcessorMock) CommitBlock(header data.HeaderHandler, body data.BodyHandler) error + func (bpm *BlockProcessorMock) CreateBlock(initialHdrData data.HeaderHandler, haveTime func() bool) (data.HeaderHandler, data.BodyHandler, error) + func (bpm *BlockProcessorMock) CreateGenesisBlock(balances map[string]*big.Int) (data.HeaderHandler, error) + func (bpm *BlockProcessorMock) CreateNewHeader(round uint64, nonce uint64) (data.HeaderHandler, error) + func (bpm *BlockProcessorMock) DecodeBlockBody(dta []byte) data.BodyHandler + func (bpm *BlockProcessorMock) DecodeBlockHeader(dta []byte) data.HeaderHandler + func (bpm *BlockProcessorMock) IsInterfaceNil() bool + func (bpm *BlockProcessorMock) MarshalizedDataToBroadcast(header data.HeaderHandler, body data.BodyHandler) (map[uint32][]byte, map[string][][]byte, error) + func (bpm *BlockProcessorMock) ProcessBlock(header data.HeaderHandler, body data.BodyHandler, ...) error + func (bpm *BlockProcessorMock) ProcessScheduledBlock(header data.HeaderHandler, body data.BodyHandler, ...) error + func (bpm *BlockProcessorMock) PruneStateOnRollback(currHeader data.HeaderHandler, currHeaderHash []byte, ...) + func (bpm *BlockProcessorMock) RestoreBlockBodyIntoPools(body data.BodyHandler) error + func (bpm *BlockProcessorMock) RestoreBlockIntoPools(header data.HeaderHandler, body data.BodyHandler) error + func (bpm *BlockProcessorMock) RestoreLastNotarizedHrdsToGenesis() + func (bpm *BlockProcessorMock) RevertCurrentBlock() + func (bpm *BlockProcessorMock) RevertIndexedBlock(header data.HeaderHandler) + func (bpm *BlockProcessorMock) RevertStateToBlock(header data.HeaderHandler, rootHash []byte) error + func (bpm *BlockProcessorMock) SetNumProcessedObj(_ uint64) + type BlockSizeThrottlerStub struct + AddCalled func(round uint64, size uint32) + ComputeCurrentMaxSizeCalled func() + GetCurrentMaxSizeCalled func() uint32 + SucceedCalled func(round uint64) + func (bsts *BlockSizeThrottlerStub) Add(round uint64, size uint32) + func (bsts *BlockSizeThrottlerStub) ComputeCurrentMaxSize() + func (bsts *BlockSizeThrottlerStub) GetCurrentMaxSize() uint32 + func (bsts *BlockSizeThrottlerStub) IsInterfaceNil() bool + func (bsts *BlockSizeThrottlerStub) Succeed(round uint64) + type BlockTrackerHandlerMock struct + AddHeaderFromPoolCalled func(shardID uint32, nonce uint64) + ComputeCrossInfoCalled func(headers []data.HeaderHandler) + ComputeLongestSelfChainCalled func() (data.HeaderHandler, []byte, []data.HeaderHandler, [][]byte) + GetSelfHeadersCalled func(headerHandler data.HeaderHandler) []*track.HeaderInfo + SortHeadersFromNonceCalled func(shardID uint32, nonce uint64) ([]data.HeaderHandler, [][]byte) + func (bthm *BlockTrackerHandlerMock) AddHeaderFromPool(shardID uint32, nonce uint64) + func (bthm *BlockTrackerHandlerMock) ComputeCrossInfo(headers []data.HeaderHandler) + func (bthm *BlockTrackerHandlerMock) ComputeLongestSelfChain() (data.HeaderHandler, []byte, []data.HeaderHandler, [][]byte) + func (bthm *BlockTrackerHandlerMock) GetSelfHeaders(headerHandler data.HeaderHandler) []*track.HeaderInfo + func (bthm *BlockTrackerHandlerMock) IsInterfaceNil() bool + func (bthm *BlockTrackerHandlerMock) SortHeadersFromNonce(shardID uint32, nonce uint64) ([]data.HeaderHandler, [][]byte) + type BlockTrackerMock 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 NewBlockTrackerMock(shardCoordinator sharding.Coordinator, ...) *BlockTrackerMock + func (btm *BlockTrackerMock) AddCrossNotarizedHeader(shardID uint32, crossNotarizedHeader data.HeaderHandler, ...) + func (btm *BlockTrackerMock) AddSelfNotarizedHeader(shardID uint32, selfNotarizedHeader data.HeaderHandler, ...) + func (btm *BlockTrackerMock) AddTrackedHeader(header data.HeaderHandler, hash []byte) + func (btm *BlockTrackerMock) CheckBlockAgainstFinal(headerHandler data.HeaderHandler) error + func (btm *BlockTrackerMock) CheckBlockAgainstRoundHandler(headerHandler data.HeaderHandler) error + func (btm *BlockTrackerMock) CheckBlockAgainstWhitelist(interceptedData process.InterceptedData) bool + func (btm *BlockTrackerMock) CleanupHeadersBehindNonce(shardID uint32, selfNotarizedNonce uint64, crossNotarizedNonce uint64) + func (btm *BlockTrackerMock) CleanupInvalidCrossHeaders(_ uint32, _ uint64) + func (btm *BlockTrackerMock) ComputeLongestChain(shardID uint32, header data.HeaderHandler) ([]data.HeaderHandler, [][]byte) + func (btm *BlockTrackerMock) ComputeLongestMetaChainFromLastNotarized() ([]data.HeaderHandler, [][]byte, error) + func (btm *BlockTrackerMock) ComputeLongestShardsChainsFromLastNotarized() ([]data.HeaderHandler, [][]byte, map[uint32][]data.HeaderHandler, error) + func (btm *BlockTrackerMock) DisplayTrackedHeaders() + func (btm *BlockTrackerMock) GetCrossNotarizedHeader(shardID uint32, offset uint64) (data.HeaderHandler, []byte, error) + func (btm *BlockTrackerMock) GetLastCrossNotarizedHeader(shardID uint32) (data.HeaderHandler, []byte, error) + func (btm *BlockTrackerMock) GetLastCrossNotarizedHeadersForAllShards() (map[uint32]data.HeaderHandler, error) + func (btm *BlockTrackerMock) GetLastSelfNotarizedHeader(shardID uint32) (data.HeaderHandler, []byte, error) + func (btm *BlockTrackerMock) GetSelfNotarizedHeader(shardID uint32, offset uint64) (data.HeaderHandler, []byte, error) + func (btm *BlockTrackerMock) GetTrackedHeaders(shardID uint32) ([]data.HeaderHandler, [][]byte) + func (btm *BlockTrackerMock) GetTrackedHeadersForAllShards() map[uint32][]data.HeaderHandler + func (btm *BlockTrackerMock) GetTrackedHeadersWithNonce(shardID uint32, nonce uint64) ([]data.HeaderHandler, [][]byte) + func (btm *BlockTrackerMock) InitNotarizedHeaders(startHeaders map[uint32]data.HeaderHandler) error + func (btm *BlockTrackerMock) IsInterfaceNil() bool + func (btm *BlockTrackerMock) IsShardStuck(shardId uint32) bool + func (btm *BlockTrackerMock) RegisterCrossNotarizedHeadersHandler(...) + func (btm *BlockTrackerMock) RegisterFinalMetachainHeadersHandler(...) + func (btm *BlockTrackerMock) RegisterSelfNotarizedFromCrossHeadersHandler(...) + func (btm *BlockTrackerMock) RegisterSelfNotarizedHeadersHandler(...) + func (btm *BlockTrackerMock) RemoveLastNotarizedHeaders() + func (btm *BlockTrackerMock) RestoreToGenesis() + func (btm *BlockTrackerMock) ShouldAddHeader(headerHandler data.HeaderHandler) bool + func (btm *BlockTrackerMock) ShouldSkipMiniBlocksCreationFromSelf() bool + type BoostrapStorerMock struct + GetCalled func(round int64) (bootstrapStorage.BootstrapData, error) + GetHighestRoundCalled func() int64 + PutCalled func(round int64, bootData bootstrapStorage.BootstrapData) error + SaveLastRoundCalled func(round int64) 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 BootstrapComponentsMock struct + Coordinator sharding.Coordinator + HdrIntegrityVerifier factory.HeaderIntegrityVerifierHandler + VersionedHdrFactory factory.VersionedHeaderFactory + func (bcm *BootstrapComponentsMock) HeaderIntegrityVerifier() factory.HeaderIntegrityVerifierHandler + func (bcm *BootstrapComponentsMock) IsInterfaceNil() bool + func (bcm *BootstrapComponentsMock) ShardCoordinator() sharding.Coordinator + func (bcm *BootstrapComponentsMock) VersionedHeaderFactory() factory.VersionedHeaderFactory + type BootstrapperStub struct + AddSyncStateListenerCalled func(func(bool)) + CreateAndCommitEmptyBlockCalled func(uint32) (data.BodyHandler, data.HeaderHandler, error) + GetNodeStateCalled func() common.NodeState + StartSyncingBlocksCalled func() + func (boot *BootstrapperStub) AddSyncStateListener(syncStateNotifier func(isSyncing bool)) + func (boot *BootstrapperStub) Close() error + func (boot *BootstrapperStub) CreateAndCommitEmptyBlock(shardForCurrentNode uint32) (data.BodyHandler, data.HeaderHandler, error) + func (boot *BootstrapperStub) GetNodeState() common.NodeState + func (boot *BootstrapperStub) IsInterfaceNil() bool + func (boot *BootstrapperStub) StartSyncingBlocks() + type BuiltInCostHandlerStub struct + func (b *BuiltInCostHandlerStub) ComputeBuiltInCost(_ data.TransactionWithFeeHandler) uint64 + func (b *BuiltInCostHandlerStub) IsBuiltInFuncCall(_ data.TransactionWithFeeHandler) bool + func (b *BuiltInCostHandlerStub) IsInterfaceNil() bool + type BuiltInFunctionStub struct + IsActiveCalled func() bool + ProcessBuiltinFunctionCalled func(acntSnd, acntDst vmcommon.UserAccountHandler, ...) (*vmcommon.VMOutput, error) + SetNewGasConfigCalled func(gasCost *vmcommon.GasCost) + func (b *BuiltInFunctionStub) IsActive() bool + func (b *BuiltInFunctionStub) IsInterfaceNil() bool + func (b *BuiltInFunctionStub) ProcessBuiltinFunction(acntSnd, acntDst vmcommon.UserAccountHandler, ...) (*vmcommon.VMOutput, error) + func (b *BuiltInFunctionStub) SetNewGasConfig(gasCost *vmcommon.GasCost) + 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 + SetEpochForPutOperationCalled func(epoch uint32) + func (csm *ChainStorerMock) AddStorer(key dataRetriever.UnitType, s storage.Storer) + func (csm *ChainStorerMock) CloseAll() error + func (csm *ChainStorerMock) Destroy() error + func (csm *ChainStorerMock) Get(unitType dataRetriever.UnitType, key []byte) ([]byte, error) + func (csm *ChainStorerMock) GetAll(unitType dataRetriever.UnitType, keys [][]byte) (map[string][]byte, error) + func (csm *ChainStorerMock) GetAllStorers() map[dataRetriever.UnitType]storage.Storer + func (csm *ChainStorerMock) GetStorer(unitType dataRetriever.UnitType) storage.Storer + func (csm *ChainStorerMock) Has(unitType dataRetriever.UnitType, key []byte) error + func (csm *ChainStorerMock) IsInterfaceNil() bool + func (csm *ChainStorerMock) Put(unitType dataRetriever.UnitType, key []byte, value []byte) error + func (csm *ChainStorerMock) SetEpochForPutOperation(epoch uint32) + type ChunkProcessorStub struct + CheckBatchCalled func(b *batch.Batch, w process.WhiteListHandler) (process.CheckedChunkResult, error) + CloseCalled func() error + func (c *ChunkProcessorStub) CheckBatch(b *batch.Batch, w process.WhiteListHandler) (process.CheckedChunkResult, error) + func (c *ChunkProcessorStub) Close() error + func (c *ChunkProcessorStub) IsInterfaceNil() bool + type CloserStub struct + CloseCalled func() error + func (cs *CloserStub) Close() error + type CoordinatorStub struct + CommunicationIdentifierCalled func(destShardID uint32) string + ComputeIdCalled func(address []byte) uint32 + NumberOfShardsCalled func() uint32 + SameShardCalled func(firstAddress, secondAddress []byte) bool + SelfIdCalled func() uint32 + func (coordinator *CoordinatorStub) CommunicationIdentifier(destShardID uint32) string + func (coordinator *CoordinatorStub) ComputeId(address []byte) uint32 + func (coordinator *CoordinatorStub) IsInterfaceNil() bool + func (coordinator *CoordinatorStub) NumberOfShards() uint32 + func (coordinator *CoordinatorStub) SameShard(firstAddress, secondAddress []byte) bool + func (coordinator *CoordinatorStub) SelfId() uint32 + type CoreComponentsMock struct + AddrPubKeyConv core.PubkeyConverter + ChainIdCalled func() string + ChanStopNode chan endProcess.ArgEndProcess + EconomicsDataField process.EconomicsDataHandler + EpochNotifierField process.EpochNotifier + GenesisNodesSetupCalled func() sharding.GenesisNodesSetupHandler + HardforkTriggerPubKeyField []byte + Hash hashing.Hasher + IntMarsh marshal.Marshalizer + MinTransactionVersionCalled func() uint32 + NodeTypeProviderField core.NodeTypeProviderHandler + PathHdl storage.PathManagerHandler + ProcessStatusHandlerField common.ProcessStatusHandler + RoundField consensus.RoundHandler + StatusField core.AppStatusHandler + TxMarsh marshal.Marshalizer + TxSignHasherField hashing.Hasher + TxVersionCheckField process.TxVersionCheckerHandler + UInt64ByteSliceConv typeConverters.Uint64ByteSliceConverter + ValPubKeyConv core.PubkeyConverter + func (ccm *CoreComponentsMock) AddressPubKeyConverter() core.PubkeyConverter + func (ccm *CoreComponentsMock) ChainID() string + func (ccm *CoreComponentsMock) ChanStopNodeProcess() chan endProcess.ArgEndProcess + func (ccm *CoreComponentsMock) EconomicsData() process.EconomicsDataHandler + func (ccm *CoreComponentsMock) EpochNotifier() process.EpochNotifier + func (ccm *CoreComponentsMock) GenesisNodesSetup() sharding.GenesisNodesSetupHandler + func (ccm *CoreComponentsMock) HardforkTriggerPubKey() []byte + func (ccm *CoreComponentsMock) Hasher() hashing.Hasher + func (ccm *CoreComponentsMock) InternalMarshalizer() marshal.Marshalizer + func (ccm *CoreComponentsMock) IsInterfaceNil() bool + func (ccm *CoreComponentsMock) MinTransactionVersion() uint32 + func (ccm *CoreComponentsMock) NodeTypeProvider() core.NodeTypeProviderHandler + func (ccm *CoreComponentsMock) PathHandler() storage.PathManagerHandler + func (ccm *CoreComponentsMock) ProcessStatusHandler() common.ProcessStatusHandler + func (ccm *CoreComponentsMock) RoundHandler() consensus.RoundHandler + func (ccm *CoreComponentsMock) SetInternalMarshalizer(m marshal.Marshalizer) error + func (ccm *CoreComponentsMock) StatusHandler() core.AppStatusHandler + func (ccm *CoreComponentsMock) TxMarshalizer() marshal.Marshalizer + func (ccm *CoreComponentsMock) TxSignHasher() hashing.Hasher + func (ccm *CoreComponentsMock) TxVersionChecker() process.TxVersionCheckerHandler + func (ccm *CoreComponentsMock) Uint64ByteSliceConverter() typeConverters.Uint64ByteSliceConverter + func (ccm *CoreComponentsMock) ValidatorPubKeyConverter() core.PubkeyConverter + type CryptoComponentsMock struct + BlKeyGen crypto.KeyGenerator + BlockSig crypto.SingleSigner + MultiSig crypto.MultiSigner + PeerSignHandler crypto.PeerSignatureHandler + PubKey crypto.PublicKey + TxKeyGen crypto.KeyGenerator + TxSig crypto.SingleSigner + func (ccm *CryptoComponentsMock) BlockSignKeyGen() crypto.KeyGenerator + func (ccm *CryptoComponentsMock) BlockSigner() crypto.SingleSigner + func (ccm *CryptoComponentsMock) Clone() interface{} + func (ccm *CryptoComponentsMock) IsInterfaceNil() bool + func (ccm *CryptoComponentsMock) MultiSigner() crypto.MultiSigner + func (ccm *CryptoComponentsMock) PeerSignatureHandler() crypto.PeerSignatureHandler + func (ccm *CryptoComponentsMock) PublicKey() crypto.PublicKey + func (ccm *CryptoComponentsMock) SetMultiSigner(multiSigner crypto.MultiSigner) error + func (ccm *CryptoComponentsMock) TxSignKeyGen() crypto.KeyGenerator + func (ccm *CryptoComponentsMock) TxSingleSigner() crypto.SingleSigner + type CurrentNetworkEpochSetterStub struct + SetCurrentEpochCalled func(epoch uint32) + func (c *CurrentNetworkEpochSetterStub) IsInterfaceNil() bool + func (c *CurrentNetworkEpochSetterStub) SetNetworkEpochAtBootstrap(epoch uint32) + type DataComponentsMock struct + BlockChain data.ChainHandler + DataPool dataRetriever.PoolsHolder + Storage dataRetriever.StorageService + func (dcm *DataComponentsMock) Blockchain() data.ChainHandler + func (dcm *DataComponentsMock) Clone() interface{} + func (dcm *DataComponentsMock) Datapool() dataRetriever.PoolsHolder + func (dcm *DataComponentsMock) IsInterfaceNil() bool + func (dcm *DataComponentsMock) StorageService() dataRetriever.StorageService + type DataTrieTrackerStub struct + ClearDataCachesCalled func() + DataTrieCalled func() common.Trie + DirtyDataCalled func() map[string][]byte + RetrieveValueCalled func(key []byte) ([]byte, error) + SaveKeyValueCalled func(key []byte, value []byte) error + SetDataTrieCalled func(tr common.Trie) + func (dtts *DataTrieTrackerStub) ClearDataCaches() + func (dtts *DataTrieTrackerStub) DataTrie() common.Trie + func (dtts *DataTrieTrackerStub) DirtyData() map[string][]byte + func (dtts *DataTrieTrackerStub) IsInterfaceNil() bool + func (dtts *DataTrieTrackerStub) RetrieveValue(key []byte) ([]byte, error) + func (dtts *DataTrieTrackerStub) SaveKeyValue(key []byte, value []byte) error + func (dtts *DataTrieTrackerStub) SetDataTrie(tr common.Trie) + type ESDTRoleHandlerStub struct + CheckAllowedToExecuteCalled func(account state.UserAccountHandler, tokenID []byte, action []byte) error + func (e *ESDTRoleHandlerStub) CheckAllowedToExecute(account state.UserAccountHandler, tokenID []byte, action []byte) error + func (e *ESDTRoleHandlerStub) IsInterfaceNil() bool + type EpochEconomicsStub struct + ComputeEndOfEpochEconomicsCalled func(metaBlock *block.MetaBlock) (*block.Economics, error) + VerifyRewardsPerBlockCalled func(metaBlock *block.MetaBlock, correctedProtocolSustainability *big.Int, ...) error + func (e *EpochEconomicsStub) ComputeEndOfEpochEconomics(metaBlock *block.MetaBlock) (*block.Economics, error) + func (e *EpochEconomicsStub) IsInterfaceNil() bool + func (e *EpochEconomicsStub) VerifyRewardsPerBlock(metaBlock *block.MetaBlock, correctedProtocolSustainability *big.Int, ...) error + type EpochRewardsCreatorStub struct + CreateMarshalizedDataCalled func(body *block.Body) map[string][][]byte + CreateRewardsMiniBlocksCalled func(metaBlock data.MetaHeaderHandler, ...) (block.MiniBlockSlice, error) + DeleteTxsFromStorageCalled func(metaBlock data.MetaHeaderHandler, body *block.Body) + GetLocalTxCacheCalled func() epochStart.TransactionCacher + GetProtocolSustainCalled func() *big.Int + GetRewardsTxsCalled func(body *block.Body) map[string]data.TransactionHandler + RemoveBlockDataFromPoolsCalled func(metaBlock data.MetaHeaderHandler, body *block.Body) + SaveTxBlockToStorageCalled func(metaBlock data.MetaHeaderHandler, body *block.Body) + VerifyRewardsMiniBlocksCalled func(metaBlock data.MetaHeaderHandler, ...) error + func (e *EpochRewardsCreatorStub) CreateMarshalizedData(body *block.Body) map[string][][]byte + func (e *EpochRewardsCreatorStub) CreateRewardsMiniBlocks(metaBlock data.MetaHeaderHandler, ...) (block.MiniBlockSlice, error) + func (e *EpochRewardsCreatorStub) DeleteTxsFromStorage(metaBlock data.MetaHeaderHandler, body *block.Body) + func (e *EpochRewardsCreatorStub) GetLocalTxCache() epochStart.TransactionCacher + func (e *EpochRewardsCreatorStub) GetProtocolSustainabilityRewards() *big.Int + func (e *EpochRewardsCreatorStub) GetRewardsTxs(body *block.Body) map[string]data.TransactionHandler + func (e *EpochRewardsCreatorStub) IsInterfaceNil() bool + func (e *EpochRewardsCreatorStub) RemoveBlockDataFromPools(metaBlock data.MetaHeaderHandler, body *block.Body) + func (e *EpochRewardsCreatorStub) SaveTxBlockToStorage(metaBlock data.MetaHeaderHandler, body *block.Body) + func (e *EpochRewardsCreatorStub) VerifyRewardsMiniBlocks(metaBlock data.MetaHeaderHandler, ...) error + type EpochStartDataCreatorStub struct + CreateEpochStartDataCalled func() (*block.EpochStart, error) + VerifyEpochStartDataForMetablockCalled func(metaBlock *block.MetaBlock) error + func (e *EpochStartDataCreatorStub) CreateEpochStartData() (*block.EpochStart, error) + func (e *EpochStartDataCreatorStub) IsInterfaceNil() bool + func (e *EpochStartDataCreatorStub) VerifyEpochStartDataForMetablock(metaBlock *block.MetaBlock) error + 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 EpochStartSystemSCStub struct + ProcessDelegationRewardsCalled func(miniBlocks block.MiniBlockSlice, txCache epochStart.TransactionCacher) error + ProcessSystemSmartContractCalled func(validatorInfos map[uint32][]*state.ValidatorInfo, nonce uint64, epoch uint32) error + ToggleUnStakeUnBondCalled func(value bool) error + func (e *EpochStartSystemSCStub) IsInterfaceNil() bool + func (e *EpochStartSystemSCStub) ProcessDelegationRewards(miniBlocks block.MiniBlockSlice, txCache epochStart.TransactionCacher) error + func (e *EpochStartSystemSCStub) ProcessSystemSmartContract(validatorInfos map[uint32][]*state.ValidatorInfo, nonce uint64, epoch uint32) error + func (e *EpochStartSystemSCStub) ToggleUnStakeUnBond(value bool) error + type EpochStartTriggerStub struct + EpochCalled func() uint32 + EpochFinalityAttestingRoundCalled func() uint64 + EpochStartMetaHdrHashCalled func() []byte + EpochStartRoundCalled func() uint64 + ForceEpochStartCalled func() error + 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() error + 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 EpochValidatorInfoCreatorStub struct + CreateMarshalizedDataCalled func(body block.Body) map[string][][]byte + CreateValidatorInfoMiniBlocksCalled func(validatorsInfo map[uint32][]*state.ValidatorInfo) (block.MiniBlockSlice, error) + DeleteTxsFromStorageCalled func(metaBlock data.HeaderHandler) + RemoveBlockDataFromPoolsCalled func(metaBlock data.HeaderHandler, body *block.Body) + SaveTxBlockToStorageCalled func(metaBlock data.HeaderHandler, body *block.Body) + VerifyValidatorInfoMiniBlocksCalled func(miniblocks []*block.MiniBlock, ...) error + func (e *EpochValidatorInfoCreatorStub) CreateValidatorInfoMiniBlocks(validatorInfo map[uint32][]*state.ValidatorInfo) (block.MiniBlockSlice, error) + func (e *EpochValidatorInfoCreatorStub) DeleteValidatorInfoBlocksFromStorage(metaBlock data.HeaderHandler) + func (e *EpochValidatorInfoCreatorStub) IsInterfaceNil() bool + func (e *EpochValidatorInfoCreatorStub) RemoveBlockDataFromPools(metaBlock data.HeaderHandler, body *block.Body) + func (e *EpochValidatorInfoCreatorStub) SaveValidatorInfoBlocksToStorage(metaBlock data.HeaderHandler, body *block.Body) + func (e *EpochValidatorInfoCreatorStub) VerifyValidatorInfoMiniBlocks(miniblocks []*block.MiniBlock, ...) error + type FeeAccumulatorStub struct + CreateBlockStartedCalled func(gasAndFees scheduled.GasAndFees) + GetAccumulatedFeesCalled func() *big.Int + GetDeveloperFeesCalled func() *big.Int + ProcessTransactionFeeCalled func(cost *big.Int, devFee *big.Int, hash []byte) + ProcessTransactionFeeRelayedUserTxCalled func(cost *big.Int, devFee *big.Int, userTxHash []byte, originalTxHash []byte) + RevertFeesCalled func(txHashes [][]byte) + func (f *FeeAccumulatorStub) CreateBlockStarted(gasAndFees scheduled.GasAndFees) + func (f *FeeAccumulatorStub) GetAccumulatedFees() *big.Int + func (f *FeeAccumulatorStub) GetDeveloperFees() *big.Int + func (f *FeeAccumulatorStub) IsInterfaceNil() bool + func (f *FeeAccumulatorStub) ProcessTransactionFee(cost *big.Int, devFee *big.Int, txHash []byte) + func (f *FeeAccumulatorStub) ProcessTransactionFeeRelayedUserTx(cost *big.Int, devFee *big.Int, userTxHash []byte, originalTxHash []byte) + func (f *FeeAccumulatorStub) RevertFees(txHashes [][]byte) + type FeeHandlerStub 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 + MaxGasLimitPerBlockCalled func() uint64 + MaxGasLimitPerBlockForSafeCrossShardCalled func() uint64 + MaxGasLimitPerMiniBlockCalled func() uint64 + MaxGasLimitPerMiniBlockForSafeCrossShardCalled func() uint64 + MaxGasLimitPerTxCalled func() uint64 + MinGasPriceCalled func() uint64 + MinGasPriceForProcessingCalled func() uint64 + SetMaxGasLimitPerBlockCalled func(maxGasLimitPerBlock uint64) + SetMinGasLimitCalled func(minGasLimit uint64) + SetMinGasPriceCalled func(minGasPrice uint64) + SplitTxGasInCategoriesCalled func(tx data.TransactionWithFeeHandler) (uint64, uint64) + func (fhs *FeeHandlerStub) CheckValidityTxValues(tx data.TransactionWithFeeHandler) error + func (fhs *FeeHandlerStub) ComputeFeeForProcessing(tx data.TransactionWithFeeHandler, gasToUse uint64) *big.Int + func (fhs *FeeHandlerStub) ComputeGasLimit(tx data.TransactionWithFeeHandler) uint64 + func (fhs *FeeHandlerStub) ComputeGasLimitBasedOnBalance(tx data.TransactionWithFeeHandler, balance *big.Int) (uint64, error) + func (fhs *FeeHandlerStub) ComputeGasUsedAndFeeBasedOnRefundValue(tx data.TransactionWithFeeHandler, refundValue *big.Int) (uint64, *big.Int) + func (fhs *FeeHandlerStub) ComputeMoveBalanceFee(tx data.TransactionWithFeeHandler) *big.Int + func (fhs *FeeHandlerStub) ComputeTxFee(tx data.TransactionWithFeeHandler) *big.Int + func (fhs *FeeHandlerStub) ComputeTxFeeBasedOnGasUsed(tx data.TransactionWithFeeHandler, gasUsed uint64) *big.Int + func (fhs *FeeHandlerStub) DeveloperPercentage() float64 + func (fhs *FeeHandlerStub) GasPerDataByte() uint64 + func (fhs *FeeHandlerStub) GasPriceForMove(tx data.TransactionWithFeeHandler) uint64 + func (fhs *FeeHandlerStub) GasPriceForProcessing(tx data.TransactionWithFeeHandler) uint64 + 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) MaxGasLimitPerBlockForSafeCrossShard() uint64 + func (fhs *FeeHandlerStub) MaxGasLimitPerMiniBlock(uint32) uint64 + func (fhs *FeeHandlerStub) MaxGasLimitPerMiniBlockForSafeCrossShard() uint64 + func (fhs *FeeHandlerStub) MaxGasLimitPerTx() uint64 + func (fhs *FeeHandlerStub) MinGasLimit() uint64 + func (fhs *FeeHandlerStub) MinGasPrice() uint64 + func (fhs *FeeHandlerStub) MinGasPriceForProcessing() uint64 + func (fhs *FeeHandlerStub) SetMaxGasLimitPerBlock(maxGasLimitPerBlock uint64) + func (fhs *FeeHandlerStub) SetMinGasLimit(minGasLimit uint64) + func (fhs *FeeHandlerStub) SetMinGasPrice(minGasPrice uint64) + func (fhs *FeeHandlerStub) SplitTxGasInCategories(tx data.TransactionWithFeeHandler) (uint64, uint64) + type FloodPreventerStub struct + ApplyConsensusSizeCalled func(size int) + IncreaseLoadCalled func(pid core.PeerID, size uint64) error + ResetCalled func() + func (fps *FloodPreventerStub) ApplyConsensusSize(size int) + func (fps *FloodPreventerStub) IncreaseLoad(pid core.PeerID, size uint64) error + func (fps *FloodPreventerStub) IsInterfaceNil() bool + func (fps *FloodPreventerStub) Reset() + 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 GasHandlerMock struct + ComputeGasProvidedByMiniBlockCalled func(miniBlock *block.MiniBlock, mapHashTx map[string]data.TransactionHandler) (uint64, uint64, error) + ComputeGasProvidedByTxCalled func(txSenderShardId uint32, txReceiverSharedId uint32, ...) (uint64, uint64, error) + GasPenalizedCalled func(hash []byte) uint64 + GasProvidedAsScheduledCalled func(hash []byte) uint64 + GasProvidedCalled func(hash []byte) uint64 + GasRefundedCalled func(hash []byte) uint64 + InitCalled func() + RemoveGasPenalizedCalled func(hashes [][]byte) + RemoveGasProvidedAsScheduledCalled func(hashes [][]byte) + RemoveGasProvidedCalled func(hashes [][]byte) + RemoveGasRefundedCalled func(hashes [][]byte) + ResetCalled func(key []byte) + RestoreGasSinceLastResetCalled func(key []byte) + SetGasPenalizedCalled func(gasPenalized uint64, hash []byte) + SetGasProvidedAsScheduledCalled func(gasProvided uint64, hash []byte) + SetGasProvidedCalled func(gasProvided uint64, hash []byte) + SetGasRefundedCalled func(gasRefunded uint64, hash []byte) + TotalGasPenalizedCalled func() uint64 + TotalGasProvidedAsScheduledCalled func() uint64 + TotalGasProvidedCalled func() uint64 + TotalGasProvidedWithScheduledCalled func() uint64 + TotalGasRefundedCalled func() uint64 + func (ghm *GasHandlerMock) ComputeGasProvidedByMiniBlock(miniBlock *block.MiniBlock, mapHashTx map[string]data.TransactionHandler) (uint64, uint64, error) + func (ghm *GasHandlerMock) ComputeGasProvidedByTx(txSenderShardId uint32, txReceiverShardId uint32, ...) (uint64, uint64, error) + func (ghm *GasHandlerMock) GasPenalized(hash []byte) uint64 + func (ghm *GasHandlerMock) GasProvided(hash []byte) uint64 + func (ghm *GasHandlerMock) GasProvidedAsScheduled(hash []byte) uint64 + func (ghm *GasHandlerMock) GasRefunded(hash []byte) uint64 + func (ghm *GasHandlerMock) Init() + func (ghm *GasHandlerMock) IsInterfaceNil() bool + func (ghm *GasHandlerMock) RemoveGasPenalized(hashes [][]byte) + func (ghm *GasHandlerMock) RemoveGasProvided(hashes [][]byte) + func (ghm *GasHandlerMock) RemoveGasProvidedAsScheduled(hashes [][]byte) + func (ghm *GasHandlerMock) RemoveGasRefunded(hashes [][]byte) + func (ghm *GasHandlerMock) Reset(key []byte) + func (ghm *GasHandlerMock) RestoreGasSinceLastReset(key []byte) + func (ghm *GasHandlerMock) SetGasPenalized(gasPenalized uint64, hash []byte) + func (ghm *GasHandlerMock) SetGasProvided(gasProvided uint64, hash []byte) + func (ghm *GasHandlerMock) SetGasProvidedAsScheduled(gasProvided uint64, hash []byte) + func (ghm *GasHandlerMock) SetGasRefunded(gasRefunded uint64, hash []byte) + func (ghm *GasHandlerMock) TotalGasPenalized() uint64 + func (ghm *GasHandlerMock) TotalGasProvided() uint64 + func (ghm *GasHandlerMock) TotalGasProvidedAsScheduled() uint64 + func (ghm *GasHandlerMock) TotalGasProvidedWithScheduled() uint64 + func (ghm *GasHandlerMock) TotalGasRefunded() uint64 + type GetHdrHandlerStub struct + HeaderHandlerCalled func() data.HeaderHandler + func (ghhs *GetHdrHandlerStub) HeaderHandler() data.HeaderHandler + type HasherStub struct + ComputeCalled func(s string) []byte + EmptyHashCalled func() []byte + func (hash *HasherStub) Compute(s string) []byte + func (hash *HasherStub) EmptyHash() []byte + func (hash *HasherStub) IsInterfaceNil() bool + func (hash *HasherStub) Size() int + 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 HeaderResolverMock struct + 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 + func (hrm *HeaderResolverMock) IsInterfaceNil() bool + func (hrm *HeaderResolverMock) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error + func (hrm *HeaderResolverMock) RequestDataFromEpoch(identifier []byte) error + func (hrm *HeaderResolverMock) RequestDataFromHash(hash []byte, epoch uint32) error + func (hrm *HeaderResolverMock) RequestDataFromNonce(nonce uint64, epoch uint32) error + func (hrm *HeaderResolverMock) SetEpochHandler(epochHandler dataRetriever.EpochHandler) 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 InterceptedDataFactoryStub struct + CreateCalled func(buff []byte) (process.InterceptedData, error) + func (idfs *InterceptedDataFactoryStub) Create(buff []byte) (process.InterceptedData, error) + func (idfs *InterceptedDataFactoryStub) IsInterfaceNil() bool + type InterceptedDataVerifierMock struct + func (i *InterceptedDataVerifierMock) IsForCurrentShard(_ process.InterceptedData) bool + func (i *InterceptedDataVerifierMock) IsInterfaceNil() bool + type InterceptedDebugHandlerStub struct + LogProcessedHashesCalled func(topic string, hashes [][]byte, err error) + LogReceivedHashesCalled func(topic string, hashes [][]byte) + func (idhs *InterceptedDebugHandlerStub) IsInterfaceNil() bool + func (idhs *InterceptedDebugHandlerStub) LogProcessedHashes(topic string, hashes [][]byte, err error) + func (idhs *InterceptedDebugHandlerStub) LogReceivedHashes(topic string, hashes [][]byte) + type InterceptedTrieNodeStub struct + CheckValidityCalled func() error + HashField []byte + IdentifiersField [][]byte + IsForCurrentShardCalled func() bool + SizeInBytesCalled func() int + StringField string + TypeField string + func (ins *InterceptedTrieNodeStub) CheckValidity() error + func (ins *InterceptedTrieNodeStub) Hash() []byte + func (ins *InterceptedTrieNodeStub) Identifiers() [][]byte + func (ins *InterceptedTrieNodeStub) IsForCurrentShard() bool + func (ins *InterceptedTrieNodeStub) IsInterfaceNil() bool + func (ins *InterceptedTrieNodeStub) SizeInBytes() int + func (ins *InterceptedTrieNodeStub) String() string + func (ins *InterceptedTrieNodeStub) Type() string + type InterceptedTxHandlerStub struct + FeeCalled func() *big.Int + NonceCalled func() uint64 + ReceiverShardIdCalled func() uint32 + SenderAddressCalled func() []byte + SenderShardIdCalled func() uint32 + TransactionCalled func() data.TransactionHandler + func (iths *InterceptedTxHandlerStub) Fee() *big.Int + func (iths *InterceptedTxHandlerStub) Nonce() uint64 + func (iths *InterceptedTxHandlerStub) ReceiverShardId() uint32 + func (iths *InterceptedTxHandlerStub) SenderAddress() []byte + func (iths *InterceptedTxHandlerStub) SenderShardId() uint32 + func (iths *InterceptedTxHandlerStub) Transaction() data.TransactionHandler + type InterceptorProcessorStub struct + RegisterHandlerCalled func(handler func(topic string, hash []byte, data interface{})) + SaveCalled func(data process.InterceptedData) error + ValidateCalled func(data process.InterceptedData) error + func (ips *InterceptorProcessorStub) IsInterfaceNil() bool + func (ips *InterceptorProcessorStub) RegisterHandler(handler func(topic string, hash []byte, data interface{})) + func (ips *InterceptorProcessorStub) Save(data process.InterceptedData, _ core.PeerID, _ string) error + func (ips *InterceptorProcessorStub) Validate(data process.InterceptedData, _ core.PeerID) error + type InterceptorThrottlerStub struct + CanProcessCalled func() bool + func (its *InterceptorThrottlerStub) CanProcess() bool + func (its *InterceptorThrottlerStub) EndProcessing() + func (its *InterceptorThrottlerStub) EndProcessingCount() int32 + func (its *InterceptorThrottlerStub) IsInterfaceNil() bool + func (its *InterceptorThrottlerStub) StartProcessing() + func (its *InterceptorThrottlerStub) StartProcessingCount() int32 + type InterimProcessorContainerMock struct + GetCalled func(key block.Type) (process.IntermediateTransactionHandler, error) + KeysCalled func() []block.Type + func (ipcm *InterimProcessorContainerMock) Add(_ block.Type, _ process.IntermediateTransactionHandler) error + func (ipcm *InterimProcessorContainerMock) AddMultiple(_ []block.Type, _ []process.IntermediateTransactionHandler) error + func (ipcm *InterimProcessorContainerMock) Get(key block.Type) (process.IntermediateTransactionHandler, error) + func (ipcm *InterimProcessorContainerMock) IsInterfaceNil() bool + func (ipcm *InterimProcessorContainerMock) Keys() []block.Type + func (ipcm *InterimProcessorContainerMock) Len() int + func (ipcm *InterimProcessorContainerMock) Remove(_ block.Type) + func (ipcm *InterimProcessorContainerMock) Replace(_ block.Type, _ process.IntermediateTransactionHandler) 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 IntermediateTransactionHandlerMock 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 + GetCreatedInShardMiniBlockCalled func() *block.MiniBlock + GetNumOfCrossInterMbsAndTxsCalled func() (int, int) + InitProcessedResultsCalled func(key []byte) + RemoveProcessedResultsCalled func(key []byte) [][]byte + SaveCurrentIntermediateTxToStorageCalled func() + VerifyInterMiniBlocksCalled func(body *block.Body) error + func (ith *IntermediateTransactionHandlerMock) AddIntermediateTransactions(txs []data.TransactionHandler) error + func (ith *IntermediateTransactionHandlerMock) CreateAllInterMiniBlocks() []*block.MiniBlock + func (ith *IntermediateTransactionHandlerMock) CreateBlockStarted() + func (ith *IntermediateTransactionHandlerMock) CreateMarshalizedData(txHashes [][]byte) ([][]byte, error) + func (ith *IntermediateTransactionHandlerMock) GetAllCurrentFinishedTxs() map[string]data.TransactionHandler + func (ith *IntermediateTransactionHandlerMock) GetCreatedInShardMiniBlock() *block.MiniBlock + func (ith *IntermediateTransactionHandlerMock) GetIntermediateTransactions() []data.TransactionHandler + func (ith *IntermediateTransactionHandlerMock) GetNumOfCrossInterMbsAndTxs() (int, int) + func (ith *IntermediateTransactionHandlerMock) InitProcessedResults(key []byte) + func (ith *IntermediateTransactionHandlerMock) IsInterfaceNil() bool + func (ith *IntermediateTransactionHandlerMock) RemoveProcessedResults(key []byte) [][]byte + func (ith *IntermediateTransactionHandlerMock) SaveCurrentIntermediateTxToStorage() + func (ith *IntermediateTransactionHandlerMock) VerifyInterMiniBlocks(body *block.Body) 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) + InitProcessedResultsCalled func(key []byte) + RemoveProcessedResultsCalled func(key []byte) [][]byte + SaveCurrentIntermediateTxToStorageCalled func() + 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) InitProcessedResults(key []byte) + func (ith *IntermediateTransactionHandlerStub) IsInterfaceNil() bool + func (ith *IntermediateTransactionHandlerStub) RemoveProcessedResults(key []byte) [][]byte + func (ith *IntermediateTransactionHandlerStub) SaveCurrentIntermediateTxToStorage() + func (ith *IntermediateTransactionHandlerStub) VerifyInterMiniBlocks(body *block.Body) error + type MarshalizerMock struct + Fail bool + func (mm *MarshalizerMock) IsInterfaceNil() bool + func (mm *MarshalizerMock) Marshal(obj interface{}) ([]byte, error) + func (mm *MarshalizerMock) Unmarshal(obj interface{}, buff []byte) error + type MarshalizerStub struct + MarshalCalled func(obj interface{}) ([]byte, error) + UnmarshalCalled func(obj interface{}, buff []byte) error + func (ms *MarshalizerStub) IsInterfaceNil() bool + func (ms *MarshalizerStub) Marshal(obj interface{}) ([]byte, error) + func (ms *MarshalizerStub) Unmarshal(obj interface{}, buff []byte) error + type MessageHandlerStub struct + ConnectedPeersOnTopicCalled func(topic string) []core.PeerID + SendToConnectedPeerCalled func(topic string, buff []byte, peerID core.PeerID) error + func (mhs *MessageHandlerStub) ConnectedPeersOnTopic(topic string) []core.PeerID + func (mhs *MessageHandlerStub) IsInterfaceNil() bool + func (mhs *MessageHandlerStub) SendToConnectedPeer(topic string, buff []byte, peerID core.PeerID) error + type MessageSignVerifierMock struct + func (m *MessageSignVerifierMock) IsInterfaceNil() bool + func (m *MessageSignVerifierMock) Verify(_ []byte, _ []byte, _ []byte) error + type MessengerStub struct + AddressesCalled func() []string + BootstrapCalled func() error + BroadcastCalled func(topic string, buff []byte) + BroadcastOnChannelCalled func(channel string, topic string, buff []byte) + CloseCalled func() error + ConnectToPeerCalled func(address string) error + ConnectedPeersCalled func() []core.PeerID + CreateTopicCalled func(name string, createChannelForTopic bool) error + HasTopicCalled func(name string) bool + HasTopicValidatorCalled func(name string) bool + IDCalled func() core.PeerID + IsConnectedCalled func(peerID core.PeerID) bool + OutgoingChannelLoadBalancerCalled func() p2p.ChannelLoadBalancer + PeersCalled func() []core.PeerID + RegisterMessageProcessorCalled func(topic string, handler p2p.MessageProcessor) error + SendToConnectedPeerCalled func(topic string, buff []byte, peerID core.PeerID) error + TrimConnectionsCalled func() + UnregisterMessageProcessorCalled func(topic string) error + func (ms *MessengerStub) Addresses() []string + 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) Close() error + func (ms *MessengerStub) ConnectToPeer(address string) error + func (ms *MessengerStub) ConnectedPeers() []core.PeerID + func (ms *MessengerStub) ConnectedPeersOnTopic(_ string) []core.PeerID + 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) IsConnected(peerID core.PeerID) bool + func (ms *MessengerStub) IsInterfaceNil() bool + func (ms *MessengerStub) OutgoingChannelLoadBalancer() p2p.ChannelLoadBalancer + func (ms *MessengerStub) Peers() []core.PeerID + func (ms *MessengerStub) RegisterMessageProcessor(topic string, handler p2p.MessageProcessor) error + func (ms *MessengerStub) SendToConnectedPeer(topic string, buff []byte, peerID core.PeerID) error + func (ms *MessengerStub) TrimConnections() + func (ms *MessengerStub) UnjoinAllTopics() error + func (ms *MessengerStub) UnregisterAllMessageProcessors() error + func (ms *MessengerStub) UnregisterMessageProcessor(topic string) 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 NetworkConnectionWatcherStub struct + IsConnectedToTheNetworkCalled func() bool + func (cws *NetworkConnectionWatcherStub) IsConnectedToTheNetwork() bool + func (cws *NetworkConnectionWatcherStub) IsInterfaceNil() bool + type NodeInfoMock struct + func NewNodeInfo(address []byte, pubKey []byte, shardId uint32, initialRating uint32) *NodeInfoMock + func (n *NodeInfoMock) AddressBytes() []byte + func (n *NodeInfoMock) AssignedShard() uint32 + func (n *NodeInfoMock) GetInitialRating() uint32 + func (n *NodeInfoMock) IsInterfaceNil() bool + func (n *NodeInfoMock) PubKeyBytes() []byte + type NodesConfigProviderStub struct + MinNumberOfNodesCalled func() uint32 + MinNumberOfNodesWithHysteresisCalled func() uint32 + func (n *NodesConfigProviderStub) IsInterfaceNil() bool + func (n *NodesConfigProviderStub) MinNumberOfNodes() uint32 + func (n *NodesConfigProviderStub) MinNumberOfNodesWithHysteresis() uint32 + type NodesCoordinatorStub struct + GetValidatorWithPublicKeyCalled func(publicKey []byte) (validator nodesCoordinator.Validator, shardId uint32, err error) + func (nc *NodesCoordinatorStub) GetValidatorWithPublicKey(publicKey []byte) (validator nodesCoordinator.Validator, shardId uint32, err error) + func (nc *NodesCoordinatorStub) IsInterfaceNil() bool + type NodesSetupStub struct + AllInitialNodesCalled func() []nodesCoordinator.GenesisNodeInfoHandler + GetAdaptivityCalled func() bool + GetHysteresisCalled func() float32 + GetMetaConsensusGroupSizeCalled func() uint32 + GetRoundDurationCalled func() uint64 + GetShardConsensusGroupSizeCalled func() uint32 + GetShardIDForPubKeyCalled func(pubkey []byte) (uint32, error) + GetStartTimeCalled func() int64 + InitialEligibleNodesPubKeysForShardCalled func(shardId uint32) ([]string, error) + InitialNodesInfoCalled func() (map[uint32][]nodesCoordinator.GenesisNodeInfoHandler, ...) + InitialNodesInfoForShardCalled func(shardId uint32) ([]nodesCoordinator.GenesisNodeInfoHandler, ...) + InitialNodesPubKeysCalled func() map[uint32][]string + MinNumberOfMetaNodesCalled func() uint32 + MinNumberOfNodesCalled func() uint32 + MinNumberOfNodesWithHysteresisCalled func() uint32 + MinNumberOfShardNodesCalled func() uint32 + NumberOfShardsCalled func() uint32 + func (n *NodesSetupStub) AllInitialNodes() []nodesCoordinator.GenesisNodeInfoHandler + func (n *NodesSetupStub) GetAdaptivity() bool + func (n *NodesSetupStub) GetHysteresis() float32 + func (n *NodesSetupStub) GetMetaConsensusGroupSize() uint32 + func (n *NodesSetupStub) GetRoundDuration() uint64 + func (n *NodesSetupStub) GetShardConsensusGroupSize() uint32 + func (n *NodesSetupStub) GetShardIDForPubKey(pubkey []byte) (uint32, error) + func (n *NodesSetupStub) GetStartTime() int64 + func (n *NodesSetupStub) InitialEligibleNodesPubKeysForShard(shardId uint32) ([]string, error) + func (n *NodesSetupStub) InitialNodesInfo() (map[uint32][]nodesCoordinator.GenesisNodeInfoHandler, ...) + func (n *NodesSetupStub) InitialNodesInfoForShard(shardId uint32) ([]nodesCoordinator.GenesisNodeInfoHandler, ...) + func (n *NodesSetupStub) InitialNodesPubKeys() map[uint32][]string + func (n *NodesSetupStub) IsInterfaceNil() bool + func (n *NodesSetupStub) MinNumberOfMetaNodes() uint32 + func (n *NodesSetupStub) MinNumberOfNodes() uint32 + func (n *NodesSetupStub) MinNumberOfNodesWithHysteresis() uint32 + func (n *NodesSetupStub) MinNumberOfShardNodes() uint32 + func (n *NodesSetupStub) NumberOfShards() uint32 + type ObjectsContainerStub struct + AddCalled func(key string, val interface{}) error + GetCalled func(key string) (interface{}, error) + LenCalled func() int + RemoveCalled func(key string) + ReplaceCalled func(key string, val interface{}) error + func (ocs *ObjectsContainerStub) Add(key string, val interface{}) error + func (ocs *ObjectsContainerStub) Get(key string) (interface{}, error) + func (ocs *ObjectsContainerStub) Len() int + func (ocs *ObjectsContainerStub) Remove(key string) + func (ocs *ObjectsContainerStub) Replace(key string, val interface{}) 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 + IsOriginatorEligibleForTopicCalled func(pid core.PeerID, topic string) error + SetDebuggerCalled func(debugger process.AntifloodDebugger) error + func (af *P2PAntifloodHandlerStub) Close() 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) IsOriginatorEligibleForTopic(pid core.PeerID, topic string) error + func (p2pahs *P2PAntifloodHandlerStub) SetDebugger(debugger process.AntifloodDebugger) error + type P2PMessageMock struct + DataField []byte + FromField []byte + KeyField []byte + PayloadField []byte + PeerField core.PeerID + SeqNoField []byte + SignatureField []byte + TimestampField int64 + TopicField string + func (msg *P2PMessageMock) Data() []byte + func (msg *P2PMessageMock) From() []byte + func (msg *P2PMessageMock) IsInterfaceNil() bool + func (msg *P2PMessageMock) Key() []byte + func (msg *P2PMessageMock) Payload() []byte + func (msg *P2PMessageMock) Peer() core.PeerID + func (msg *P2PMessageMock) SeqNo() []byte + func (msg *P2PMessageMock) Signature() []byte + func (msg *P2PMessageMock) Timestamp() int64 + func (msg *P2PMessageMock) Topic() string + type PauseHandlerStub struct + IsPausedCalled func(token []byte) bool + func (p *PauseHandlerStub) IsInterfaceNil() bool + func (p *PauseHandlerStub) IsPaused(token []byte) bool + type PayableHandlerStub struct + IsPayableCalled func(sndAddress []byte, recvAdress []byte) (bool, error) + func (p *PayableHandlerStub) IsInterfaceNil() bool + func (p *PayableHandlerStub) IsPayable(sndAddress []byte, recvAddress []byte) (bool, error) + type PeerAccountHandlerMock struct + DecreaseLeaderSuccessRateCalled func(uint32) + DecreaseLeaderSuccessRateValue uint32 + DecreaseValidatorSuccessRateCalled func(uint32) + DecreaseValidatorSuccessRateValue uint32 + GetAccumulatedFeesCalled func() *big.Int + GetConsecutiveProposerMissesCalled func() uint32 + GetListCalled func() string + GetTempRatingCalled func() uint32 + GetUnStakedEpochCalled func() uint32 + IncreaseLeaderSuccessRateCalled func(uint32) + IncreaseLeaderSuccessRateValue uint32 + IncreaseValidatorIgnoredSignaturesRateCalled func(uint32) + IncreaseValidatorIgnoredSignaturesValue uint32 + IncreaseValidatorSuccessRateCalled func(uint32) + IncreaseValidatorSuccessRateValue uint32 + SetAccumulatedFeesCalled func(*big.Int) + SetConsecutiveProposerMissesCalled func(rating uint32) + SetListAndIndexCalled func(shardID uint32, list string, index uint32) + SetTempRatingCalled func(uint32) + func (p *PeerAccountHandlerMock) AddToAccumulatedFees(val *big.Int) + func (p *PeerAccountHandlerMock) AddressBytes() []byte + func (p *PeerAccountHandlerMock) DataTrie() common.Trie + func (p *PeerAccountHandlerMock) DataTrieTracker() state.DataTrieTracker + func (p *PeerAccountHandlerMock) DecreaseLeaderSuccessRate(val uint32) + func (p *PeerAccountHandlerMock) DecreaseValidatorSuccessRate(val uint32) + func (p *PeerAccountHandlerMock) GetAccumulatedFees() *big.Int + func (p *PeerAccountHandlerMock) GetBLSPublicKey() []byte + func (p *PeerAccountHandlerMock) GetCode() []byte + func (p *PeerAccountHandlerMock) GetCodeHash() []byte + func (p *PeerAccountHandlerMock) GetConsecutiveProposerMisses() uint32 + func (p *PeerAccountHandlerMock) GetIndexInList() uint32 + func (p *PeerAccountHandlerMock) GetLeaderSuccessRate() state.SignRate + func (p *PeerAccountHandlerMock) GetList() string + func (p *PeerAccountHandlerMock) GetNonce() uint64 + func (p *PeerAccountHandlerMock) GetNumSelectedInSuccessBlocks() uint32 + func (p *PeerAccountHandlerMock) GetRating() uint32 + func (p *PeerAccountHandlerMock) GetRewardAddress() []byte + func (p *PeerAccountHandlerMock) GetRootHash() []byte + func (p *PeerAccountHandlerMock) GetShardId() uint32 + func (p *PeerAccountHandlerMock) GetStake() *big.Int + func (p *PeerAccountHandlerMock) GetTempRating() uint32 + func (p *PeerAccountHandlerMock) GetTotalLeaderSuccessRate() state.SignRate + func (p *PeerAccountHandlerMock) GetTotalValidatorIgnoredSignaturesRate() uint32 + func (p *PeerAccountHandlerMock) GetTotalValidatorSuccessRate() state.SignRate + func (p *PeerAccountHandlerMock) GetUnStakedEpoch() uint32 + func (p *PeerAccountHandlerMock) GetValidatorIgnoredSignaturesRate() uint32 + func (p *PeerAccountHandlerMock) GetValidatorSuccessRate() state.SignRate + func (p *PeerAccountHandlerMock) IncreaseLeaderSuccessRate(val uint32) + func (p *PeerAccountHandlerMock) IncreaseNonce(_ uint64) + func (p *PeerAccountHandlerMock) IncreaseNumSelectedInSuccessBlocks() + func (p *PeerAccountHandlerMock) IncreaseValidatorIgnoredSignaturesRate(val uint32) + func (p *PeerAccountHandlerMock) IncreaseValidatorSuccessRate(val uint32) + func (p *PeerAccountHandlerMock) IsInterfaceNil() bool + func (p *PeerAccountHandlerMock) ResetAtNewEpoch() + func (p *PeerAccountHandlerMock) SetBLSPublicKey([]byte) error + func (p *PeerAccountHandlerMock) SetCode(_ []byte) + func (p *PeerAccountHandlerMock) SetCodeHash(_ []byte) + func (p *PeerAccountHandlerMock) SetConsecutiveProposerMisses(consecutiveMisses uint32) + func (p *PeerAccountHandlerMock) SetDataTrie(_ common.Trie) + func (p *PeerAccountHandlerMock) SetListAndIndex(shardID uint32, list string, index uint32) + func (p *PeerAccountHandlerMock) SetRating(uint32) + func (p *PeerAccountHandlerMock) SetRewardAddress([]byte) error + func (p *PeerAccountHandlerMock) SetRootHash([]byte) + func (p *PeerAccountHandlerMock) SetStake(_ *big.Int) error + func (p *PeerAccountHandlerMock) SetTempRating(val uint32) + func (p *PeerAccountHandlerMock) SetUnStakedEpoch(_ uint32) + 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 PeerChangesHandler struct + PeerChangesCalled func() []block.PeerData + VerifyPeerChangesCalled func(peerChanges []block.PeerData) error + func (p *PeerChangesHandler) IsInterfaceNil() bool + func (p *PeerChangesHandler) PeerChanges() []block.PeerData + func (p *PeerChangesHandler) VerifyPeerChanges(peerChanges []block.PeerData) error + type PeerShardMapperStub struct + GetLastKnownPeerIDCalled func(pk []byte) (core.PeerID, bool) + GetPeerInfoCalled func(pid core.PeerID) core.P2PPeerInfo + PutPeerIdShardIdCalled func(pid core.PeerID, shardId uint32) + PutPeerIdSubTypeCalled func(pid core.PeerID, peerSubType core.P2PPeerSubType) + UpdatePeerIDPublicKeyPairCalled func(pid core.PeerID, pk []byte) + UpdatePeerIdPublicKeyCalled func(pid core.PeerID, pk []byte) + UpdatePublicKeyShardIdCalled func(pk []byte, shardId uint32) + func (psms *PeerShardMapperStub) GetLastKnownPeerID(pk []byte) (core.PeerID, bool) + func (psms *PeerShardMapperStub) GetPeerInfo(pid core.PeerID) core.P2PPeerInfo + func (psms *PeerShardMapperStub) IsInterfaceNil() bool + func (psms *PeerShardMapperStub) PutPeerIdShardId(pid core.PeerID, shardId uint32) + func (psms *PeerShardMapperStub) PutPeerIdSubType(pid core.PeerID, peerSubType core.P2PPeerSubType) + func (psms *PeerShardMapperStub) UpdatePeerIDPublicKeyPair(pid core.PeerID, pk []byte) + func (psms *PeerShardMapperStub) UpdatePeerIdPublicKey(pid core.PeerID, pk []byte) + func (psms *PeerShardMapperStub) UpdatePublicKeyShardId(pk []byte, shardId uint32) + type PeerShardResolverStub struct + GetPeerInfoCalled func(pid core.PeerID) core.P2PPeerInfo + func (psrs *PeerShardResolverStub) GetPeerInfo(pid core.PeerID) core.P2PPeerInfo + func (psrs *PeerShardResolverStub) IsInterfaceNil() bool + type PeerSignatureHandlerStub struct + GetPeerSignatureCalled func(key crypto.PrivateKey, pid []byte) ([]byte, error) + VerifyPeerSignatureCalled func(pk []byte, pid core.PeerID, signature []byte) error + func (pshs *PeerSignatureHandlerStub) GetPeerSignature(key crypto.PrivateKey, pid []byte) ([]byte, error) + func (pshs *PeerSignatureHandlerStub) IsInterfaceNil() bool + func (pshs *PeerSignatureHandlerStub) VerifyPeerSignature(pk []byte, pid core.PeerID, signature []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 PreProcessorContainerMock struct + GetCalled func(key block.Type) (process.PreProcessor, error) + KeysCalled func() []block.Type + func (ppcm *PreProcessorContainerMock) Add(_ block.Type, _ process.PreProcessor) error + func (ppcm *PreProcessorContainerMock) AddMultiple(_ []block.Type, _ []process.PreProcessor) error + func (ppcm *PreProcessorContainerMock) Get(key block.Type) (process.PreProcessor, error) + func (ppcm *PreProcessorContainerMock) IsInterfaceNil() bool + func (ppcm *PreProcessorContainerMock) Keys() []block.Type + func (ppcm *PreProcessorContainerMock) Len() int + func (ppcm *PreProcessorContainerMock) Remove(_ block.Type) + func (ppcm *PreProcessorContainerMock) Replace(_ block.Type, _ process.PreProcessor) error + type PreProcessorMock struct + AddTransactionsCalled func(txHandlers []data.TransactionHandler) + AddTxsFromMiniBlocksCalled func(miniBlocks block.MiniBlockSlice) + CreateAndProcessMiniBlocksCalled func(haveTime func() bool) (block.MiniBlockSlice, error) + CreateBlockStartedCalled func() + CreateMarshalizedDataCalled func(txHashes [][]byte) ([][]byte, error) + GetAllCurrentUsedTxsCalled func() map[string]data.TransactionHandler + IsDataPreparedCalled func(requestedTxs int, haveTime func() time.Duration) error + ProcessBlockTransactionsCalled func(header data.HeaderHandler, body *block.Body, haveTime func() bool) error + ProcessMiniBlockCalled func(miniBlock *block.MiniBlock, haveTime func() bool, ...) ([][]byte, int, bool, error) + RemoveBlockDataFromPoolsCalled func(body *block.Body, miniBlockPool storage.Cacher) error + RemoveTxsFromPoolsCalled func(body *block.Body) error + RequestBlockTransactionsCalled func(body *block.Body) int + RequestTransactionsForMiniBlockCalled func(miniBlock *block.MiniBlock) int + RestoreBlockDataIntoPoolsCalled func(body *block.Body, miniBlockPool storage.Cacher) (int, error) + SaveTxsToStorageCalled func(body *block.Body) error + func (ppm *PreProcessorMock) AddTransactions(txHandlers []data.TransactionHandler) + func (ppm *PreProcessorMock) AddTxsFromMiniBlocks(miniBlocks block.MiniBlockSlice) + func (ppm *PreProcessorMock) CreateAndProcessMiniBlocks(haveTime func() bool, _ []byte) (block.MiniBlockSlice, error) + func (ppm *PreProcessorMock) CreateBlockStarted() + func (ppm *PreProcessorMock) CreateMarshalizedData(txHashes [][]byte) ([][]byte, error) + func (ppm *PreProcessorMock) GetAllCurrentUsedTxs() map[string]data.TransactionHandler + func (ppm *PreProcessorMock) IsDataPrepared(requestedTxs int, haveTime func() time.Duration) error + func (ppm *PreProcessorMock) IsInterfaceNil() bool + func (ppm *PreProcessorMock) ProcessBlockTransactions(header data.HeaderHandler, body *block.Body, haveTime func() bool) error + func (ppm *PreProcessorMock) ProcessMiniBlock(miniBlock *block.MiniBlock, haveTime func() bool, ...) ([][]byte, int, bool, error) + func (ppm *PreProcessorMock) RemoveBlockDataFromPools(body *block.Body, miniBlockPool storage.Cacher) error + func (ppm *PreProcessorMock) RemoveTxsFromPools(body *block.Body) error + func (ppm *PreProcessorMock) RequestBlockTransactions(body *block.Body) int + func (ppm *PreProcessorMock) RequestTransactionsForMiniBlock(miniBlock *block.MiniBlock) int + func (ppm *PreProcessorMock) RestoreBlockDataIntoPools(body *block.Body, miniBlockPool storage.Cacher) (int, error) + func (ppm *PreProcessorMock) SaveTxsToStorage(body *block.Body) error + type ProtobufMarshalizerMock struct + func (x *ProtobufMarshalizerMock) IsInterfaceNil() bool + func (x *ProtobufMarshalizerMock) Marshal(obj interface{}) ([]byte, error) + func (x *ProtobufMarshalizerMock) Unmarshal(obj interface{}, buff []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 QuotaStatusHandlerStub struct + AddQuotaCalled func(pid core.PeerID, numReceivedMessages uint32, sizeReceivedMessages uint64, ...) + ResetStatisticsCalled func() + func (qshs *QuotaStatusHandlerStub) AddQuota(pid core.PeerID, numReceived uint32, sizeReceived uint64, numProcessed uint32, ...) + func (qshs *QuotaStatusHandlerStub) IsInterfaceNil() bool + func (qshs *QuotaStatusHandlerStub) ResetStatistics() + type RaterMock struct + Chance uint32 + ComputeDecreaseProposerCalled func(shardId uint32, rating uint32, consecutiveMissedBlocks uint32) uint32 + ComputeDecreaseValidatorCalled func(shardId uint32, rating uint32) uint32 + ComputeIncreaseProposerCalled func(shardId uint32, rating uint32) uint32 + ComputeIncreaseValidatorCalled func(shardId uint32, rating uint32) uint32 + DecreaseProposer int32 + DecreaseValidator int32 + GetChancesCalled func(val uint32) uint32 + GetRatingCalled func(string) uint32 + GetSignedBlocksThresholdCalled func() float32 + GetStartRatingCalled func() uint32 + IncreaseProposer int32 + IncreaseValidator int32 + MaxRating uint32 + MetaDecreaseProposer int32 + MetaDecreaseValidator int32 + MetaIncreaseProposer int32 + MetaIncreaseValidator int32 + MinRating uint32 + RevertIncreaseProposerCalled func(shardId uint32, rating uint32, nrReverts uint32) uint32 + StartRating uint32 + func GetNewMockRater() *RaterMock + func (rm *RaterMock) ComputeDecreaseProposer(shardId uint32, currentRating uint32, consecutiveMisses uint32) uint32 + func (rm *RaterMock) ComputeDecreaseValidator(shardId uint32, currentRating uint32) uint32 + func (rm *RaterMock) ComputeIncreaseProposer(shardId uint32, currentRating uint32) uint32 + func (rm *RaterMock) ComputeIncreaseValidator(shardId uint32, currentRating uint32) uint32 + func (rm *RaterMock) GetChance(rating uint32) uint32 + func (rm *RaterMock) GetRating(pk string) uint32 + func (rm *RaterMock) GetSignedBlocksThreshold() float32 + func (rm *RaterMock) GetStartRating() uint32 + func (rm *RaterMock) IsInterfaceNil() bool + func (rm *RaterMock) RevertIncreaseValidator(shardId uint32, currentRating uint32, nrReverts uint32) uint32 + type RatingReaderMock struct + GetRatingCalled func(string) uint32 + RatingsMap map[string]uint32 + func (rrm *RatingReaderMock) GetRating(pk string) uint32 + func (rrm *RatingReaderMock) IsInterfaceNil() bool + type RatingStepMock struct + ConsecutiveMissedBlocksPenaltyProperty float32 + ProposerDecreaseRatingStepProperty int32 + ProposerIncreaseRatingStepProperty int32 + ValidatorDecreaseRatingStepProperty int32 + ValidatorIncreaseRatingStepProperty int32 + func (rd *RatingStepMock) ConsecutiveMissedBlocksPenalty() float32 + func (rd *RatingStepMock) ProposerDecreaseRatingStep() int32 + func (rd *RatingStepMock) ProposerIncreaseRatingStep() int32 + func (rd *RatingStepMock) ValidatorDecreaseRatingStep() int32 + func (rd *RatingStepMock) ValidatorIncreaseRatingStep() int32 + type RatingsInfoMock struct + MaxRatingProperty uint32 + MetaRatingsStepDataProperty process.RatingsStepHandler + MinRatingProperty uint32 + SelectionChancesProperty []process.SelectionChance + ShardRatingsStepDataProperty process.RatingsStepHandler + SignedBlocksThresholdProperty float32 + StartRatingProperty uint32 + func (rd *RatingsInfoMock) IsInterfaceNil() bool + func (rd *RatingsInfoMock) MaxRating() uint32 + func (rd *RatingsInfoMock) MetaChainRatingsStepHandler() process.RatingsStepHandler + func (rd *RatingsInfoMock) MinRating() uint32 + func (rd *RatingsInfoMock) SelectionChances() []process.SelectionChance + func (rd *RatingsInfoMock) ShardChainRatingsStepHandler() process.RatingsStepHandler + func (rd *RatingsInfoMock) SignedBlocksThreshold() float32 + func (rd *RatingsInfoMock) StartRating() uint32 + type RequestedItemsHandlerStub struct + AddCalled func(key string) error + HasCalled func(key string) bool + SweepCalled func() + func (rihs *RequestedItemsHandlerStub) Add(key string) error + func (rihs *RequestedItemsHandlerStub) Has(key string) bool + func (rihs *RequestedItemsHandlerStub) IsInterfaceNil() bool + func (rihs *RequestedItemsHandlerStub) Sweep() + type ResolverStub struct + ProcessReceivedMessageCalled func(message p2p.MessageP2P) error + RequestDataFromHashCalled func(hash []byte, epoch uint32) error + func (rs *ResolverStub) IsInterfaceNil() bool + func (rs *ResolverStub) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error + func (rs *ResolverStub) RequestDataFromHash(hash []byte, epoch uint32) error + type ResolversContainerStub struct + AddCalled func(key string, val dataRetriever.Resolver) error + GetCalled func(key string) (dataRetriever.Resolver, error) + LenCalled func() int + RemoveCalled func(key string) + ReplaceCalled func(key string, val dataRetriever.Resolver) error + func (rcs *ResolversContainerStub) Add(key string, val dataRetriever.Resolver) error + func (rcs *ResolversContainerStub) AddMultiple(_ []string, _ []dataRetriever.Resolver) error + func (rcs *ResolversContainerStub) Get(key string) (dataRetriever.Resolver, error) + func (rcs *ResolversContainerStub) IsInterfaceNil() bool + func (rcs *ResolversContainerStub) Len() int + func (rcs *ResolversContainerStub) Remove(key string) + func (rcs *ResolversContainerStub) Replace(key string, val dataRetriever.Resolver) error + type ResolversFinderStub struct + CrossShardResolverCalled func(baseTopic string, crossShard uint32) (dataRetriever.Resolver, error) + IntraShardResolverCalled func(baseTopic string) (dataRetriever.Resolver, error) + MetaChainResolverCalled func(baseTopic string) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) CrossShardResolver(baseTopic string, crossShard uint32) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) IntraShardResolver(baseTopic string) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) MetaChainResolver(baseTopic string) (dataRetriever.Resolver, error) + type RewardsHandlerMock struct + LeaderPercentageCalled func() float64 + MaxInflationRateCalled func() float64 + MinInflationRateCalled func() float64 + ProtocolSustainabilityAddressCalled func() string + ProtocolSustainabilityPercentageCalled func() float64 + RewardsTopUpFactorCalled func() float64 + RewardsTopUpGradientPointCalled func() *big.Int + func (rhm *RewardsHandlerMock) IsInterfaceNil() bool + func (rhm *RewardsHandlerMock) LeaderPercentage() float64 + func (rhm *RewardsHandlerMock) MaxInflationRate(uint32) float64 + func (rhm *RewardsHandlerMock) MinInflationRate() float64 + func (rhm *RewardsHandlerMock) ProtocolSustainabilityAddress() string + func (rhm *RewardsHandlerMock) ProtocolSustainabilityPercentage() float64 + func (rhm *RewardsHandlerMock) RewardsTopUpFactor() float64 + func (rhm *RewardsHandlerMock) RewardsTopUpGradientPoint() *big.Int + type RoundHandlerMock struct + BeforeGenesisCalled func() bool + RoundIndex int64 + RoundTimeDuration time.Duration + RoundTimeStamp time.Time + func (rndm *RoundHandlerMock) BeforeGenesis() bool + func (rndm *RoundHandlerMock) Index() int64 + func (rndm *RoundHandlerMock) IsInterfaceNil() bool + func (rndm *RoundHandlerMock) RemainingTime(_ time.Time, _ time.Duration) time.Duration + func (rndm *RoundHandlerMock) TimeDuration() time.Duration + func (rndm *RoundHandlerMock) TimeStamp() time.Time + func (rndm *RoundHandlerMock) UpdateRound(genesisRoundTimeStamp time.Time, timeStamp time.Time) + type RoundNotifierStub struct + CheckRoundCalled func(round uint64) + func (rns *RoundNotifierStub) CheckRound(round uint64) + func (rns *RoundNotifierStub) IsInterfaceNil() bool + func (rns *RoundNotifierStub) RegisterNotifyHandler(process.RoundSubscriberHandler) + type RoundStub struct + IndexCalled func() int64 + RemainingTimeCalled func(time.Time, time.Duration) time.Duration + TimeDurationCalled func() time.Duration + TimeStampCalled func() time.Time + UpdateRoundCalled func(time.Time, time.Time) + func (rnds *RoundStub) Index() int64 + func (rnds *RoundStub) IsInterfaceNil() bool + func (rnds *RoundStub) RemainingTime(startTime time.Time, maxTime time.Duration) time.Duration + func (rnds *RoundStub) TimeDuration() time.Duration + func (rnds *RoundStub) TimeStamp() time.Time + func (rnds *RoundStub) UpdateRound(genesisRoundTimeStamp time.Time, timeStamp time.Time) + type SCToProtocolStub struct + UpdateProtocolCalled func(body *block.Body, nonce uint64) error + func (s *SCToProtocolStub) IsInterfaceNil() bool + func (s *SCToProtocolStub) UpdateProtocol(body *block.Body, nonce uint64) error + type ScQueryStub struct + CloseCalled func() error + ComputeScCallGasLimitHandler func(tx *transaction.Transaction) (uint64, error) + ExecuteQueryCalled func(query *process.SCQuery) (*vmcommon.VMOutput, error) + func (s *ScQueryStub) Close() error + func (s *ScQueryStub) ComputeScCallGasLimit(tx *transaction.Transaction) (uint64, error) + func (s *ScQueryStub) ExecuteQuery(query *process.SCQuery) (*vmcommon.VMOutput, error) + func (s *ScQueryStub) IsInterfaceNil() bool + type ShardCoordinatorStub struct + CommunicationIdentifierCalled func(destShardID uint32) string + ComputeIdCalled func(address []byte) uint32 + NumberOfShardsCalled func() uint32 + SameShardCalled func(firstAddress, secondAddress []byte) bool + SelfIdCalled func() uint32 + func (coordinator *ShardCoordinatorStub) CommunicationIdentifier(destShardID uint32) string + func (coordinator *ShardCoordinatorStub) ComputeId(address []byte) uint32 + func (coordinator *ShardCoordinatorStub) IsInterfaceNil() bool + func (coordinator *ShardCoordinatorStub) NumberOfShards() uint32 + func (coordinator *ShardCoordinatorStub) SameShard(firstAddress, secondAddress []byte) bool + func (coordinator *ShardCoordinatorStub) SelfId() uint32 + type ShardIdHasMapMock struct + DeleteCalled func(shardId uint32) + LoadCalled func(shardId uint32) ([]byte, bool) + RangeCalled func(f func(shardId uint32, hash []byte) bool) + StoreCalled func(shardId uint32, hash []byte) + func (sihsm *ShardIdHasMapMock) Delete(shardId uint32) + func (sihsm *ShardIdHasMapMock) IsInterfaceNil() bool + func (sihsm *ShardIdHasMapMock) Load(shardId uint32) ([]byte, bool) + func (sihsm *ShardIdHasMapMock) Range(f func(shardId uint32, hash []byte) bool) + func (sihsm *ShardIdHasMapMock) Store(shardId uint32, hash []byte) + type SignaturesHandlerStub struct + VerifyCalled func(payload []byte, pid core.PeerID, signature []byte) error + func (s *SignaturesHandlerStub) IsInterfaceNil() bool + func (s *SignaturesHandlerStub) Verify(payload []byte, pid core.PeerID, signature []byte) error + type SignerMock struct + SignStub func(private crypto.PrivateKey, msg []byte) ([]byte, error) + VerifyStub func(public crypto.PublicKey, msg []byte, sig []byte) error + func (s *SignerMock) IsInterfaceNil() bool + func (s *SignerMock) Sign(private crypto.PrivateKey, msg []byte) ([]byte, error) + func (s *SignerMock) Verify(public crypto.PublicKey, msg []byte, sig []byte) error + type SingleSignKeyGenMock struct + PublicKeyFromByteArrayCalled func(b []byte) (crypto.PublicKey, error) + SuiteCalled func() crypto.Suite + func (sskgm *SingleSignKeyGenMock) CheckPublicKeyValid(_ []byte) error + func (sskgm *SingleSignKeyGenMock) GeneratePair() (crypto.PrivateKey, crypto.PublicKey) + func (sskgm *SingleSignKeyGenMock) IsInterfaceNil() bool + func (sskgm *SingleSignKeyGenMock) PrivateKeyFromByteArray(_ []byte) (crypto.PrivateKey, error) + func (sskgm *SingleSignKeyGenMock) PublicKeyFromByteArray(b []byte) (crypto.PublicKey, error) + func (sskgm *SingleSignKeyGenMock) Suite() crypto.Suite + type SingleSignPublicKey struct + PointCalled func() crypto.Point + SuiteCalled func() crypto.Suite + func (sspk *SingleSignPublicKey) IsInterfaceNil() bool + func (sspk *SingleSignPublicKey) Point() crypto.Point + func (sspk *SingleSignPublicKey) Suite() crypto.Suite + func (sspk *SingleSignPublicKey) ToByteArray() ([]byte, error) + type StatusComponentsMock struct + Outport outport.OutportHandler + func (scm *StatusComponentsMock) IsInterfaceNil() bool + func (scm *StatusComponentsMock) OutportHandler() outport.OutportHandler + type StorageBootstrapperMock struct + LoadFromStorageCalled func() error + func (sbm *StorageBootstrapperMock) GetHighestBlockNonce() uint64 + func (sbm *StorageBootstrapperMock) IsInterfaceNil() bool + func (sbm *StorageBootstrapperMock) LoadFromStorage() error + 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) ([]storage.KeyValuePair, error) + func (sm *StorerMock) GetFromEpoch(key []byte, _ uint32) ([]byte, error) + func (sm *StorerMock) GetOldestEpoch() (uint32, error) + func (sm *StorerMock) Has(_ []byte) 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(key []byte, val []byte) bool) + func (sm *StorerMock) Remove(key []byte) error + func (sm *StorerMock) RemoveFromCurrentEpoch(key []byte) error + func (sm *StorerMock) SearchFirst(_ []byte) ([]byte, error) + type SyncStarterStub struct + SyncBlockCalled func() error + func (sss *SyncStarterStub) SyncBlock(_ context.Context) error + type SyncTimerMock struct + ClockOffsetCalled func() time.Duration + CurrentTimeCalled func() time.Time + func (stm *SyncTimerMock) Close() error + func (stm *SyncTimerMock) IsInterfaceNil() bool + func (stm SyncTimerMock) ClockOffset() time.Duration + func (stm SyncTimerMock) CurrentTime() time.Time + func (stm SyncTimerMock) FormattedCurrentTime() string + func (stm SyncTimerMock) StartSyncingTime() + type TopicAntiFloodStub struct + IncreaseLoadCalled func(pid core.PeerID, topic string, numMessages uint32) error + ResetForTopicCalled func(topic string) + SetMaxMessagesForTopicCalled func(topic string, num uint32) + func (t *TopicAntiFloodStub) IncreaseLoad(pid core.PeerID, topic string, numMessages uint32) error + func (t *TopicAntiFloodStub) IsInterfaceNil() bool + func (t *TopicAntiFloodStub) ResetForNotRegisteredTopics() + func (t *TopicAntiFloodStub) ResetForTopic(topic string) + func (t *TopicAntiFloodStub) SetMaxMessagesForTopic(topic string, num uint32) + type TopicHandlerStub struct + CreateTopicCalled func(name string, createChannelForTopic bool) error + HasTopicCalled func(name string) bool + IDCalled func() core.PeerID + RegisterMessageProcessorCalled func(topic string, identifier string, handler p2p.MessageProcessor) error + func (ths *TopicHandlerStub) CreateTopic(name string, createChannelForTopic bool) error + func (ths *TopicHandlerStub) HasTopic(name string) bool + func (ths *TopicHandlerStub) ID() core.PeerID + func (ths *TopicHandlerStub) IsInterfaceNil() bool + func (ths *TopicHandlerStub) RegisterMessageProcessor(topic string, identifier string, handler p2p.MessageProcessor) error + type TransactionCoordinatorMock struct + AddIntermediateTransactionsCalled func(mapSCRs map[block.Type][]data.TransactionHandler) error + AddTransactionsCalled func(txHandlers []data.TransactionHandler, blockType block.Type) + AddTxsFromMiniBlocksCalled func(miniBlocks block.MiniBlockSlice) + ComputeTransactionTypeCalled func(tx data.TransactionHandler) (process.TransactionType, process.TransactionType) + CreateBlockStartedCalled func() + CreateMarshalizedDataCalled func(body *block.Body) map[string][][]byte + CreateMbsAndProcessCrossShardTransactionsDstMeCalled func(header data.HeaderHandler, ...) (block.MiniBlockSlice, uint32, bool, error) + CreateMbsAndProcessTransactionsFromMeCalled func(haveTime func() bool) block.MiniBlockSlice + CreatePostProcessMiniBlocksCalled func() block.MiniBlockSlice + GetAllCurrentUsedTxsCalled func(blockType block.Type) map[string]data.TransactionHandler + GetAllIntermediateTxsCalled func() map[block.Type]map[string]data.TransactionHandler + GetCreatedInShardMiniBlocksCalled func() []*block.MiniBlock + IsDataPreparedForProcessingCalled func(haveTime func() time.Duration) error + ProcessBlockTransactionCalled func(header data.HeaderHandler, body *block.Body, haveTime func() time.Duration) error + RemoveBlockDataFromPoolCalled func(body *block.Body) error + RemoveTxsFromPoolCalled func(body *block.Body) error + RequestBlockTransactionsCalled func(body *block.Body) + RequestMiniBlocksCalled func(header data.HeaderHandler) + RestoreBlockDataFromStorageCalled func(body *block.Body) (int, error) + SaveTxsToStorageCalled func(body *block.Body) + VerifyCreatedBlockTransactionsCalled func(hdr data.HeaderHandler, body *block.Body) error + VerifyCreatedMiniBlocksCalled func(hdr data.HeaderHandler, body *block.Body) error + func (tcm *TransactionCoordinatorMock) AddIntermediateTransactions(mapSCRs map[block.Type][]data.TransactionHandler) error + func (tcm *TransactionCoordinatorMock) AddTransactions(txHandlers []data.TransactionHandler, blockType block.Type) + func (tcm *TransactionCoordinatorMock) AddTxsFromMiniBlocks(miniBlocks block.MiniBlockSlice) + func (tcm *TransactionCoordinatorMock) ComputeTransactionType(tx data.TransactionHandler) (process.TransactionType, process.TransactionType) + func (tcm *TransactionCoordinatorMock) CreateBlockStarted() + func (tcm *TransactionCoordinatorMock) CreateMarshalizedData(body *block.Body) map[string][][]byte + func (tcm *TransactionCoordinatorMock) CreateMbsAndProcessCrossShardTransactionsDstMe(header data.HeaderHandler, ...) (block.MiniBlockSlice, uint32, bool, error) + func (tcm *TransactionCoordinatorMock) CreateMbsAndProcessTransactionsFromMe(haveTime func() bool, _ []byte) block.MiniBlockSlice + func (tcm *TransactionCoordinatorMock) CreatePostProcessMiniBlocks() block.MiniBlockSlice + func (tcm *TransactionCoordinatorMock) CreateReceiptsHash() ([]byte, error) + func (tcm *TransactionCoordinatorMock) GetAllCurrentLogs() []*data.LogData + func (tcm *TransactionCoordinatorMock) GetAllCurrentUsedTxs(blockType block.Type) map[string]data.TransactionHandler + func (tcm *TransactionCoordinatorMock) GetAllIntermediateTxs() map[block.Type]map[string]data.TransactionHandler + func (tcm *TransactionCoordinatorMock) GetCreatedInShardMiniBlocks() []*block.MiniBlock + func (tcm *TransactionCoordinatorMock) IsDataPreparedForProcessing(haveTime func() time.Duration) error + func (tcm *TransactionCoordinatorMock) IsInterfaceNil() bool + func (tcm *TransactionCoordinatorMock) ProcessBlockTransaction(header data.HeaderHandler, body *block.Body, haveTime func() time.Duration) error + func (tcm *TransactionCoordinatorMock) RemoveBlockDataFromPool(body *block.Body) error + func (tcm *TransactionCoordinatorMock) RemoveTxsFromPool(body *block.Body) error + func (tcm *TransactionCoordinatorMock) RequestBlockTransactions(body *block.Body) + func (tcm *TransactionCoordinatorMock) RequestMiniBlocks(header data.HeaderHandler) + func (tcm *TransactionCoordinatorMock) RestoreBlockDataFromStorage(body *block.Body) (int, error) + func (tcm *TransactionCoordinatorMock) SaveTxsToStorage(body *block.Body) + func (tcm *TransactionCoordinatorMock) VerifyCreatedBlockTransactions(hdr data.HeaderHandler, body *block.Body) error + func (tcm *TransactionCoordinatorMock) VerifyCreatedMiniBlocks(hdr data.HeaderHandler, body *block.Body) error + type TransactionInterceptorMock struct + IsAddressedToOtherShardsVal bool + IsChecked bool + IsVerified bool + RcvShardVal uint32 + SndShardVal uint32 + Tx *transaction.Transaction + func (tim *TransactionInterceptorMock) Check() bool + func (tim *TransactionInterceptorMock) GetTransaction() *transaction.Transaction + func (tim *TransactionInterceptorMock) Hash() []byte + func (tim *TransactionInterceptorMock) ID() string + func (tim *TransactionInterceptorMock) IsAddressedToOtherShards() bool + func (tim *TransactionInterceptorMock) IsInterfaceNil() bool + func (tim *TransactionInterceptorMock) PubkeyConverter() core.PubkeyConverter + func (tim *TransactionInterceptorMock) RcvShard() uint32 + func (tim *TransactionInterceptorMock) SetHash(hash []byte) + func (tim *TransactionInterceptorMock) SetPubkeyConverter(converter core.PubkeyConverter) + func (tim *TransactionInterceptorMock) SndShard() uint32 + func (tim *TransactionInterceptorMock) VerifySig() bool + type TransactionPoolMock struct + MiniPoolTxStoreCalled func(shardID uint32) (c storage.Cacher) + RegisterTransactionHandlerCalled func(transactionHandler func(txHash []byte)) + RemoveTransactionsFromPoolCalled func(txHashes [][]byte, destShardID uint32) + func (tpm *TransactionPoolMock) MiniPoolTxStore(shardID uint32) (c storage.Cacher) + func (tpm *TransactionPoolMock) RegisterTransactionHandler(transactionHandler func(txHash []byte)) + func (tpm *TransactionPoolMock) RemoveTransactionsFromPool(txHashes [][]byte, destShardID uint32) + type TransactionSimulatorStub struct + ProcessTxCalled func(tx *transaction.Transaction) (*txSimData.SimulationResults, error) + func (tss *TransactionSimulatorStub) IsInterfaceNil() bool + func (tss *TransactionSimulatorStub) ProcessTx(tx *transaction.Transaction) (*txSimData.SimulationResults, error) + type TxForCurrentBlockStub struct + AddTxCalled func(txHash []byte, tx data.TransactionHandler) + CleanCalled func() + GetTxCalled func(txHash []byte) (data.TransactionHandler, error) + func (t *TxForCurrentBlockStub) AddTx(txHash []byte, tx data.TransactionHandler) + func (t *TxForCurrentBlockStub) Clean() + func (t *TxForCurrentBlockStub) GetTx(txHash []byte) (data.TransactionHandler, error) + func (t *TxForCurrentBlockStub) IsInterfaceNil() bool + type TxLogsProcessorStub struct + GetAllCurrentLogsCalled func() []*data.LogData + GetLogCalled func(txHash []byte) (data.LogHandler, error) + SaveLogCalled func(txHash []byte, tx data.TransactionHandler, vmLogs []*vmcommon.LogEntry) error + func (txls *TxLogsProcessorStub) Clean() + func (txls *TxLogsProcessorStub) GetAllCurrentLogs() []*data.LogData + func (txls *TxLogsProcessorStub) GetLog(txHash []byte) (data.LogHandler, error) + func (txls *TxLogsProcessorStub) IsInterfaceNil() bool + func (txls *TxLogsProcessorStub) SaveLog(txHash []byte, tx data.TransactionHandler, vmLogs []*vmcommon.LogEntry) error + type TxValidatorHandlerStub struct + FeeCalled func() *big.Int + NonceCalled func() uint64 + ReceiverShardIdCalled func() uint32 + SenderAddressCalled func() []byte + SenderShardIdCalled func() uint32 + func (tvhs *TxValidatorHandlerStub) Fee() *big.Int + func (tvhs *TxValidatorHandlerStub) Nonce() uint64 + func (tvhs *TxValidatorHandlerStub) ReceiverShardId() uint32 + func (tvhs *TxValidatorHandlerStub) SenderAddress() []byte + func (tvhs *TxValidatorHandlerStub) SenderShardId() uint32 + type TxValidatorStub struct + CheckTxValidityCalled func(txValidatorHandler process.TxValidatorHandler) error + CheckTxWhiteListCalled func(data process.InterceptedData) error + RejectedTxsCalled func() uint64 + func (t *TxValidatorStub) CheckTxValidity(txValidatorHandler process.TxValidatorHandler) error + func (t *TxValidatorStub) CheckTxWhiteList(data process.InterceptedData) error + func (t *TxValidatorStub) IsInterfaceNil() bool + type Uint64ByteSliceConverterMock struct + ToByteSliceCalled func(uint64) []byte + ToUint64Called func([]byte) (uint64, error) + func (u *Uint64ByteSliceConverterMock) IsInterfaceNil() bool + func (u *Uint64ByteSliceConverterMock) ToByteSlice(p uint64) []byte + func (u *Uint64ByteSliceConverterMock) ToUint64(p []byte) (uint64, error) + type Uint64SyncMapCacherStub struct + ClearCalled func() + GetCalled func(nonce uint64) (dataRetriever.ShardIdHashMap, bool) + HasCalled func(nonce uint64, shardId uint32) bool + MergeCalled func(nonce uint64, src dataRetriever.ShardIdHashMap) + RegisterHandlerCalled func(handler func(nonce uint64, shardId uint32, value []byte)) + RemoveCalled func(nonce uint64, shardId uint32) + UnRegisterHandlerCalled func(func(key []byte, value interface{})) + func (usmcs *Uint64SyncMapCacherStub) Clear() + func (usmcs *Uint64SyncMapCacherStub) Get(nonce uint64) (dataRetriever.ShardIdHashMap, bool) + func (usmcs *Uint64SyncMapCacherStub) Has(nonce uint64, shardId uint32) bool + func (usmcs *Uint64SyncMapCacherStub) IsInterfaceNil() bool + func (usmcs *Uint64SyncMapCacherStub) Merge(nonce uint64, src dataRetriever.ShardIdHashMap) + func (usmcs *Uint64SyncMapCacherStub) RegisterHandler(handler func(nonce uint64, shardId uint32, value []byte)) + func (usmcs *Uint64SyncMapCacherStub) Remove(nonce uint64, shardId uint32) + func (usmcs *Uint64SyncMapCacherStub) UnRegisterHandler(handler func(key []byte, value interface{})) + 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 + CloseCalled func() error + GasScheduleChangeCalled func(gasSchedule 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(gasSchedule 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 ValidatorSettingsStub struct + func (v *ValidatorSettingsStub) GenesisNodePrice() *big.Int + func (v *ValidatorSettingsStub) IsInterfaceNil() bool + func (v *ValidatorSettingsStub) UnBondPeriod() uint64 + type ValidatorStatisticsProcessorStub struct + CommitCalled func() ([]byte, error) + GetPeerAccountCalled func(address []byte) (state.PeerAccountHandler, error) + GetValidatorInfoForRootHashCalled func(rootHash []byte) (map[uint32][]*state.ValidatorInfo, error) + LastFinalizedRootHashCalled func() []byte + 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 ValidityAttesterStub struct + CheckBlockAgainstFinalCalled func(headerHandler data.HeaderHandler) error + CheckBlockAgainstRoundHandlerCalled func(headerHandler data.HeaderHandler) error + CheckBlockAgainstWhitelistCalled func(interceptedData process.InterceptedData) bool + func (vas *ValidityAttesterStub) CheckBlockAgainstFinal(headerHandler data.HeaderHandler) error + func (vas *ValidityAttesterStub) CheckBlockAgainstRoundHandler(headerHandler data.HeaderHandler) error + func (vas *ValidityAttesterStub) CheckBlockAgainstWhitelist(interceptedData process.InterceptedData) bool + func (vas *ValidityAttesterStub) IsInterfaceNil() bool