Versions in this module Expand all Collapse all v1 v1.999.0 Nov 17, 2022 Changes in this version + var ErrMockMarshalizer = errors.New("MarshalizerMock generic error") + func InitChronologyHandlerMock() consensus.ChronologyHandler + func InitKeys() (*KeyGenMock, *PrivateKeyMock, *PublicKeyMock) + func InitMultiSignerMock() *cryptoMocks.MultisignerMock + type AlarmSchedulerStub struct + AddCalled func(func(alarmID string), time.Duration, string) + CancelCalled func(string) + CloseCalled func() + ResetCalled func(string) + func (a *AlarmSchedulerStub) Add(callback func(alarmID string), duration time.Duration, alarmID string) + func (a *AlarmSchedulerStub) Cancel(alarmID string) + func (a *AlarmSchedulerStub) Close() + func (a *AlarmSchedulerStub) IsInterfaceNil() bool + func (a *AlarmSchedulerStub) Reset(alarmID string) + 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 InitBlockProcessorHeaderV2Mock() *BlockProcessorMock + func InitBlockProcessorMock() *BlockProcessorMock + 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) 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 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 BroadcastMessengerMock struct + BroadcastBlockCalled func(data.BodyHandler, data.HeaderHandler) error + BroadcastBlockDataLeaderCalled func(h data.HeaderHandler, mbs map[uint32][]byte, txs map[string][][]byte) error + BroadcastConsensusMessageCalled func(*consensus.Message) error + BroadcastHeaderCalled func(data.HeaderHandler) error + BroadcastMiniBlocksCalled func(map[uint32][]byte) error + BroadcastTransactionsCalled func(map[string][][]byte) error + PrepareBroadcastBlockDataValidatorCalled func(h data.HeaderHandler, mbs map[uint32][]byte, txs map[string][][]byte, idx int) error + PrepareBroadcastHeaderValidatorCalled func(h data.HeaderHandler, mbs map[uint32][]byte, txs map[string][][]byte, idx int) + func (bmm *BroadcastMessengerMock) BroadcastBlock(bodyHandler data.BodyHandler, headerhandler data.HeaderHandler) error + func (bmm *BroadcastMessengerMock) BroadcastBlockDataLeader(header data.HeaderHandler, miniBlocks map[uint32][]byte, ...) error + func (bmm *BroadcastMessengerMock) BroadcastConsensusMessage(message *consensus.Message) error + func (bmm *BroadcastMessengerMock) BroadcastHeader(headerhandler data.HeaderHandler) error + func (bmm *BroadcastMessengerMock) BroadcastMiniBlocks(miniBlocks map[uint32][]byte) error + func (bmm *BroadcastMessengerMock) BroadcastTransactions(transactions map[string][][]byte) error + func (bmm *BroadcastMessengerMock) IsInterfaceNil() bool + func (bmm *BroadcastMessengerMock) PrepareBroadcastBlockDataValidator(header data.HeaderHandler, miniBlocks map[uint32][]byte, ...) + func (bmm *BroadcastMessengerMock) PrepareBroadcastHeaderValidator(header data.HeaderHandler, miniBlocks map[uint32][]byte, ...) + type ChronologyHandlerMock struct + AddSubroundCalled func(consensus.SubroundHandler) + EpochCalled func() uint32 + RemoveAllSubroundsCalled func() + StartRoundCalled func() + func (chrm *ChronologyHandlerMock) AddSubround(subroundHandler consensus.SubroundHandler) + func (chrm *ChronologyHandlerMock) Close() error + func (chrm *ChronologyHandlerMock) Epoch() uint32 + func (chrm *ChronologyHandlerMock) IsInterfaceNil() bool + func (chrm *ChronologyHandlerMock) RemoveAllSubrounds() + func (chrm *ChronologyHandlerMock) StartRounds() + type ConsensusCoreMock struct + func InitConsensusCore() *ConsensusCoreMock + func InitConsensusCoreHeaderV2() *ConsensusCoreMock + func InitConsensusCoreWithMultiSigner(multiSigner crypto.MultiSigner) *ConsensusCoreMock + func (ccm *ConsensusCoreMock) BlockProcessor() process.BlockProcessor + func (ccm *ConsensusCoreMock) Blockchain() data.ChainHandler + func (ccm *ConsensusCoreMock) BootStrapper() process.Bootstrapper + func (ccm *ConsensusCoreMock) BroadcastMessenger() consensus.BroadcastMessenger + func (ccm *ConsensusCoreMock) Chronology() consensus.ChronologyHandler + func (ccm *ConsensusCoreMock) EpochStartRegistrationHandler() epochStart.RegistrationHandler + func (ccm *ConsensusCoreMock) FallbackHeaderValidator() consensus.FallbackHeaderValidator + func (ccm *ConsensusCoreMock) GetAntiFloodHandler() consensus.P2PAntifloodHandler + func (ccm *ConsensusCoreMock) Hasher() hashing.Hasher + func (ccm *ConsensusCoreMock) HeaderSigVerifier() consensus.HeaderSigVerifier + func (ccm *ConsensusCoreMock) HeadersPoolSubscriber() consensus.HeadersPoolSubscriber + func (ccm *ConsensusCoreMock) IsInterfaceNil() bool + func (ccm *ConsensusCoreMock) Marshalizer() marshal.Marshalizer + func (ccm *ConsensusCoreMock) MultiSigner() crypto.MultiSigner + func (ccm *ConsensusCoreMock) NodeRedundancyHandler() consensus.NodeRedundancyHandler + func (ccm *ConsensusCoreMock) NodesCoordinator() nodesCoordinator.NodesCoordinator + func (ccm *ConsensusCoreMock) PeerHonestyHandler() consensus.PeerHonestyHandler + func (ccm *ConsensusCoreMock) PrivateKey() crypto.PrivateKey + func (ccm *ConsensusCoreMock) RoundHandler() consensus.RoundHandler + func (ccm *ConsensusCoreMock) ScheduledProcessor() consensus.ScheduledProcessor + func (ccm *ConsensusCoreMock) SetBlockProcessor(blockProcessor process.BlockProcessor) + func (ccm *ConsensusCoreMock) SetBlockchain(blockChain data.ChainHandler) + func (ccm *ConsensusCoreMock) SetBootStrapper(bootstrapper process.Bootstrapper) + func (ccm *ConsensusCoreMock) SetBroadcastMessenger(broadcastMessenger consensus.BroadcastMessenger) + func (ccm *ConsensusCoreMock) SetChronology(chronologyHandler consensus.ChronologyHandler) + func (ccm *ConsensusCoreMock) SetFallbackHeaderValidator(fallbackHeaderValidator consensus.FallbackHeaderValidator) + func (ccm *ConsensusCoreMock) SetHasher(hasher hashing.Hasher) + func (ccm *ConsensusCoreMock) SetHeaderSigVerifier(headerSigVerifier consensus.HeaderSigVerifier) + func (ccm *ConsensusCoreMock) SetMarshalizer(marshalizer marshal.Marshalizer) + func (ccm *ConsensusCoreMock) SetMultiSigner(multiSigner crypto.MultiSigner) + func (ccm *ConsensusCoreMock) SetNodeRedundancyHandler(nodeRedundancyHandler consensus.NodeRedundancyHandler) + func (ccm *ConsensusCoreMock) SetRoundHandler(roundHandler consensus.RoundHandler) + func (ccm *ConsensusCoreMock) SetShardCoordinator(shardCoordinator sharding.Coordinator) + func (ccm *ConsensusCoreMock) SetSingleSigner(signer crypto.SingleSigner) + func (ccm *ConsensusCoreMock) SetSyncTimer(syncTimer ntp.SyncTimer) + func (ccm *ConsensusCoreMock) SetValidatorGroupSelector(validatorGroupSelector nodesCoordinator.NodesCoordinator) + func (ccm *ConsensusCoreMock) ShardCoordinator() sharding.Coordinator + func (ccm *ConsensusCoreMock) SingleSigner() crypto.SingleSigner + func (ccm *ConsensusCoreMock) SyncTimer() ntp.SyncTimer + type ConsensusStateMock struct + CanDoSubroundJobCalled func(currentSubroundId int) bool + CanProcessReceivedMessageCalled func(cnsDta consensus.Message, currentRoundIndex int32, currentSubroundId int) bool + ConsensusGroupSizeCalled func() int + GenerateBitmapCalled func(subroundId int) []byte + GetLeaderCalled func() (string, error) + GetNextConsensusGroupCalled func(randomSource string, vgs nodesCoordinator.NodesCoordinator) ([]string, error) + IsBlockBodyAlreadyReceivedCalled func() bool + IsConsensusDataEqualCalled func(data []byte) bool + IsConsensusDataSetCalled func() bool + IsCurrentSubroundFinishedCalled func(currentSubroundId int) bool + IsHeaderAlreadyReceivedCalled func() bool + IsJobDoneCalled func(node string, currentSubroundId int) bool + IsNodeLeaderInCurrentRoundCalled func(node string) bool + IsNodeSelfCalled func(node string) bool + IsSelfJobDoneCalled func(currentSubroundId int) bool + IsSelfLeaderInCurrentRoundCalled func() bool + ProcessingBlockCalled func() bool + ResetConsensusStateCalled func() + SetProcessingBlockCalled func(processingBlock bool) + SetThresholdCalled func(subroundId int, threshold int) + func (cnsm *ConsensusStateMock) CanDoSubroundJob(currentSubroundId int) bool + func (cnsm *ConsensusStateMock) CanProcessReceivedMessage(cnsDta consensus.Message, currentRoundIndex int32, currentSubroundId int) bool + func (cnsm *ConsensusStateMock) ConsensusGroupSize() int + func (cnsm *ConsensusStateMock) GenerateBitmap(subroundId int) []byte + func (cnsm *ConsensusStateMock) GetLeader() (string, error) + func (cnsm *ConsensusStateMock) GetNextConsensusGroup(randomSource string, vgs nodesCoordinator.NodesCoordinator) ([]string, error) + func (cnsm *ConsensusStateMock) IsBlockBodyAlreadyReceived() bool + func (cnsm *ConsensusStateMock) IsConsensusDataEqual(data []byte) bool + func (cnsm *ConsensusStateMock) IsConsensusDataSet() bool + func (cnsm *ConsensusStateMock) IsCurrentSubroundFinished(currentSubroundId int) bool + func (cnsm *ConsensusStateMock) IsHeaderAlreadyReceived() bool + func (cnsm *ConsensusStateMock) IsJobDone(node string, currentSubroundId int) bool + func (cnsm *ConsensusStateMock) IsNodeLeaderInCurrentRound(node string) bool + func (cnsm *ConsensusStateMock) IsNodeSelf(node string) bool + func (cnsm *ConsensusStateMock) IsSelfJobDone(currentSubroundId int) bool + func (cnsm *ConsensusStateMock) IsSelfLeaderInCurrentRound() bool + func (cnsm *ConsensusStateMock) ProcessingBlock() bool + func (cnsm *ConsensusStateMock) ResetConsensusState() + func (cnsm *ConsensusStateMock) SetProcessingBlock(processingBlock bool) + func (cnsm *ConsensusStateMock) SetThreshold(subroundId int, threshold int) + 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 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 HasherStub struct + ComputeCalled func(s string) []byte + EmptyHashCalled func() []byte + SizeCalled func() int + func (hs *HasherStub) Compute(s string) []byte + func (hs *HasherStub) EmptyHash() []byte + func (hs *HasherStub) IsInterfaceNil() bool + func (hs *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 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 IndexerMock struct + func (im *IndexerMock) IsInterfaceNil() bool + func (im *IndexerMock) SaveRoundsInfo(_ []*indexer.RoundInfo) + type KeyGenMock struct + CheckPublicKeyValidMock func(b []byte) error + GeneratePairMock func() (crypto.PrivateKey, crypto.PublicKey) + PrivateKeyFromByteArrayMock func(b []byte) (crypto.PrivateKey, error) + PublicKeyFromByteArrayMock func(b []byte) (crypto.PublicKey, error) + SuiteMock func() crypto.Suite + func (keyGen *KeyGenMock) CheckPublicKeyValid(b []byte) error + func (keyGen *KeyGenMock) GeneratePair() (crypto.PrivateKey, crypto.PublicKey) + func (keyGen *KeyGenMock) IsInterfaceNil() bool + func (keyGen *KeyGenMock) PrivateKeyFromByteArray(b []byte) (crypto.PrivateKey, error) + func (keyGen *KeyGenMock) PublicKeyFromByteArray(b []byte) (crypto.PublicKey, error) + func (keyGen *KeyGenMock) Suite() crypto.Suite + type 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 MessengerStub struct + BroadcastCalled func(topic string, buff []byte) + func (ms *MessengerStub) Broadcast(topic string, buff []byte) + func (ms *MessengerStub) IsInterfaceNil() bool + type MultipleShardsCoordinatorMock struct + ComputeIdCalled func(address []byte) uint32 + CurrentShard uint32 + NoShards uint32 + SelfIDCalled func() uint32 + func NewMultiShardsCoordinatorMock(nrShard uint32) *MultipleShardsCoordinatorMock + func (scm *MultipleShardsCoordinatorMock) CommunicationIdentifier(destShardID uint32) string + func (scm *MultipleShardsCoordinatorMock) ComputeId(address []byte) uint32 + func (scm *MultipleShardsCoordinatorMock) IsInterfaceNil() bool + func (scm *MultipleShardsCoordinatorMock) NumberOfShards() uint32 + func (scm *MultipleShardsCoordinatorMock) SameShard(_, _ []byte) bool + func (scm *MultipleShardsCoordinatorMock) SelfId() uint32 + func (scm *MultipleShardsCoordinatorMock) SetNoShards(noShards uint32) + func (scm *MultipleShardsCoordinatorMock) SetSelfId(_ uint32) error + type NodeRedundancyHandlerStub struct + AdjustInactivityIfNeededCalled func(selfPubKey string, consensusPubKeys []string, roundIndex int64) + IsMainMachineActiveCalled func() bool + IsRedundancyNodeCalled func() bool + ObserverPrivateKeyCalled func() crypto.PrivateKey + ResetInactivityIfNeededCalled func(selfPubKey string, consensusMsgPubKey string, consensusMsgPeerID core.PeerID) + func (nrhs *NodeRedundancyHandlerStub) AdjustInactivityIfNeeded(selfPubKey string, consensusPubKeys []string, roundIndex int64) + func (nrhs *NodeRedundancyHandlerStub) IsInterfaceNil() bool + func (nrhs *NodeRedundancyHandlerStub) IsMainMachineActive() bool + func (nrhs *NodeRedundancyHandlerStub) IsRedundancyNode() bool + func (nrhs *NodeRedundancyHandlerStub) ObserverPrivateKey() crypto.PrivateKey + func (nrhs *NodeRedundancyHandlerStub) ResetInactivityIfNeeded(selfPubKey string, consensusMsgPubKey string, consensusMsgPeerID core.PeerID) + type P2PAntifloodHandlerStub struct + BlacklistPeerCalled func(peer core.PeerID, reason string, duration time.Duration) + CanProcessMessageCalled func(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + CanProcessMessagesOnTopicCalled func(peer core.PeerID, topic string, numMessages uint32, totalSize uint64, ...) error + func (p2pahs *P2PAntifloodHandlerStub) BlacklistPeer(peer core.PeerID, reason string, duration time.Duration) + func (p2pahs *P2PAntifloodHandlerStub) CanProcessMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + func (p2pahs *P2PAntifloodHandlerStub) CanProcessMessagesOnTopic(peer core.PeerID, topic string, numMessages uint32, totalSize uint64, ...) error + func (p2pahs *P2PAntifloodHandlerStub) IsInterfaceNil() bool + func (p2pahs *P2PAntifloodHandlerStub) ResetForTopic(_ string) + func (p2pahs *P2PAntifloodHandlerStub) SetMaxMessagesForTopic(_ string, _ uint32) + type 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 PeerSignatureHandler struct + KeyGen crypto.KeyGenerator + Signer crypto.SingleSigner + func (p *PeerSignatureHandler) GetPeerSignature(privateKey crypto.PrivateKey, msg []byte) ([]byte, error) + func (p *PeerSignatureHandler) IsInterfaceNil() bool + func (p *PeerSignatureHandler) VerifyPeerSignature(pk []byte, pid core.PeerID, sig []byte) error + type PrivateKeyMock struct + GeneratePublicMock func() crypto.PublicKey + ScalarMock func() crypto.Scalar + SuiteMock func() crypto.Suite + ToByteArrayMock func() ([]byte, error) + func (privKey *PrivateKeyMock) GeneratePublic() crypto.PublicKey + func (privKey *PrivateKeyMock) IsInterfaceNil() bool + func (privKey *PrivateKeyMock) Scalar() crypto.Scalar + func (privKey *PrivateKeyMock) Suite() crypto.Suite + func (privKey *PrivateKeyMock) ToByteArray() ([]byte, error) + type PublicKeyMock struct + PointMock func() crypto.Point + SuiteMock func() crypto.Suite + ToByteArrayMock func() ([]byte, error) + func (pubKey *PublicKeyMock) IsInterfaceNil() bool + func (pubKey *PublicKeyMock) Point() crypto.Point + func (pubKey *PublicKeyMock) Suite() crypto.Suite + func (pubKey *PublicKeyMock) ToByteArray() ([]byte, error) + type RoundHandlerMock struct + BeforeGenesisCalled func() bool + IndexCalled func() int64 + RemainingTimeCalled func(startTime time.Time, maxTime time.Duration) time.Duration + RoundIndex int64 + TimeDurationCalled func() time.Duration + TimeStampCalled func() time.Time + UpdateRoundCalled func(time.Time, time.Time) + func (rndm *RoundHandlerMock) BeforeGenesis() bool + func (rndm *RoundHandlerMock) Index() int64 + func (rndm *RoundHandlerMock) IsInterfaceNil() bool + func (rndm *RoundHandlerMock) RemainingTime(startTime time.Time, maxTime time.Duration) time.Duration + func (rndm *RoundHandlerMock) TimeDuration() time.Duration + func (rndm *RoundHandlerMock) TimeStamp() time.Time + func (rndm *RoundHandlerMock) UpdateRound(genesisRoundTimeStamp time.Time, timeStamp time.Time) + type ShardCoordinatorMock struct + ShardID uint32 + func (scm ShardCoordinatorMock) CommunicationIdentifier(destShardID uint32) string + func (scm ShardCoordinatorMock) ComputeId(_ []byte) uint32 + func (scm ShardCoordinatorMock) IsInterfaceNil() bool + func (scm ShardCoordinatorMock) NumberOfShards() uint32 + func (scm ShardCoordinatorMock) SameShard(_, _ []byte) bool + func (scm ShardCoordinatorMock) SelfId() uint32 + func (scm ShardCoordinatorMock) SetSelfId(_ uint32) error + type SingleSignerMock struct + SignStub func(private crypto.PrivateKey, msg []byte) ([]byte, error) + VerifyStub func(public crypto.PublicKey, msg []byte, sig []byte) error + func (s *SingleSignerMock) IsInterfaceNil() bool + func (s *SingleSignerMock) Sign(private crypto.PrivateKey, msg []byte) ([]byte, error) + func (s *SingleSignerMock) Verify(public crypto.PublicKey, msg []byte, sig []byte) error + type SposWorkerMock struct + AddReceivedHeaderHandlerCalled func(handler func(data.HeaderHandler)) + AddReceivedMessageCallCalled func(messageType consensus.MessageType, ...) + DisplayStatisticsCalled func() + ExecuteStoredMessagesCalled func() + ExtendCalled func(subroundId int) + GetBroadcastBlockCalled func(data.BodyHandler, data.HeaderHandler) error + GetBroadcastHeaderCalled func(data.HeaderHandler) error + GetConsensusStateChangedChannelsCalled func() chan bool + ProcessReceivedMessageCalled func(message p2p.MessageP2P) error + ReceivedHeaderCalled func(headerHandler data.HeaderHandler, headerHash []byte) + RemoveAllReceivedMessagesCallsCalled func() + ResetConsensusMessagesCalled func() + SendConsensusMessageCalled func(cnsDta *consensus.Message) bool + SetAppStatusHandlerCalled func(ash core.AppStatusHandler) error + func (sposWorkerMock *SposWorkerMock) AddReceivedHeaderHandler(handler func(data.HeaderHandler)) + func (sposWorkerMock *SposWorkerMock) AddReceivedMessageCall(messageType consensus.MessageType, ...) + func (sposWorkerMock *SposWorkerMock) BroadcastBlock(body data.BodyHandler, header data.HeaderHandler) error + func (sposWorkerMock *SposWorkerMock) Close() error + func (sposWorkerMock *SposWorkerMock) DisplayStatistics() + func (sposWorkerMock *SposWorkerMock) ExecuteStoredMessages() + func (sposWorkerMock *SposWorkerMock) Extend(subroundId int) + func (sposWorkerMock *SposWorkerMock) GetConsensusStateChangedChannel() chan bool + func (sposWorkerMock *SposWorkerMock) IsInterfaceNil() bool + func (sposWorkerMock *SposWorkerMock) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error + func (sposWorkerMock *SposWorkerMock) ReceivedHeader(headerHandler data.HeaderHandler, headerHash []byte) + func (sposWorkerMock *SposWorkerMock) RemoveAllReceivedMessagesCalls() + func (sposWorkerMock *SposWorkerMock) ResetConsensusMessages() + func (sposWorkerMock *SposWorkerMock) SendConsensusMessage(cnsDta *consensus.Message) bool + func (sposWorkerMock *SposWorkerMock) StartWorking() + type SubroundHandlerMock struct + CheckCalled func() bool + ConsensusChannelCalled func() chan bool + CurrentCalled func() int + DoWorkCalled func(roundHandler consensus.RoundHandler) bool + EndTimeCalled func() int64 + JobCalled func() bool + NameCalled func() string + NextCalled func() int + PreviousCalled func() int + StartTimeCalled func() int64 + func (srm *SubroundHandlerMock) ConsensusChannel() chan bool + func (srm *SubroundHandlerMock) Current() int + func (srm *SubroundHandlerMock) DoWork(_ context.Context, roundHandler consensus.RoundHandler) bool + func (srm *SubroundHandlerMock) EndTime() int64 + func (srm *SubroundHandlerMock) IsInterfaceNil() bool + func (srm *SubroundHandlerMock) Name() string + func (srm *SubroundHandlerMock) Next() int + func (srm *SubroundHandlerMock) Previous() int + func (srm *SubroundHandlerMock) StartTime() int64 + type SyncTimerMock struct + ClockOffsetCalled func() time.Duration + CurrentTimeCalled func() time.Time + func (stm *SyncTimerMock) ClockOffset() time.Duration + func (stm *SyncTimerMock) Close() error + func (stm *SyncTimerMock) CurrentTime() time.Time + func (stm *SyncTimerMock) FormattedCurrentTime() string + func (stm *SyncTimerMock) IsInterfaceNil() bool + func (stm *SyncTimerMock) StartSyncingTime() + type ValidatorStatisticsProcessorStub struct + IsInterfaceNilCalled func() bool + LoadInitialStateCalled func(in []*sharding.InitialNode) error + UpdatePeerStateCalled func(header, previousHeader data.HeaderHandler) error + func (pm *ValidatorStatisticsProcessorStub) IsInterfaceNil() bool + func (pm *ValidatorStatisticsProcessorStub) LoadInitialState(in []*sharding.InitialNode) error + func (pm *ValidatorStatisticsProcessorStub) UpdatePeerState(header, previousHeader data.HeaderHandler) error + type WatchdogMock struct + func (w *WatchdogMock) IsInterfaceNil() bool + func (w *WatchdogMock) Reset(alarmID string) + func (w *WatchdogMock) Set(callback func(alarmID string), duration time.Duration, alarmID string) + func (w *WatchdogMock) SetDefault(duration time.Duration, alarmID string) + func (w *WatchdogMock) Stop(alarmID string)