consensus

package
v1.9.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 9, 2025 License: GPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitBlockProcessorHeaderV2Mock added in v1.9.0 

func InitBlockProcessorHeaderV2Mock() *testscommon.BlockProcessorStub

InitBlockProcessorHeaderV2Mock -

func InitBlockProcessorMock added in v1.9.0 

func InitBlockProcessorMock(marshaller marshal.Marshalizer) *testscommon.BlockProcessorStub

InitBlockProcessorMock -

func InitChronologyHandlerMock added in v1.9.0 

func InitChronologyHandlerMock() consensus.ChronologyHandler

InitChronologyHandlerMock -

func InitConsensusCore added in v1.9.0 

func InitConsensusCore() *spos.ConsensusCore

InitConsensusCore -

func InitConsensusCoreHeaderV2 added in v1.9.0 

func InitConsensusCoreHeaderV2() *spos.ConsensusCore

InitConsensusCoreHeaderV2 -

func InitConsensusCoreWithMultiSigner added in v1.9.0 

func InitConsensusCoreWithMultiSigner(multiSigner crypto.MultiSigner) *spos.ConsensusCore

InitConsensusCoreWithMultiSigner -

func InitKeys added in v1.9.0 

func InitKeys() (*mock.KeyGenMock, *mock.PrivateKeyMock, *mock.PublicKeyMock)

InitKeys -

func InitMultiSignerMock added in v1.9.0 

func InitMultiSignerMock() *cryptoMocks.MultisignerMock

InitMultiSignerMock -

Types

type BroadcastMessengerMock added in v1.9.0 

type BroadcastMessengerMock struct {
	BroadcastBlockCalled                                func(data.BodyHandler, data.HeaderHandler) error
	BroadcastHeaderCalled                               func(data.HeaderHandler, []byte) error
	BroadcastEquivalentProofCalled                      func(proof data.HeaderProofHandler, pkBytes []byte) error
	PrepareBroadcastBlockDataValidatorCalled            func(h data.HeaderHandler, mbs map[uint32][]byte, txs map[string][][]byte, idx int, pkBytes []byte) error
	PrepareBroadcastBlockDataWithEquivalentProofsCalled func(h data.HeaderHandler, mbs map[uint32][]byte, txs map[string][][]byte, pkBytes []byte)
	PrepareBroadcastHeaderValidatorCalled               func(h data.HeaderHandler, mbs map[uint32][]byte, txs map[string][][]byte, idx int, pkBytes []byte)
	BroadcastMiniBlocksCalled                           func(map[uint32][]byte, []byte) error
	BroadcastTransactionsCalled                         func(map[string][][]byte, []byte) error
	BroadcastConsensusMessageCalled                     func(*consensus.Message) error
	BroadcastBlockDataLeaderCalled                      func(h data.HeaderHandler, mbs map[uint32][]byte, txs map[string][][]byte, pkBytes []byte) error
}

BroadcastMessengerMock -

func (*BroadcastMessengerMock) BroadcastBlock added in v1.9.0 

func (bmm *BroadcastMessengerMock) BroadcastBlock(bodyHandler data.BodyHandler, headerhandler data.HeaderHandler) error

BroadcastBlock -

func (*BroadcastMessengerMock) BroadcastBlockDataLeader added in v1.9.0 

func (bmm *BroadcastMessengerMock) BroadcastBlockDataLeader(
	header data.HeaderHandler,
	miniBlocks map[uint32][]byte,
	transactions map[string][][]byte,
	pkBytes []byte,
) error

BroadcastBlockDataLeader -

func (*BroadcastMessengerMock) BroadcastConsensusMessage added in v1.9.0 

func (bmm *BroadcastMessengerMock) BroadcastConsensusMessage(message *consensus.Message) error

BroadcastConsensusMessage -

func (*BroadcastMessengerMock) BroadcastEquivalentProof added in v1.9.0 

func (bmm *BroadcastMessengerMock) BroadcastEquivalentProof(proof data.HeaderProofHandler, pkBytes []byte) error

BroadcastEquivalentProof -

func (*BroadcastMessengerMock) BroadcastHeader added in v1.9.0 

func (bmm *BroadcastMessengerMock) BroadcastHeader(headerhandler data.HeaderHandler, pkBytes []byte) error

BroadcastHeader -

func (*BroadcastMessengerMock) BroadcastMiniBlocks added in v1.9.0 

func (bmm *BroadcastMessengerMock) BroadcastMiniBlocks(miniBlocks map[uint32][]byte, pkBytes []byte) error

BroadcastMiniBlocks -

func (*BroadcastMessengerMock) BroadcastTransactions added in v1.9.0 

func (bmm *BroadcastMessengerMock) BroadcastTransactions(transactions map[string][][]byte, pkBytes []byte) error

BroadcastTransactions -

func (*BroadcastMessengerMock) IsInterfaceNil added in v1.9.0 

func (bmm *BroadcastMessengerMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*BroadcastMessengerMock) PrepareBroadcastBlockDataValidator added in v1.9.0 

func (bmm *BroadcastMessengerMock) PrepareBroadcastBlockDataValidator(
	header data.HeaderHandler,
	miniBlocks map[uint32][]byte,
	transactions map[string][][]byte,
	idx int,
	pkBytes []byte,
)

PrepareBroadcastBlockDataValidator -

func (*BroadcastMessengerMock) PrepareBroadcastBlockDataWithEquivalentProofs added in v1.9.0 

func (bmm *BroadcastMessengerMock) PrepareBroadcastBlockDataWithEquivalentProofs(
	header data.HeaderHandler,
	miniBlocks map[uint32][]byte,
	transactions map[string][][]byte,
	pkBytes []byte,
)

PrepareBroadcastBlockDataWithEquivalentProofs -

func (*BroadcastMessengerMock) PrepareBroadcastHeaderValidator added in v1.9.0 

func (bmm *BroadcastMessengerMock) PrepareBroadcastHeaderValidator(
	header data.HeaderHandler,
	miniBlocks map[uint32][]byte,
	transactions map[string][][]byte,
	order int,
	pkBytes []byte,
)

PrepareBroadcastHeaderValidator -

type ChronologyHandlerMock added in v1.9.0 

type ChronologyHandlerMock struct {
	AddSubroundCalled        func(consensus.SubroundHandler)
	RemoveAllSubroundsCalled func()
	StartRoundCalled         func()
	EpochCalled              func() uint32
}

ChronologyHandlerMock -

func (*ChronologyHandlerMock) AddSubround added in v1.9.0 

func (chrm *ChronologyHandlerMock) AddSubround(subroundHandler consensus.SubroundHandler)

AddSubround -

func (*ChronologyHandlerMock) Close added in v1.9.0 

func (chrm *ChronologyHandlerMock) Close() error

Close -

func (*ChronologyHandlerMock) Epoch added in v1.9.0 

func (chrm *ChronologyHandlerMock) Epoch() uint32

Epoch -

func (*ChronologyHandlerMock) IsInterfaceNil added in v1.9.0 

func (chrm *ChronologyHandlerMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*ChronologyHandlerMock) RemoveAllSubrounds added in v1.9.0 

func (chrm *ChronologyHandlerMock) RemoveAllSubrounds()

RemoveAllSubrounds -

func (*ChronologyHandlerMock) StartRounds added in v1.9.0 

func (chrm *ChronologyHandlerMock) StartRounds()

StartRounds -

type ConsensusStateMock added in v1.9.0 

type ConsensusStateMock struct {
	ResetConsensusStateCalled                    func()
	IsNodeLeaderInCurrentRoundCalled             func(node string) bool
	IsSelfLeaderInCurrentRoundCalled             func() bool
	GetLeaderCalled                              func() (string, error)
	GetNextConsensusGroupCalled                  func(randomSource []byte, round uint64, shardId uint32, nodesCoordinator nodesCoordinator.NodesCoordinator, epoch uint32) (string, []string, error)
	IsConsensusDataSetCalled                     func() bool
	IsConsensusDataEqualCalled                   func(data []byte) bool
	IsJobDoneCalled                              func(node string, currentSubroundId int) bool
	IsSelfJobDoneCalled                          func(currentSubroundId int) bool
	IsCurrentSubroundFinishedCalled              func(currentSubroundId int) bool
	IsNodeSelfCalled                             func(node string) bool
	IsBlockBodyAlreadyReceivedCalled             func() bool
	IsHeaderAlreadyReceivedCalled                func() bool
	CanDoSubroundJobCalled                       func(currentSubroundId int) bool
	CanProcessReceivedMessageCalled              func(cnsDta *consensus.Message, currentRoundIndex int64, currentSubroundId int) bool
	GenerateBitmapCalled                         func(subroundId int) []byte
	ProcessingBlockCalled                        func() bool
	SetProcessingBlockCalled                     func(processingBlock bool)
	ConsensusGroupSizeCalled                     func() int
	SetThresholdCalled                           func(subroundId int, threshold int)
	AddReceivedHeaderCalled                      func(headerHandler data.HeaderHandler)
	GetReceivedHeadersCalled                     func() []data.HeaderHandler
	AddMessageWithSignatureCalled                func(key string, message p2p.MessageP2P)
	GetMessageWithSignatureCalled                func(key string) (p2p.MessageP2P, bool)
	IsSubroundFinishedCalled                     func(subroundID int) bool
	GetDataCalled                                func() []byte
	SetDataCalled                                func(data []byte)
	IsMultiKeyLeaderInCurrentRoundCalled         func() bool
	IsLeaderJobDoneCalled                        func(currentSubroundId int) bool
	IsMultiKeyJobDoneCalled                      func(currentSubroundId int) bool
	GetMultikeyRedundancyStepInReasonCalled      func() string
	ResetRoundsWithoutReceivedMessagesCalled     func(pkBytes []byte, pid core.PeerID)
	GetRoundCanceledCalled                       func() bool
	SetRoundCanceledCalled                       func(state bool)
	GetRoundIndexCalled                          func() int64
	SetRoundIndexCalled                          func(roundIndex int64)
	GetRoundTimeStampCalled                      func() time.Time
	SetRoundTimeStampCalled                      func(roundTimeStamp time.Time)
	GetExtendedCalledCalled                      func() bool
	GetBodyCalled                                func() data.BodyHandler
	SetBodyCalled                                func(body data.BodyHandler)
	GetHeaderCalled                              func() data.HeaderHandler
	SetHeaderCalled                              func(header data.HeaderHandler)
	GetWaitingAllSignaturesTimeOutCalled         func() bool
	SetWaitingAllSignaturesTimeOutCalled         func(b bool)
	ConsensusGroupIndexCalled                    func(pubKey string) (int, error)
	SelfConsensusGroupIndexCalled                func() (int, error)
	SetEligibleListCalled                        func(eligibleList map[string]struct{})
	ConsensusGroupCalled                         func() []string
	SetConsensusGroupCalled                      func(consensusGroup []string)
	SetLeaderCalled                              func(leader string)
	SetConsensusGroupSizeCalled                  func(consensusGroupSize int)
	SelfPubKeyCalled                             func() string
	SetSelfPubKeyCalled                          func(selfPubKey string)
	JobDoneCalled                                func(key string, subroundId int) (bool, error)
	SetJobDoneCalled                             func(key string, subroundId int, value bool) error
	SelfJobDoneCalled                            func(subroundId int) (bool, error)
	IsNodeInConsensusGroupCalled                 func(node string) bool
	IsNodeInEligibleListCalled                   func(node string) bool
	ComputeSizeCalled                            func(subroundId int) int
	ResetRoundStateCalled                        func()
	IsMultiKeyInConsensusGroupCalled             func() bool
	IsKeyManagedBySelfCalled                     func(pkBytes []byte) bool
	IncrementRoundsWithoutReceivedMessagesCalled func(pkBytes []byte)
	GetKeysHandlerCalled                         func() consensus.KeysHandler
	LeaderCalled                                 func() string
	StatusCalled                                 func(subroundId int) int
	SetStatusCalled                              func(subroundId int, subroundStatus int)
	ResetRoundStatusCalled                       func()
	ThresholdCalled                              func(subroundId int) int
	FallbackThresholdCalled                      func(subroundId int) int
	SetFallbackThresholdCalled                   func(subroundId int, threshold int)
	ResetConsensusRoundStateCalled               func()
}

ConsensusStateMock -

func (*ConsensusStateMock) AddMessageWithSignature added in v1.9.0 

func (cnsm *ConsensusStateMock) AddMessageWithSignature(key string, message p2p.MessageP2P)

AddMessageWithSignature -

func (*ConsensusStateMock) AddReceivedHeader added in v1.9.0 

func (cnsm *ConsensusStateMock) AddReceivedHeader(headerHandler data.HeaderHandler)

AddReceivedHeader -

func (*ConsensusStateMock) CanDoSubroundJob added in v1.9.0 

func (cnsm *ConsensusStateMock) CanDoSubroundJob(currentSubroundId int) bool

CanDoSubroundJob -

func (*ConsensusStateMock) CanProcessReceivedMessage added in v1.9.0 

func (cnsm *ConsensusStateMock) CanProcessReceivedMessage(
	cnsDta *consensus.Message,
	currentRoundIndex int64,
	currentSubroundId int,
) bool

CanProcessReceivedMessage -

func (*ConsensusStateMock) ComputeSize added in v1.9.0 

func (cnsm *ConsensusStateMock) ComputeSize(subroundId int) int

ComputeSize -

func (*ConsensusStateMock) ConsensusGroup added in v1.9.0 

func (cnsm *ConsensusStateMock) ConsensusGroup() []string

ConsensusGroup -

func (*ConsensusStateMock) ConsensusGroupIndex added in v1.9.0 

func (cnsm *ConsensusStateMock) ConsensusGroupIndex(pubKey string) (int, error)

ConsensusGroupIndex -

func (*ConsensusStateMock) ConsensusGroupSize added in v1.9.0 

func (cnsm *ConsensusStateMock) ConsensusGroupSize() int

ConsensusGroupSize -

func (*ConsensusStateMock) FallbackThreshold added in v1.9.0 

func (cnsm *ConsensusStateMock) FallbackThreshold(subroundId int) int

FallbackThreshold -

func (*ConsensusStateMock) GenerateBitmap added in v1.9.0 

func (cnsm *ConsensusStateMock) GenerateBitmap(subroundId int) []byte

GenerateBitmap -

func (*ConsensusStateMock) GetBody added in v1.9.0 

func (cnsm *ConsensusStateMock) GetBody() data.BodyHandler

GetBody -

func (*ConsensusStateMock) GetData added in v1.9.0 

func (cnsm *ConsensusStateMock) GetData() []byte

GetData -

func (*ConsensusStateMock) GetExtendedCalled added in v1.9.0 

func (cnsm *ConsensusStateMock) GetExtendedCalled() bool

GetExtendedCalled -

func (*ConsensusStateMock) GetHeader added in v1.9.0 

func (cnsm *ConsensusStateMock) GetHeader() data.HeaderHandler

GetHeader -

func (*ConsensusStateMock) GetKeysHandler added in v1.9.0 

func (cnsm *ConsensusStateMock) GetKeysHandler() consensus.KeysHandler

GetKeysHandler -

func (*ConsensusStateMock) GetLeader added in v1.9.0 

func (cnsm *ConsensusStateMock) GetLeader() (string, error)

GetLeader -

func (*ConsensusStateMock) GetMessageWithSignature added in v1.9.0 

func (cnsm *ConsensusStateMock) GetMessageWithSignature(key string) (p2p.MessageP2P, bool)

GetMessageWithSignature -

func (*ConsensusStateMock) GetMultikeyRedundancyStepInReason added in v1.9.0 

func (cnsm *ConsensusStateMock) GetMultikeyRedundancyStepInReason() string

GetMultikeyRedundancyStepInReason -

func (*ConsensusStateMock) GetNextConsensusGroup added in v1.9.0 

func (cnsm *ConsensusStateMock) GetNextConsensusGroup(
	randomSource []byte,
	round uint64,
	shardId uint32,
	nodesCoordinator nodesCoordinator.NodesCoordinator,
	epoch uint32,
) (string, []string, error)

GetNextConsensusGroup -

func (*ConsensusStateMock) GetReceivedHeaders added in v1.9.0 

func (cnsm *ConsensusStateMock) GetReceivedHeaders() []data.HeaderHandler

GetReceivedHeaders -

func (*ConsensusStateMock) GetRoundCanceled added in v1.9.0 

func (cnsm *ConsensusStateMock) GetRoundCanceled() bool

GetRoundCanceled -

func (*ConsensusStateMock) GetRoundIndex added in v1.9.0 

func (cnsm *ConsensusStateMock) GetRoundIndex() int64

GetRoundIndex -

func (*ConsensusStateMock) GetRoundTimeStamp added in v1.9.0 

func (cnsm *ConsensusStateMock) GetRoundTimeStamp() time.Time

GetRoundTimeStamp -

func (*ConsensusStateMock) GetWaitingAllSignaturesTimeOut added in v1.9.0 

func (cnsm *ConsensusStateMock) GetWaitingAllSignaturesTimeOut() bool

GetWaitingAllSignaturesTimeOut -

func (*ConsensusStateMock) IncrementRoundsWithoutReceivedMessages added in v1.9.0 

func (cnsm *ConsensusStateMock) IncrementRoundsWithoutReceivedMessages(pkBytes []byte)

IncrementRoundsWithoutReceivedMessages -

func (*ConsensusStateMock) IsBlockBodyAlreadyReceived added in v1.9.0 

func (cnsm *ConsensusStateMock) IsBlockBodyAlreadyReceived() bool

IsBlockBodyAlreadyReceived -

func (*ConsensusStateMock) IsConsensusDataEqual added in v1.9.0 

func (cnsm *ConsensusStateMock) IsConsensusDataEqual(data []byte) bool

IsConsensusDataEqual -

func (*ConsensusStateMock) IsConsensusDataSet added in v1.9.0 

func (cnsm *ConsensusStateMock) IsConsensusDataSet() bool

IsConsensusDataSet -

func (*ConsensusStateMock) IsCurrentSubroundFinished added in v1.9.0 

func (cnsm *ConsensusStateMock) IsCurrentSubroundFinished(currentSubroundId int) bool

IsCurrentSubroundFinished -

func (*ConsensusStateMock) IsHeaderAlreadyReceived added in v1.9.0 

func (cnsm *ConsensusStateMock) IsHeaderAlreadyReceived() bool

IsHeaderAlreadyReceived -

func (*ConsensusStateMock) IsInterfaceNil added in v1.9.0 

func (cnsm *ConsensusStateMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*ConsensusStateMock) IsJobDone added in v1.9.0 

func (cnsm *ConsensusStateMock) IsJobDone(node string, currentSubroundId int) bool

IsJobDone -

func (*ConsensusStateMock) IsKeyManagedBySelf added in v1.9.0 

func (cnsm *ConsensusStateMock) IsKeyManagedBySelf(pkBytes []byte) bool

IsKeyManagedBySelf -

func (*ConsensusStateMock) IsLeaderJobDone added in v1.9.0 

func (cnsm *ConsensusStateMock) IsLeaderJobDone(currentSubroundId int) bool

IsLeaderJobDone -

func (*ConsensusStateMock) IsMultiKeyInConsensusGroup added in v1.9.0 

func (cnsm *ConsensusStateMock) IsMultiKeyInConsensusGroup() bool

IsMultiKeyInConsensusGroup -

func (*ConsensusStateMock) IsMultiKeyJobDone added in v1.9.0 

func (cnsm *ConsensusStateMock) IsMultiKeyJobDone(currentSubroundId int) bool

IsMultiKeyJobDone -

func (*ConsensusStateMock) IsMultiKeyLeaderInCurrentRound added in v1.9.0 

func (cnsm *ConsensusStateMock) IsMultiKeyLeaderInCurrentRound() bool

IsMultiKeyLeaderInCurrentRound -

func (*ConsensusStateMock) IsNodeInConsensusGroup added in v1.9.0 

func (cnsm *ConsensusStateMock) IsNodeInConsensusGroup(node string) bool

IsNodeInConsensusGroup -

func (*ConsensusStateMock) IsNodeInEligibleList added in v1.9.0 

func (cnsm *ConsensusStateMock) IsNodeInEligibleList(node string) bool

IsNodeInEligibleList -

func (*ConsensusStateMock) IsNodeLeaderInCurrentRound added in v1.9.0 

func (cnsm *ConsensusStateMock) IsNodeLeaderInCurrentRound(node string) bool

IsNodeLeaderInCurrentRound -

func (*ConsensusStateMock) IsNodeSelf added in v1.9.0 

func (cnsm *ConsensusStateMock) IsNodeSelf(node string) bool

IsNodeSelf -

func (*ConsensusStateMock) IsSelfJobDone added in v1.9.0 

func (cnsm *ConsensusStateMock) IsSelfJobDone(currentSubroundId int) bool

IsSelfJobDone -

func (*ConsensusStateMock) IsSelfLeaderInCurrentRound added in v1.9.0 

func (cnsm *ConsensusStateMock) IsSelfLeaderInCurrentRound() bool

IsSelfLeaderInCurrentRound -

func (*ConsensusStateMock) IsSubroundFinished added in v1.9.0 

func (cnsm *ConsensusStateMock) IsSubroundFinished(subroundID int) bool

IsSubroundFinished -

func (*ConsensusStateMock) JobDone added in v1.9.0 

func (cnsm *ConsensusStateMock) JobDone(key string, subroundId int) (bool, error)

JobDone -

func (*ConsensusStateMock) Leader added in v1.9.0 

func (cnsm *ConsensusStateMock) Leader() string

Leader -

func (*ConsensusStateMock) ProcessingBlock added in v1.9.0 

func (cnsm *ConsensusStateMock) ProcessingBlock() bool

ProcessingBlock -

func (*ConsensusStateMock) ResetConsensusRoundState added in v1.9.0 

func (cnsm *ConsensusStateMock) ResetConsensusRoundState()

ResetConsensusRoundState -

func (*ConsensusStateMock) ResetConsensusState added in v1.9.0 

func (cnsm *ConsensusStateMock) ResetConsensusState()

ResetConsensusState -

func (*ConsensusStateMock) ResetRoundState added in v1.9.0 

func (cnsm *ConsensusStateMock) ResetRoundState()

ResetRoundState -

func (*ConsensusStateMock) ResetRoundStatus added in v1.9.0 

func (cnsm *ConsensusStateMock) ResetRoundStatus()

ResetRoundStatus -

func (*ConsensusStateMock) ResetRoundsWithoutReceivedMessages added in v1.9.0 

func (cnsm *ConsensusStateMock) ResetRoundsWithoutReceivedMessages(pkBytes []byte, pid core.PeerID)

ResetRoundsWithoutReceivedMessages -

func (*ConsensusStateMock) SelfConsensusGroupIndex added in v1.9.0 

func (cnsm *ConsensusStateMock) SelfConsensusGroupIndex() (int, error)

SelfConsensusGroupIndex -

func (*ConsensusStateMock) SelfJobDone added in v1.9.0 

func (cnsm *ConsensusStateMock) SelfJobDone(subroundId int) (bool, error)

SelfJobDone -

func (*ConsensusStateMock) SelfPubKey added in v1.9.0 

func (cnsm *ConsensusStateMock) SelfPubKey() string

SelfPubKey -

func (*ConsensusStateMock) SetBody added in v1.9.0 

func (cnsm *ConsensusStateMock) SetBody(body data.BodyHandler)

SetBody -

func (*ConsensusStateMock) SetConsensusGroup added in v1.9.0 

func (cnsm *ConsensusStateMock) SetConsensusGroup(consensusGroup []string)

SetConsensusGroup -

func (*ConsensusStateMock) SetConsensusGroupSize added in v1.9.0 

func (cnsm *ConsensusStateMock) SetConsensusGroupSize(consensusGroupSize int)

SetConsensusGroupSize -

func (*ConsensusStateMock) SetData added in v1.9.0 

func (cnsm *ConsensusStateMock) SetData(data []byte)

SetData -

func (*ConsensusStateMock) SetEligibleList added in v1.9.0 

func (cnsm *ConsensusStateMock) SetEligibleList(eligibleList map[string]struct{})

SetEligibleList -

func (*ConsensusStateMock) SetFallbackThreshold added in v1.9.0 

func (cnsm *ConsensusStateMock) SetFallbackThreshold(subroundId int, threshold int)

func (*ConsensusStateMock) SetHeader added in v1.9.0 

func (cnsm *ConsensusStateMock) SetHeader(header data.HeaderHandler)

SetHeader -

func (*ConsensusStateMock) SetJobDone added in v1.9.0 

func (cnsm *ConsensusStateMock) SetJobDone(key string, subroundId int, value bool) error

SetJobDone -

func (*ConsensusStateMock) SetLeader added in v1.9.0 

func (cnsm *ConsensusStateMock) SetLeader(leader string)

SetLeader -

func (*ConsensusStateMock) SetProcessingBlock added in v1.9.0 

func (cnsm *ConsensusStateMock) SetProcessingBlock(processingBlock bool)

SetProcessingBlock -

func (*ConsensusStateMock) SetRoundCanceled added in v1.9.0 

func (cnsm *ConsensusStateMock) SetRoundCanceled(state bool)

SetRoundCanceled -

func (*ConsensusStateMock) SetRoundIndex added in v1.9.0 

func (cnsm *ConsensusStateMock) SetRoundIndex(roundIndex int64)

SetRoundIndex -

func (*ConsensusStateMock) SetRoundTimeStamp added in v1.9.0 

func (cnsm *ConsensusStateMock) SetRoundTimeStamp(roundTimeStamp time.Time)

SetRoundTimeStamp -

func (*ConsensusStateMock) SetSelfPubKey added in v1.9.0 

func (cnsm *ConsensusStateMock) SetSelfPubKey(selfPubKey string)

SetSelfPubKey -

func (*ConsensusStateMock) SetStatus added in v1.9.0 

func (cnsm *ConsensusStateMock) SetStatus(subroundId int, subroundStatus int)

SetStatus -

func (*ConsensusStateMock) SetThreshold added in v1.9.0 

func (cnsm *ConsensusStateMock) SetThreshold(subroundId int, threshold int)

SetThreshold -

func (*ConsensusStateMock) SetWaitingAllSignaturesTimeOut added in v1.9.0 

func (cnsm *ConsensusStateMock) SetWaitingAllSignaturesTimeOut(b bool)

SetWaitingAllSignaturesTimeOut -

func (*ConsensusStateMock) Status added in v1.9.0 

func (cnsm *ConsensusStateMock) Status(subroundId int) int

Status -

func (*ConsensusStateMock) Threshold added in v1.9.0 

func (cnsm *ConsensusStateMock) Threshold(subroundId int) int

Threshold -

type DelayedBroadcasterMock added in v1.9.0 

type DelayedBroadcasterMock struct {
	SetLeaderDataCalled         func(data *shared.DelayedBroadcastData) error
	SetValidatorDataCalled      func(data *shared.DelayedBroadcastData) error
	SetHeaderForValidatorCalled func(vData *shared.ValidatorHeaderBroadcastData) error
	SetBroadcastHandlersCalled  func(
		mbBroadcast func(mbData map[uint32][]byte, pkBytes []byte) error,
		txBroadcast func(txData map[string][][]byte, pkBytes []byte) error,
		headerBroadcast func(header data.HeaderHandler, pkBytes []byte) error,
		consensusMessageBroadcast func(message *consensus.Message) error) error
	CloseCalled func()
}

DelayedBroadcasterMock -

func (*DelayedBroadcasterMock) Close added in v1.9.0 

func (mock *DelayedBroadcasterMock) Close()

Close -

func (*DelayedBroadcasterMock) IsInterfaceNil added in v1.9.0 

func (mock *DelayedBroadcasterMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*DelayedBroadcasterMock) SetBroadcastHandlers added in v1.9.0 

func (mock *DelayedBroadcasterMock) SetBroadcastHandlers(
	mbBroadcast func(mbData map[uint32][]byte, pkBytes []byte) error,
	txBroadcast func(txData map[string][][]byte, pkBytes []byte) error,
	headerBroadcast func(header data.HeaderHandler, pkBytes []byte) error,
	consensusMessageBroadcast func(message *consensus.Message) error,
) error

SetBroadcastHandlers -

func (*DelayedBroadcasterMock) SetHeaderForValidator added in v1.9.0 

func (mock *DelayedBroadcasterMock) SetHeaderForValidator(vData *shared.ValidatorHeaderBroadcastData) error

SetHeaderForValidator -

func (*DelayedBroadcasterMock) SetLeaderData added in v1.9.0 

func (mock *DelayedBroadcasterMock) SetLeaderData(data *shared.DelayedBroadcastData) error

SetLeaderData -

func (*DelayedBroadcasterMock) SetValidatorData added in v1.9.0 

func (mock *DelayedBroadcasterMock) SetValidatorData(data *shared.DelayedBroadcastData) error

SetValidatorData -

type HasherStub added in v1.9.0 

type HasherStub struct {
	ComputeCalled   func(s string) []byte
	EmptyHashCalled func() []byte
	SizeCalled      func() int
}

HasherStub -

func (*HasherStub) Compute added in v1.9.0 

func (hs *HasherStub) Compute(s string) []byte

Compute will output the SHA's equivalent of the input string

func (*HasherStub) EmptyHash added in v1.9.0 

func (hs *HasherStub) EmptyHash() []byte

EmptyHash will return the equivalent of empty string SHA's

func (*HasherStub) IsInterfaceNil added in v1.9.0 

func (hs *HasherStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*HasherStub) Size added in v1.9.0 

func (hs *HasherStub) Size() int

Size returns the required size in bytes

type HeaderSigVerifierMock added in v1.9.0 

type HeaderSigVerifierMock struct {
	VerifyRandSeedAndLeaderSignatureCalled func(header data.HeaderHandler) error
	VerifySignatureCalled                  func(header data.HeaderHandler) error
	VerifyRandSeedCalled                   func(header data.HeaderHandler) error
	VerifyLeaderSignatureCalled            func(header data.HeaderHandler) error
	VerifySignatureForHashCalled           func(header data.HeaderHandler, hash []byte, pubkeysBitmap []byte, signature []byte) error
	VerifyHeaderProofCalled                func(proofHandler data.HeaderProofHandler) error
}

HeaderSigVerifierMock -

func (*HeaderSigVerifierMock) IsInterfaceNil added in v1.9.0 

func (mock *HeaderSigVerifierMock) IsInterfaceNil() bool

IsInterfaceNil -

func (*HeaderSigVerifierMock) VerifyHeaderProof added in v1.9.0 

func (mock *HeaderSigVerifierMock) VerifyHeaderProof(proofHandler data.HeaderProofHandler) error

VerifyHeaderProof -

func (*HeaderSigVerifierMock) VerifyLeaderSignature added in v1.9.0 

func (mock *HeaderSigVerifierMock) VerifyLeaderSignature(header data.HeaderHandler) error

VerifyLeaderSignature -

func (*HeaderSigVerifierMock) VerifyRandSeed added in v1.9.0 

func (mock *HeaderSigVerifierMock) VerifyRandSeed(header data.HeaderHandler) error

VerifyRandSeed -

func (*HeaderSigVerifierMock) VerifyRandSeedAndLeaderSignature added in v1.9.0 

func (mock *HeaderSigVerifierMock) VerifyRandSeedAndLeaderSignature(header data.HeaderHandler) error

VerifyRandSeedAndLeaderSignature -

func (*HeaderSigVerifierMock) VerifySignature added in v1.9.0 

func (mock *HeaderSigVerifierMock) VerifySignature(header data.HeaderHandler) error

VerifySignature -

func (*HeaderSigVerifierMock) VerifySignatureForHash added in v1.9.0 

func (mock *HeaderSigVerifierMock) VerifySignatureForHash(header data.HeaderHandler, hash []byte, pubkeysBitmap []byte, signature []byte) error

VerifySignatureForHash -

type InvalidSignersCacheMock added in v1.9.0 

type InvalidSignersCacheMock struct {
	AddInvalidSignersCalled        func(headerHash []byte, invalidSigners []byte, invalidPublicKeys []string)
	CheckKnownInvalidSignersCalled func(headerHash []byte, invalidSigners []byte) bool
	ResetCalled                    func()
}

InvalidSignersCacheMock -

func (*InvalidSignersCacheMock) AddInvalidSigners added in v1.9.0 

func (mock *InvalidSignersCacheMock) AddInvalidSigners(headerHash []byte, invalidSigners []byte, invalidPublicKeys []string)

AddInvalidSigners -

func (*InvalidSignersCacheMock) CheckKnownInvalidSigners added in v1.9.0 

func (mock *InvalidSignersCacheMock) CheckKnownInvalidSigners(headerHash []byte, invalidSigners []byte) bool

CheckKnownInvalidSigners -

func (*InvalidSignersCacheMock) IsInterfaceNil added in v1.9.0 

func (mock *InvalidSignersCacheMock) IsInterfaceNil() bool

IsInterfaceNil -

func (*InvalidSignersCacheMock) Reset added in v1.9.0 

func (mock *InvalidSignersCacheMock) Reset()

Reset -

type RoundHandlerMock added in v1.9.0 

type RoundHandlerMock struct {
	RoundIndex int64

	IndexCalled         func() int64
	TimeDurationCalled  func() time.Duration
	TimeStampCalled     func() time.Time
	UpdateRoundCalled   func(time.Time, time.Time)
	RemainingTimeCalled func(startTime time.Time, maxTime time.Duration) time.Duration
	BeforeGenesisCalled func() bool
}

RoundHandlerMock -

func (*RoundHandlerMock) BeforeGenesis added in v1.9.0 

func (rndm *RoundHandlerMock) BeforeGenesis() bool

BeforeGenesis -

func (*RoundHandlerMock) Index added in v1.9.0 

func (rndm *RoundHandlerMock) Index() int64

Index -

func (*RoundHandlerMock) IsInterfaceNil added in v1.9.0 

func (rndm *RoundHandlerMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*RoundHandlerMock) RemainingTime added in v1.9.0 

func (rndm *RoundHandlerMock) RemainingTime(startTime time.Time, maxTime time.Duration) time.Duration

RemainingTime -

func (*RoundHandlerMock) RevertOneRound added in v1.9.0 

func (rndm *RoundHandlerMock) RevertOneRound()

RevertOneRound -

func (*RoundHandlerMock) TimeDuration added in v1.9.0 

func (rndm *RoundHandlerMock) TimeDuration() time.Duration

TimeDuration -

func (*RoundHandlerMock) TimeStamp added in v1.9.0 

func (rndm *RoundHandlerMock) TimeStamp() time.Time

TimeStamp -

func (*RoundHandlerMock) UpdateRound added in v1.9.0 

func (rndm *RoundHandlerMock) UpdateRound(genesisRoundTimeStamp time.Time, timeStamp time.Time)

UpdateRound -

type ScheduledProcessorStub 

type ScheduledProcessorStub struct {
	StartScheduledProcessingCalled func(header data.HeaderHandler, body data.BodyHandler, startTime time.Time)
	IsProcessedOKCalled            func() bool
}

ScheduledProcessorStub -

func (*ScheduledProcessorStub) ForceStopScheduledExecutionBlocking 

func (sps *ScheduledProcessorStub) ForceStopScheduledExecutionBlocking()

ForceStopScheduledExecutionBlocking -

func (*ScheduledProcessorStub) IsInterfaceNil 

func (sps *ScheduledProcessorStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*ScheduledProcessorStub) IsProcessedOKWithTimeout 

func (sps *ScheduledProcessorStub) IsProcessedOKWithTimeout() bool

IsProcessedOKWithTimeout -

func (*ScheduledProcessorStub) StartScheduledProcessing 

func (sps *ScheduledProcessorStub) StartScheduledProcessing(header data.HeaderHandler, body data.BodyHandler, startTime time.Time)

StartScheduledProcessing -

type SigningHandlerStub added in v1.6.0 

type SigningHandlerStub struct {
	ResetCalled                            func(pubKeys []string) error
	CreateSignatureShareForPublicKeyCalled func(message []byte, index uint16, epoch uint32, publicKeyBytes []byte) ([]byte, error)
	CreateSignatureForPublicKeyCalled      func(message []byte, publicKeyBytes []byte) ([]byte, error)
	VerifySingleSignatureCalled            func(publicKeyBytes []byte, message []byte, signature []byte) error
	StoreSignatureShareCalled              func(index uint16, sig []byte) error
	SignatureShareCalled                   func(index uint16) ([]byte, error)
	VerifySignatureShareCalled             func(index uint16, sig []byte, msg []byte, epoch uint32) error
	AggregateSigsCalled                    func(bitmap []byte, epoch uint32) ([]byte, error)
	SetAggregatedSigCalled                 func(_ []byte) error
	VerifyCalled                           func(msg []byte, bitmap []byte, epoch uint32) error
}

SigningHandlerStub implements SigningHandler interface

func (*SigningHandlerStub) AggregateSigs added in v1.6.0 

func (stub *SigningHandlerStub) AggregateSigs(bitmap []byte, epoch uint32) ([]byte, error)

AggregateSigs -

func (*SigningHandlerStub) CreateSignatureForPublicKey added in v1.6.0 

func (stub *SigningHandlerStub) CreateSignatureForPublicKey(message []byte, publicKeyBytes []byte) ([]byte, error)

CreateSignatureForPublicKey -

func (*SigningHandlerStub) CreateSignatureShareForPublicKey added in v1.6.0 

func (stub *SigningHandlerStub) CreateSignatureShareForPublicKey(message []byte, index uint16, epoch uint32, publicKeyBytes []byte) ([]byte, error)

CreateSignatureShareForPublicKey -

func (*SigningHandlerStub) IsInterfaceNil added in v1.6.0 

func (stub *SigningHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*SigningHandlerStub) Reset added in v1.6.0 

func (stub *SigningHandlerStub) Reset(pubKeys []string) error

Reset -

func (*SigningHandlerStub) SetAggregatedSig added in v1.6.0 

func (stub *SigningHandlerStub) SetAggregatedSig(sig []byte) error

SetAggregatedSig -

func (*SigningHandlerStub) SignatureShare added in v1.6.0 

func (stub *SigningHandlerStub) SignatureShare(index uint16) ([]byte, error)

SignatureShare -

func (*SigningHandlerStub) StoreSignatureShare added in v1.6.0 

func (stub *SigningHandlerStub) StoreSignatureShare(index uint16, sig []byte) error

StoreSignatureShare -

func (*SigningHandlerStub) Verify added in v1.6.0 

func (stub *SigningHandlerStub) Verify(msg []byte, bitmap []byte, epoch uint32) error

Verify -

func (*SigningHandlerStub) VerifySignatureShare added in v1.6.0 

func (stub *SigningHandlerStub) VerifySignatureShare(index uint16, sig []byte, msg []byte, epoch uint32) error

VerifySignatureShare -

func (*SigningHandlerStub) VerifySingleSignature added in v1.6.0 

func (stub *SigningHandlerStub) VerifySingleSignature(publicKeyBytes []byte, message []byte, signature []byte) error

VerifySingleSignature -

type SposWorkerMock added in v1.9.0 

type SposWorkerMock struct {
	AddReceivedMessageCallCalled func(
		messageType consensus.MessageType,
		receivedMessageCall func(ctx context.Context, cnsDta *consensus.Message) bool,
	)
	AddReceivedHeaderHandlerCalled         func(handler func(data.HeaderHandler))
	RemoveAllReceivedHeaderHandlersCalled  func()
	AddReceivedProofHandlerCalled          func(handler func(proofHandler consensus.ProofHandler))
	RemoveAllReceivedMessagesCallsCalled   func()
	ProcessReceivedMessageCalled           func(message p2p.MessageP2P) ([]byte, error)
	SendConsensusMessageCalled             func(cnsDta *consensus.Message) bool
	ExtendCalled                           func(subroundId int)
	GetConsensusStateChangedChannelsCalled func() chan bool
	GetBroadcastBlockCalled                func(data.BodyHandler, data.HeaderHandler) error
	GetBroadcastHeaderCalled               func(data.HeaderHandler) error
	ExecuteStoredMessagesCalled            func()
	DisplayStatisticsCalled                func()
	ReceivedHeaderCalled                   func(headerHandler data.HeaderHandler, headerHash []byte)
	SetAppStatusHandlerCalled              func(ash core.AppStatusHandler) error
	ResetConsensusMessagesCalled           func()
	ResetConsensusStateCalled              func()
	ReceivedProofCalled                    func(proofHandler consensus.ProofHandler)
	ResetConsensusRoundStateCalled         func()
	ResetInvalidSignersCacheCalled         func()
}

SposWorkerMock -

func (*SposWorkerMock) AddReceivedHeaderHandler added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) AddReceivedHeaderHandler(handler func(data.HeaderHandler))

AddReceivedHeaderHandler -

func (*SposWorkerMock) AddReceivedMessageCall added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) AddReceivedMessageCall(messageType consensus.MessageType,
	receivedMessageCall func(ctx context.Context, cnsDta *consensus.Message) bool)

AddReceivedMessageCall -

func (*SposWorkerMock) AddReceivedProofHandler added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) AddReceivedProofHandler(handler func(proofHandler consensus.ProofHandler))

func (*SposWorkerMock) BroadcastBlock added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) BroadcastBlock(body data.BodyHandler, header data.HeaderHandler) error

BroadcastBlock -

func (*SposWorkerMock) Close added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) Close() error

Close -

func (*SposWorkerMock) DisplayStatistics added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) DisplayStatistics()

DisplayStatistics -

func (*SposWorkerMock) ExecuteStoredMessages added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) ExecuteStoredMessages()

ExecuteStoredMessages -

func (*SposWorkerMock) Extend added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) Extend(subroundId int)

Extend -

func (*SposWorkerMock) GetConsensusStateChangedChannel added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) GetConsensusStateChangedChannel() chan bool

GetConsensusStateChangedChannel -

func (*SposWorkerMock) IsInterfaceNil added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*SposWorkerMock) ProcessReceivedMessage added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID, _ p2p.MessageHandler) ([]byte, error)

ProcessReceivedMessage -

func (*SposWorkerMock) ReceivedHeader added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) ReceivedHeader(headerHandler data.HeaderHandler, headerHash []byte)

ReceivedHeader -

func (*SposWorkerMock) ReceivedProof added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) ReceivedProof(proofHandler consensus.ProofHandler)

ReceivedProof -

func (*SposWorkerMock) RemoveAllReceivedHeaderHandlers added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) RemoveAllReceivedHeaderHandlers()

RemoveAllReceivedHeaderHandlers -

func (*SposWorkerMock) RemoveAllReceivedMessagesCalls added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) RemoveAllReceivedMessagesCalls()

RemoveAllReceivedMessagesCalls -

func (*SposWorkerMock) ResetConsensusMessages added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) ResetConsensusMessages()

ResetConsensusMessages -

func (*SposWorkerMock) ResetConsensusRoundState added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) ResetConsensusRoundState()

ResetConsensusRoundState -

func (*SposWorkerMock) ResetConsensusState added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) ResetConsensusState()

ResetConsensusState -

func (*SposWorkerMock) ResetInvalidSignersCache added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) ResetInvalidSignersCache()

ResetInvalidSignersCache -

func (*SposWorkerMock) SendConsensusMessage added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) SendConsensusMessage(cnsDta *consensus.Message) bool

SendConsensusMessage -

func (*SposWorkerMock) StartWorking added in v1.9.0 

func (sposWorkerMock *SposWorkerMock) StartWorking()

StartWorking -

type SyncTimerMock added in v1.9.0 

type SyncTimerMock struct {
	ClockOffsetCalled func() time.Duration
	CurrentTimeCalled func() time.Time
}

SyncTimerMock mocks the implementation for a SyncTimer

func (*SyncTimerMock) ClockOffset added in v1.9.0 

func (stm *SyncTimerMock) ClockOffset() time.Duration

ClockOffset method gets the current time offset

func (*SyncTimerMock) Close added in v1.9.0 

func (stm *SyncTimerMock) Close() error

Close -

func (*SyncTimerMock) CurrentTime added in v1.9.0 

func (stm *SyncTimerMock) CurrentTime() time.Time

CurrentTime method gets the current time on which is added the current offset

func (*SyncTimerMock) FormattedCurrentTime added in v1.9.0 

func (stm *SyncTimerMock) FormattedCurrentTime() string

FormattedCurrentTime method gets the formatted current time on which is added a given offset

func (*SyncTimerMock) IsInterfaceNil added in v1.9.0 

func (stm *SyncTimerMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*SyncTimerMock) StartSyncingTime added in v1.9.0 

func (stm *SyncTimerMock) StartSyncingTime()

StartSyncingTime method does the time synchronization at every syncPeriod time elapsed. This should be started as a go routine

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.