Documentation ¶
Index ¶
- type BlockProducer
- type BlockSigner
- type BlockSignerDecoder
- type Committee
- func (_m *Committee) DKG(blockID flow.Identifier) (hotstuff.DKG, error)
- func (_m *Committee) Identities(blockID flow.Identifier) (flow.IdentityList, error)
- func (_m *Committee) Identity(blockID flow.Identifier, participantID flow.Identifier) (*flow.Identity, error)
- func (_m *Committee) LeaderForView(view uint64) (flow.Identifier, error)
- func (_m *Committee) Self() flow.Identifier
- type Communicator
- type Consumer
- func (_m *Consumer) OnBlockIncorporated(_a0 *model.Block)
- func (_m *Consumer) OnDoubleProposeDetected(_a0 *model.Block, _a1 *model.Block)
- func (_m *Consumer) OnDoubleVotingDetected(_a0 *model.Vote, _a1 *model.Vote)
- func (_m *Consumer) OnEnteringView(viewNumber uint64, leader flow.Identifier)
- func (_m *Consumer) OnEventProcessed()
- func (_m *Consumer) OnFinalizedBlock(_a0 *model.Block)
- func (_m *Consumer) OnForkChoiceGenerated(_a0 uint64, _a1 *flow.QuorumCertificate)
- func (_m *Consumer) OnInvalidVoteDetected(_a0 *model.Vote)
- func (_m *Consumer) OnProposingBlock(proposal *model.Proposal)
- func (_m *Consumer) OnQcConstructedFromVotes(curView uint64, qc *flow.QuorumCertificate)
- func (_m *Consumer) OnQcIncorporated(_a0 *flow.QuorumCertificate)
- func (_m *Consumer) OnQcTriggeredViewChange(qc *flow.QuorumCertificate, newView uint64)
- func (_m *Consumer) OnReachedTimeout(timeout *model.TimerInfo)
- func (_m *Consumer) OnReceiveProposal(currentView uint64, proposal *model.Proposal)
- func (_m *Consumer) OnReceiveVote(currentView uint64, vote *model.Vote)
- func (_m *Consumer) OnStartingTimeout(_a0 *model.TimerInfo)
- func (_m *Consumer) OnVoteForInvalidBlockDetected(vote *model.Vote, invalidProposal *model.Proposal)
- func (_m *Consumer) OnVoting(vote *model.Vote)
- type DKG
- type EventHandler
- type EventHandlerV2
- func (_m *EventHandlerV2) OnLocalTimeout() error
- func (_m *EventHandlerV2) OnQCConstructed(qc *flow.QuorumCertificate) error
- func (_m *EventHandlerV2) OnReceiveProposal(proposal *model.Proposal) error
- func (_m *EventHandlerV2) Start() error
- func (_m *EventHandlerV2) TimeoutChannel() <-chan time.Time
- type EventLoop
- func (_m *EventLoop) Done() <-chan struct{}
- func (_m *EventLoop) Ready() <-chan struct{}
- func (_m *EventLoop) Start(_a0 irrecoverable.SignalerContext)
- func (_m *EventLoop) SubmitProposal(proposal *flow.Header, parentView uint64) <-chan struct{}
- func (_m *EventLoop) SubmitTrustedQC(qc *flow.QuorumCertificate)
- type FinalizationConsumer
- type FollowerLogic
- type Forks
- func (_m *Forks) AddBlock(block *model.Block) error
- func (_m *Forks) AddQC(qc *flow.QuorumCertificate) error
- func (_m *Forks) FinalizedBlock() *model.Block
- func (_m *Forks) FinalizedView() uint64
- func (_m *Forks) GetBlock(id flow.Identifier) (*model.Block, bool)
- func (_m *Forks) GetBlocksForView(view uint64) []*model.Block
- func (_m *Forks) IsSafeBlock(block *model.Block) bool
- func (_m *Forks) MakeForkChoice(curView uint64) (*flow.QuorumCertificate, *model.Block, error)
- type ForksReader
- type OnQCCreated
- type PaceMaker
- func (_m *PaceMaker) BlockRateDelay() time.Duration
- func (_m *PaceMaker) CurView() uint64
- func (_m *PaceMaker) OnTimeout() *model.NewViewEvent
- func (_m *PaceMaker) Start()
- func (_m *PaceMaker) TimeoutChannel() <-chan time.Time
- func (_m *PaceMaker) UpdateCurViewWithBlock(block *model.Block, isLeaderForNextView bool) (*model.NewViewEvent, bool)
- func (_m *PaceMaker) UpdateCurViewWithQC(qc *flow.QuorumCertificate) (*model.NewViewEvent, bool)
- type Packer
- type Persister
- type QCCreatedConsumer
- type RandomBeaconInspector
- func (_m *RandomBeaconInspector) EnoughShares() bool
- func (_m *RandomBeaconInspector) Reconstruct() (crypto.Signature, error)
- func (_m *RandomBeaconInspector) TrustedAdd(signerIndex int, share crypto.Signature) (bool, error)
- func (_m *RandomBeaconInspector) Verify(signerIndex int, share crypto.Signature) error
- type RandomBeaconReconstructor
- func (_m *RandomBeaconReconstructor) EnoughShares() bool
- func (_m *RandomBeaconReconstructor) Reconstruct() (crypto.Signature, error)
- func (_m *RandomBeaconReconstructor) TrustedAdd(signerID flow.Identifier, sig crypto.Signature) (bool, error)
- func (_m *RandomBeaconReconstructor) Verify(signerID flow.Identifier, sig crypto.Signature) error
- type RandomBeaconSigner
- func (_m *RandomBeaconSigner) EnoughShares() bool
- func (_m *RandomBeaconSigner) Reconstruct() (crypto.Signature, error)
- func (_m *RandomBeaconSigner) SignShare() (crypto.Signature, error)
- func (_m *RandomBeaconSigner) TrustedAdd(signerIndex int, share crypto.Signature) (bool, error)
- func (_m *RandomBeaconSigner) Verify(signerIndex int, share crypto.Signature) error
- type Signer
- type Validator
- type Verifier
- type VerifyingVoteProcessor
- type VoteAggregator
- func (_m *VoteAggregator) AddBlock(block *model.Proposal) error
- func (_m *VoteAggregator) AddVote(vote *model.Vote)
- func (_m *VoteAggregator) Done() <-chan struct{}
- func (_m *VoteAggregator) InvalidBlock(block *model.Proposal) error
- func (_m *VoteAggregator) PruneUpToView(view uint64)
- func (_m *VoteAggregator) Ready() <-chan struct{}
- func (_m *VoteAggregator) Start(_a0 irrecoverable.SignalerContext)
- type VoteCollector
- func (_m *VoteCollector) AddVote(vote *model.Vote) error
- func (_m *VoteCollector) ProcessBlock(block *model.Proposal) error
- func (_m *VoteCollector) RegisterVoteConsumer(consumer hotstuff.VoteConsumer)
- func (_m *VoteCollector) Status() hotstuff.VoteCollectorStatus
- func (_m *VoteCollector) View() uint64
- type VoteCollectorState
- type VoteCollectors
- func (_m *VoteCollectors) Done() <-chan struct{}
- func (_m *VoteCollectors) GetOrCreateCollector(view uint64) (hotstuff.VoteCollector, bool, error)
- func (_m *VoteCollectors) PruneUpToView(lowestRetainedView uint64)
- func (_m *VoteCollectors) Ready() <-chan struct{}
- func (_m *VoteCollectors) Start(_a0 irrecoverable.SignalerContext)
- type VoteConsumer
- type VoteProcessor
- type VoteProcessorFactory
- type Voter
- type WeightedSignatureAggregator
- func (_m *WeightedSignatureAggregator) Aggregate() ([]flow.Identifier, []byte, error)
- func (_m *WeightedSignatureAggregator) TotalWeight() uint64
- func (_m *WeightedSignatureAggregator) TrustedAdd(signerID flow.Identifier, sig crypto.Signature) (uint64, error)
- func (_m *WeightedSignatureAggregator) Verify(signerID flow.Identifier, sig crypto.Signature) error
- type Workerpool
- type Workers
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockProducer ¶
BlockProducer is an autogenerated mock type for the BlockProducer type
func NewBlockProducer ¶ added in v0.26.1
func NewBlockProducer(t mockConstructorTestingTNewBlockProducer) *BlockProducer
NewBlockProducer creates a new instance of BlockProducer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*BlockProducer) MakeBlockProposal ¶
func (_m *BlockProducer) MakeBlockProposal(qc *flow.QuorumCertificate, view uint64) (*model.Proposal, error)
MakeBlockProposal provides a mock function with given fields: qc, view
type BlockSigner ¶ added in v0.23.9
BlockSigner is an autogenerated mock type for the BlockSigner type
func NewBlockSigner ¶ added in v0.26.1
func NewBlockSigner(t mockConstructorTestingTNewBlockSigner) *BlockSigner
NewBlockSigner creates a new instance of BlockSigner. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*BlockSigner) CreateVote ¶ added in v0.23.9
CreateVote provides a mock function with given fields: _a0
type BlockSignerDecoder ¶ added in v0.26.17
BlockSignerDecoder is an autogenerated mock type for the BlockSignerDecoder type
func NewBlockSignerDecoder ¶ added in v0.26.17
func NewBlockSignerDecoder(t mockConstructorTestingTNewBlockSignerDecoder) *BlockSignerDecoder
NewBlockSignerDecoder creates a new instance of BlockSignerDecoder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*BlockSignerDecoder) DecodeSignerIDs ¶ added in v0.26.17
func (_m *BlockSignerDecoder) DecodeSignerIDs(header *flow.Header) (flow.IdentifierList, error)
DecodeSignerIDs provides a mock function with given fields: header
type Committee ¶
Committee is an autogenerated mock type for the Committee type
func NewCommittee ¶ added in v0.26.1
func NewCommittee(t mockConstructorTestingTNewCommittee) *Committee
NewCommittee creates a new instance of Committee. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Committee) Identities ¶
func (_m *Committee) Identities(blockID flow.Identifier) (flow.IdentityList, error)
Identities provides a mock function with given fields: blockID
func (*Committee) Identity ¶
func (_m *Committee) Identity(blockID flow.Identifier, participantID flow.Identifier) (*flow.Identity, error)
Identity provides a mock function with given fields: blockID, participantID
func (*Committee) LeaderForView ¶
func (_m *Committee) LeaderForView(view uint64) (flow.Identifier, error)
LeaderForView provides a mock function with given fields: view
func (*Committee) Self ¶
func (_m *Committee) Self() flow.Identifier
Self provides a mock function with given fields:
type Communicator ¶
Communicator is an autogenerated mock type for the Communicator type
func NewCommunicator ¶ added in v0.26.1
func NewCommunicator(t mockConstructorTestingTNewCommunicator) *Communicator
NewCommunicator creates a new instance of Communicator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Communicator) BroadcastProposal ¶
func (_m *Communicator) BroadcastProposal(proposal *flow.Header) error
BroadcastProposal provides a mock function with given fields: proposal
func (*Communicator) BroadcastProposalWithDelay ¶
func (_m *Communicator) BroadcastProposalWithDelay(proposal *flow.Header, delay time.Duration) error
BroadcastProposalWithDelay provides a mock function with given fields: proposal, delay
func (*Communicator) SendVote ¶
func (_m *Communicator) SendVote(blockID flow.Identifier, view uint64, sigData []byte, recipientID flow.Identifier) error
SendVote provides a mock function with given fields: blockID, view, sigData, recipientID
type Consumer ¶
Consumer is an autogenerated mock type for the Consumer type
func NewConsumer ¶ added in v0.26.1
func NewConsumer(t mockConstructorTestingTNewConsumer) *Consumer
NewConsumer creates a new instance of Consumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Consumer) OnBlockIncorporated ¶
OnBlockIncorporated provides a mock function with given fields: _a0
func (*Consumer) OnDoubleProposeDetected ¶
OnDoubleProposeDetected provides a mock function with given fields: _a0, _a1
func (*Consumer) OnDoubleVotingDetected ¶
OnDoubleVotingDetected provides a mock function with given fields: _a0, _a1
func (*Consumer) OnEnteringView ¶
func (_m *Consumer) OnEnteringView(viewNumber uint64, leader flow.Identifier)
OnEnteringView provides a mock function with given fields: viewNumber, leader
func (*Consumer) OnEventProcessed ¶
func (_m *Consumer) OnEventProcessed()
OnEventProcessed provides a mock function with given fields:
func (*Consumer) OnFinalizedBlock ¶
OnFinalizedBlock provides a mock function with given fields: _a0
func (*Consumer) OnForkChoiceGenerated ¶
func (_m *Consumer) OnForkChoiceGenerated(_a0 uint64, _a1 *flow.QuorumCertificate)
OnForkChoiceGenerated provides a mock function with given fields: _a0, _a1
func (*Consumer) OnInvalidVoteDetected ¶
OnInvalidVoteDetected provides a mock function with given fields: _a0
func (*Consumer) OnProposingBlock ¶
OnProposingBlock provides a mock function with given fields: proposal
func (*Consumer) OnQcConstructedFromVotes ¶
func (_m *Consumer) OnQcConstructedFromVotes(curView uint64, qc *flow.QuorumCertificate)
OnQcConstructedFromVotes provides a mock function with given fields: curView, qc
func (*Consumer) OnQcIncorporated ¶
func (_m *Consumer) OnQcIncorporated(_a0 *flow.QuorumCertificate)
OnQcIncorporated provides a mock function with given fields: _a0
func (*Consumer) OnQcTriggeredViewChange ¶
func (_m *Consumer) OnQcTriggeredViewChange(qc *flow.QuorumCertificate, newView uint64)
OnQcTriggeredViewChange provides a mock function with given fields: qc, newView
func (*Consumer) OnReachedTimeout ¶
OnReachedTimeout provides a mock function with given fields: timeout
func (*Consumer) OnReceiveProposal ¶
OnReceiveProposal provides a mock function with given fields: currentView, proposal
func (*Consumer) OnReceiveVote ¶
OnReceiveVote provides a mock function with given fields: currentView, vote
func (*Consumer) OnStartingTimeout ¶
OnStartingTimeout provides a mock function with given fields: _a0
type DKG ¶
DKG is an autogenerated mock type for the DKG type
func NewDKG ¶ added in v0.26.1
func NewDKG(t mockConstructorTestingTNewDKG) *DKG
NewDKG creates a new instance of DKG. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*DKG) Index ¶
func (_m *DKG) Index(nodeID flow.Identifier) (uint, error)
Index provides a mock function with given fields: nodeID
type EventHandler ¶
EventHandler is an autogenerated mock type for the EventHandler type
func NewEventHandler ¶ added in v0.26.1
func NewEventHandler(t mockConstructorTestingTNewEventHandler) *EventHandler
NewEventHandler creates a new instance of EventHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*EventHandler) OnLocalTimeout ¶
func (_m *EventHandler) OnLocalTimeout() error
OnLocalTimeout provides a mock function with given fields:
func (*EventHandler) OnQCConstructed ¶ added in v0.23.9
func (_m *EventHandler) OnQCConstructed(qc *flow.QuorumCertificate) error
OnQCConstructed provides a mock function with given fields: qc
func (*EventHandler) OnReceiveProposal ¶
func (_m *EventHandler) OnReceiveProposal(proposal *model.Proposal) error
OnReceiveProposal provides a mock function with given fields: proposal
func (*EventHandler) Start ¶
func (_m *EventHandler) Start() error
Start provides a mock function with given fields:
func (*EventHandler) TimeoutChannel ¶
func (_m *EventHandler) TimeoutChannel() <-chan time.Time
TimeoutChannel provides a mock function with given fields:
type EventHandlerV2 ¶ added in v0.23.9
EventHandlerV2 is an autogenerated mock type for the EventHandlerV2 type
func (*EventHandlerV2) OnLocalTimeout ¶ added in v0.23.9
func (_m *EventHandlerV2) OnLocalTimeout() error
OnLocalTimeout provides a mock function with given fields:
func (*EventHandlerV2) OnQCConstructed ¶ added in v0.23.9
func (_m *EventHandlerV2) OnQCConstructed(qc *flow.QuorumCertificate) error
OnQCConstructed provides a mock function with given fields: qc
func (*EventHandlerV2) OnReceiveProposal ¶ added in v0.23.9
func (_m *EventHandlerV2) OnReceiveProposal(proposal *model.Proposal) error
OnReceiveProposal provides a mock function with given fields: proposal
func (*EventHandlerV2) Start ¶ added in v0.23.9
func (_m *EventHandlerV2) Start() error
Start provides a mock function with given fields:
func (*EventHandlerV2) TimeoutChannel ¶ added in v0.23.9
func (_m *EventHandlerV2) TimeoutChannel() <-chan time.Time
TimeoutChannel provides a mock function with given fields:
type EventLoop ¶ added in v0.23.9
EventLoop is an autogenerated mock type for the EventLoop type
func NewEventLoop ¶ added in v0.26.1
func NewEventLoop(t mockConstructorTestingTNewEventLoop) *EventLoop
NewEventLoop creates a new instance of EventLoop. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*EventLoop) Done ¶ added in v0.23.9
func (_m *EventLoop) Done() <-chan struct{}
Done provides a mock function with given fields:
func (*EventLoop) Ready ¶ added in v0.23.9
func (_m *EventLoop) Ready() <-chan struct{}
Ready provides a mock function with given fields:
func (*EventLoop) Start ¶ added in v0.23.9
func (_m *EventLoop) Start(_a0 irrecoverable.SignalerContext)
Start provides a mock function with given fields: _a0
func (*EventLoop) SubmitProposal ¶ added in v0.23.9
SubmitProposal provides a mock function with given fields: proposal, parentView
func (*EventLoop) SubmitTrustedQC ¶ added in v0.23.9
func (_m *EventLoop) SubmitTrustedQC(qc *flow.QuorumCertificate)
SubmitTrustedQC provides a mock function with given fields: qc
type FinalizationConsumer ¶
FinalizationConsumer is an autogenerated mock type for the FinalizationConsumer type
func NewFinalizationConsumer ¶ added in v0.26.1
func NewFinalizationConsumer(t mockConstructorTestingTNewFinalizationConsumer) *FinalizationConsumer
NewFinalizationConsumer creates a new instance of FinalizationConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*FinalizationConsumer) OnBlockIncorporated ¶
func (_m *FinalizationConsumer) OnBlockIncorporated(_a0 *model.Block)
OnBlockIncorporated provides a mock function with given fields: _a0
func (*FinalizationConsumer) OnDoubleProposeDetected ¶
func (_m *FinalizationConsumer) OnDoubleProposeDetected(_a0 *model.Block, _a1 *model.Block)
OnDoubleProposeDetected provides a mock function with given fields: _a0, _a1
func (*FinalizationConsumer) OnFinalizedBlock ¶
func (_m *FinalizationConsumer) OnFinalizedBlock(_a0 *model.Block)
OnFinalizedBlock provides a mock function with given fields: _a0
type FollowerLogic ¶
FollowerLogic is an autogenerated mock type for the FollowerLogic type
func NewFollowerLogic ¶ added in v0.26.1
func NewFollowerLogic(t mockConstructorTestingTNewFollowerLogic) *FollowerLogic
NewFollowerLogic creates a new instance of FollowerLogic. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*FollowerLogic) AddBlock ¶
func (_m *FollowerLogic) AddBlock(proposal *model.Proposal) error
AddBlock provides a mock function with given fields: proposal
func (*FollowerLogic) FinalizedBlock ¶
func (_m *FollowerLogic) FinalizedBlock() *model.Block
FinalizedBlock provides a mock function with given fields:
type Forks ¶
Forks is an autogenerated mock type for the Forks type
func NewForks ¶ added in v0.26.1
func NewForks(t mockConstructorTestingTNewForks) *Forks
NewForks creates a new instance of Forks. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Forks) AddQC ¶
func (_m *Forks) AddQC(qc *flow.QuorumCertificate) error
AddQC provides a mock function with given fields: qc
func (*Forks) FinalizedBlock ¶
FinalizedBlock provides a mock function with given fields:
func (*Forks) FinalizedView ¶
FinalizedView provides a mock function with given fields:
func (*Forks) GetBlocksForView ¶
GetBlocksForView provides a mock function with given fields: view
func (*Forks) IsSafeBlock ¶
IsSafeBlock provides a mock function with given fields: block
func (*Forks) MakeForkChoice ¶
MakeForkChoice provides a mock function with given fields: curView
type ForksReader ¶
ForksReader is an autogenerated mock type for the ForksReader type
func NewForksReader ¶ added in v0.26.1
func NewForksReader(t mockConstructorTestingTNewForksReader) *ForksReader
NewForksReader creates a new instance of ForksReader. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ForksReader) FinalizedBlock ¶
func (_m *ForksReader) FinalizedBlock() *model.Block
FinalizedBlock provides a mock function with given fields:
func (*ForksReader) FinalizedView ¶
func (_m *ForksReader) FinalizedView() uint64
FinalizedView provides a mock function with given fields:
func (*ForksReader) GetBlock ¶
func (_m *ForksReader) GetBlock(id flow.Identifier) (*model.Block, bool)
GetBlock provides a mock function with given fields: id
func (*ForksReader) GetBlocksForView ¶
func (_m *ForksReader) GetBlocksForView(view uint64) []*model.Block
GetBlocksForView provides a mock function with given fields: view
func (*ForksReader) IsSafeBlock ¶
func (_m *ForksReader) IsSafeBlock(block *model.Block) bool
IsSafeBlock provides a mock function with given fields: block
type OnQCCreated ¶ added in v0.26.1
OnQCCreated is an autogenerated mock type for the OnQCCreated type
func NewOnQCCreated ¶ added in v0.26.1
func NewOnQCCreated(t mockConstructorTestingTNewOnQCCreated) *OnQCCreated
NewOnQCCreated creates a new instance of OnQCCreated. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*OnQCCreated) Execute ¶ added in v0.26.1
func (_m *OnQCCreated) Execute(_a0 *flow.QuorumCertificate)
Execute provides a mock function with given fields: _a0
type PaceMaker ¶
PaceMaker is an autogenerated mock type for the PaceMaker type
func NewPaceMaker ¶ added in v0.26.1
func NewPaceMaker(t mockConstructorTestingTNewPaceMaker) *PaceMaker
NewPaceMaker creates a new instance of PaceMaker. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*PaceMaker) BlockRateDelay ¶
BlockRateDelay provides a mock function with given fields:
func (*PaceMaker) OnTimeout ¶
func (_m *PaceMaker) OnTimeout() *model.NewViewEvent
OnTimeout provides a mock function with given fields:
func (*PaceMaker) Start ¶
func (_m *PaceMaker) Start()
Start provides a mock function with given fields:
func (*PaceMaker) TimeoutChannel ¶
TimeoutChannel provides a mock function with given fields:
func (*PaceMaker) UpdateCurViewWithBlock ¶
func (_m *PaceMaker) UpdateCurViewWithBlock(block *model.Block, isLeaderForNextView bool) (*model.NewViewEvent, bool)
UpdateCurViewWithBlock provides a mock function with given fields: block, isLeaderForNextView
func (*PaceMaker) UpdateCurViewWithQC ¶
func (_m *PaceMaker) UpdateCurViewWithQC(qc *flow.QuorumCertificate) (*model.NewViewEvent, bool)
UpdateCurViewWithQC provides a mock function with given fields: qc
type Packer ¶ added in v0.23.9
Packer is an autogenerated mock type for the Packer type
func NewPacker ¶ added in v0.26.1
func NewPacker(t mockConstructorTestingTNewPacker) *Packer
NewPacker creates a new instance of Packer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Packer) Pack ¶ added in v0.23.9
func (_m *Packer) Pack(blockID flow.Identifier, sig *hotstuff.BlockSignatureData) ([]byte, []byte, error)
Pack provides a mock function with given fields: blockID, sig
func (*Packer) Unpack ¶ added in v0.23.9
func (_m *Packer) Unpack(signerIdentities flow.IdentityList, sigData []byte) (*hotstuff.BlockSignatureData, error)
Unpack provides a mock function with given fields: signerIdentities, sigData
type Persister ¶
Persister is an autogenerated mock type for the Persister type
func NewPersister ¶ added in v0.26.1
func NewPersister(t mockConstructorTestingTNewPersister) *Persister
NewPersister creates a new instance of Persister. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Persister) GetStarted ¶
GetStarted provides a mock function with given fields:
func (*Persister) PutStarted ¶
PutStarted provides a mock function with given fields: view
type QCCreatedConsumer ¶ added in v0.23.9
QCCreatedConsumer is an autogenerated mock type for the QCCreatedConsumer type
func NewQCCreatedConsumer ¶ added in v0.26.1
func NewQCCreatedConsumer(t mockConstructorTestingTNewQCCreatedConsumer) *QCCreatedConsumer
NewQCCreatedConsumer creates a new instance of QCCreatedConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*QCCreatedConsumer) OnQcConstructedFromVotes ¶ added in v0.23.9
func (_m *QCCreatedConsumer) OnQcConstructedFromVotes(_a0 *flow.QuorumCertificate)
OnQcConstructedFromVotes provides a mock function with given fields: _a0
type RandomBeaconInspector ¶ added in v0.23.9
RandomBeaconInspector is an autogenerated mock type for the RandomBeaconInspector type
func NewRandomBeaconInspector ¶ added in v0.26.1
func NewRandomBeaconInspector(t mockConstructorTestingTNewRandomBeaconInspector) *RandomBeaconInspector
NewRandomBeaconInspector creates a new instance of RandomBeaconInspector. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*RandomBeaconInspector) EnoughShares ¶ added in v0.23.9
func (_m *RandomBeaconInspector) EnoughShares() bool
EnoughShares provides a mock function with given fields:
func (*RandomBeaconInspector) Reconstruct ¶ added in v0.23.9
func (_m *RandomBeaconInspector) Reconstruct() (crypto.Signature, error)
Reconstruct provides a mock function with given fields:
func (*RandomBeaconInspector) TrustedAdd ¶ added in v0.23.9
TrustedAdd provides a mock function with given fields: signerIndex, share
type RandomBeaconReconstructor ¶ added in v0.23.9
RandomBeaconReconstructor is an autogenerated mock type for the RandomBeaconReconstructor type
func NewRandomBeaconReconstructor ¶ added in v0.26.1
func NewRandomBeaconReconstructor(t mockConstructorTestingTNewRandomBeaconReconstructor) *RandomBeaconReconstructor
NewRandomBeaconReconstructor creates a new instance of RandomBeaconReconstructor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*RandomBeaconReconstructor) EnoughShares ¶ added in v0.23.9
func (_m *RandomBeaconReconstructor) EnoughShares() bool
EnoughShares provides a mock function with given fields:
func (*RandomBeaconReconstructor) Reconstruct ¶ added in v0.23.9
func (_m *RandomBeaconReconstructor) Reconstruct() (crypto.Signature, error)
Reconstruct provides a mock function with given fields:
func (*RandomBeaconReconstructor) TrustedAdd ¶ added in v0.23.9
func (_m *RandomBeaconReconstructor) TrustedAdd(signerID flow.Identifier, sig crypto.Signature) (bool, error)
TrustedAdd provides a mock function with given fields: signerID, sig
func (*RandomBeaconReconstructor) Verify ¶ added in v0.23.9
func (_m *RandomBeaconReconstructor) Verify(signerID flow.Identifier, sig crypto.Signature) error
Verify provides a mock function with given fields: signerID, sig
type RandomBeaconSigner ¶ added in v0.23.9
RandomBeaconSigner is an autogenerated mock type for the RandomBeaconSigner type
func (*RandomBeaconSigner) EnoughShares ¶ added in v0.23.9
func (_m *RandomBeaconSigner) EnoughShares() bool
EnoughShares provides a mock function with given fields:
func (*RandomBeaconSigner) Reconstruct ¶ added in v0.23.9
func (_m *RandomBeaconSigner) Reconstruct() (crypto.Signature, error)
Reconstruct provides a mock function with given fields:
func (*RandomBeaconSigner) SignShare ¶ added in v0.23.9
func (_m *RandomBeaconSigner) SignShare() (crypto.Signature, error)
SignShare provides a mock function with given fields:
func (*RandomBeaconSigner) TrustedAdd ¶ added in v0.23.9
TrustedAdd provides a mock function with given fields: signerIndex, share
type Signer ¶
Signer is an autogenerated mock type for the Signer type
func NewSigner ¶ added in v0.26.1
func NewSigner(t mockConstructorTestingTNewSigner) *Signer
NewSigner creates a new instance of Signer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Signer) CreateProposal ¶
CreateProposal provides a mock function with given fields: block
type Validator ¶
Validator is an autogenerated mock type for the Validator type
func NewValidator ¶ added in v0.26.1
func NewValidator(t mockConstructorTestingTNewValidator) *Validator
NewValidator creates a new instance of Validator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Validator) ValidateProposal ¶
ValidateProposal provides a mock function with given fields: proposal
func (*Validator) ValidateQC ¶
ValidateQC provides a mock function with given fields: qc, block
type Verifier ¶
Verifier is an autogenerated mock type for the Verifier type
func NewVerifier ¶ added in v0.26.1
func NewVerifier(t mockConstructorTestingTNewVerifier) *Verifier
NewVerifier creates a new instance of Verifier. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
type VerifyingVoteProcessor ¶ added in v0.23.9
VerifyingVoteProcessor is an autogenerated mock type for the VerifyingVoteProcessor type
func NewVerifyingVoteProcessor ¶ added in v0.26.1
func NewVerifyingVoteProcessor(t mockConstructorTestingTNewVerifyingVoteProcessor) *VerifyingVoteProcessor
NewVerifyingVoteProcessor creates a new instance of VerifyingVoteProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*VerifyingVoteProcessor) Block ¶ added in v0.23.9
func (_m *VerifyingVoteProcessor) Block() *model.Block
Block provides a mock function with given fields:
func (*VerifyingVoteProcessor) Process ¶ added in v0.23.9
func (_m *VerifyingVoteProcessor) Process(vote *model.Vote) error
Process provides a mock function with given fields: vote
func (*VerifyingVoteProcessor) Status ¶ added in v0.23.9
func (_m *VerifyingVoteProcessor) Status() hotstuff.VoteCollectorStatus
Status provides a mock function with given fields:
type VoteAggregator ¶
VoteAggregator is an autogenerated mock type for the VoteAggregator type
func NewVoteAggregator ¶ added in v0.26.1
func NewVoteAggregator(t mockConstructorTestingTNewVoteAggregator) *VoteAggregator
NewVoteAggregator creates a new instance of VoteAggregator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*VoteAggregator) AddBlock ¶ added in v0.23.9
func (_m *VoteAggregator) AddBlock(block *model.Proposal) error
AddBlock provides a mock function with given fields: block
func (*VoteAggregator) AddVote ¶ added in v0.23.9
func (_m *VoteAggregator) AddVote(vote *model.Vote)
AddVote provides a mock function with given fields: vote
func (*VoteAggregator) Done ¶ added in v0.23.9
func (_m *VoteAggregator) Done() <-chan struct{}
Done provides a mock function with given fields:
func (*VoteAggregator) InvalidBlock ¶ added in v0.23.9
func (_m *VoteAggregator) InvalidBlock(block *model.Proposal) error
InvalidBlock provides a mock function with given fields: block
func (*VoteAggregator) PruneUpToView ¶ added in v0.23.9
func (_m *VoteAggregator) PruneUpToView(view uint64)
PruneUpToView provides a mock function with given fields: view
func (*VoteAggregator) Ready ¶ added in v0.23.9
func (_m *VoteAggregator) Ready() <-chan struct{}
Ready provides a mock function with given fields:
func (*VoteAggregator) Start ¶ added in v0.23.9
func (_m *VoteAggregator) Start(_a0 irrecoverable.SignalerContext)
Start provides a mock function with given fields: _a0
type VoteCollector ¶ added in v0.23.9
VoteCollector is an autogenerated mock type for the VoteCollector type
func NewVoteCollector ¶ added in v0.26.1
func NewVoteCollector(t mockConstructorTestingTNewVoteCollector) *VoteCollector
NewVoteCollector creates a new instance of VoteCollector. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*VoteCollector) AddVote ¶ added in v0.23.9
func (_m *VoteCollector) AddVote(vote *model.Vote) error
AddVote provides a mock function with given fields: vote
func (*VoteCollector) ProcessBlock ¶ added in v0.23.9
func (_m *VoteCollector) ProcessBlock(block *model.Proposal) error
ProcessBlock provides a mock function with given fields: block
func (*VoteCollector) RegisterVoteConsumer ¶ added in v0.23.9
func (_m *VoteCollector) RegisterVoteConsumer(consumer hotstuff.VoteConsumer)
RegisterVoteConsumer provides a mock function with given fields: consumer
func (*VoteCollector) Status ¶ added in v0.23.9
func (_m *VoteCollector) Status() hotstuff.VoteCollectorStatus
Status provides a mock function with given fields:
func (*VoteCollector) View ¶ added in v0.23.9
func (_m *VoteCollector) View() uint64
View provides a mock function with given fields:
type VoteCollectorState ¶ added in v0.23.9
VoteCollectorState is an autogenerated mock type for the VoteCollectorState type
func (*VoteCollectorState) AddVote ¶ added in v0.23.9
func (_m *VoteCollectorState) AddVote(vote *model.Vote) error
AddVote provides a mock function with given fields: vote
func (*VoteCollectorState) Status ¶ added in v0.23.9
func (_m *VoteCollectorState) Status() hotstuff.VoteCollectorStatus
Status provides a mock function with given fields:
func (*VoteCollectorState) View ¶ added in v0.23.9
func (_m *VoteCollectorState) View() uint64
View provides a mock function with given fields:
type VoteCollectors ¶ added in v0.23.9
VoteCollectors is an autogenerated mock type for the VoteCollectors type
func NewVoteCollectors ¶ added in v0.26.1
func NewVoteCollectors(t mockConstructorTestingTNewVoteCollectors) *VoteCollectors
NewVoteCollectors creates a new instance of VoteCollectors. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*VoteCollectors) Done ¶ added in v0.23.9
func (_m *VoteCollectors) Done() <-chan struct{}
Done provides a mock function with given fields:
func (*VoteCollectors) GetOrCreateCollector ¶ added in v0.23.9
func (_m *VoteCollectors) GetOrCreateCollector(view uint64) (hotstuff.VoteCollector, bool, error)
GetOrCreateCollector provides a mock function with given fields: view
func (*VoteCollectors) PruneUpToView ¶ added in v0.23.9
func (_m *VoteCollectors) PruneUpToView(lowestRetainedView uint64)
PruneUpToView provides a mock function with given fields: lowestRetainedView
func (*VoteCollectors) Ready ¶ added in v0.23.9
func (_m *VoteCollectors) Ready() <-chan struct{}
Ready provides a mock function with given fields:
func (*VoteCollectors) Start ¶ added in v0.23.9
func (_m *VoteCollectors) Start(_a0 irrecoverable.SignalerContext)
Start provides a mock function with given fields: _a0
type VoteConsumer ¶ added in v0.26.1
VoteConsumer is an autogenerated mock type for the VoteConsumer type
func NewVoteConsumer ¶ added in v0.26.1
func NewVoteConsumer(t mockConstructorTestingTNewVoteConsumer) *VoteConsumer
NewVoteConsumer creates a new instance of VoteConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*VoteConsumer) Execute ¶ added in v0.26.1
func (_m *VoteConsumer) Execute(vote *model.Vote)
Execute provides a mock function with given fields: vote
type VoteProcessor ¶ added in v0.23.9
VoteProcessor is an autogenerated mock type for the VoteProcessor type
func NewVoteProcessor ¶ added in v0.26.1
func NewVoteProcessor(t mockConstructorTestingTNewVoteProcessor) *VoteProcessor
NewVoteProcessor creates a new instance of VoteProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*VoteProcessor) Process ¶ added in v0.23.9
func (_m *VoteProcessor) Process(vote *model.Vote) error
Process provides a mock function with given fields: vote
func (*VoteProcessor) Status ¶ added in v0.23.9
func (_m *VoteProcessor) Status() hotstuff.VoteCollectorStatus
Status provides a mock function with given fields:
type VoteProcessorFactory ¶ added in v0.23.9
VoteProcessorFactory is an autogenerated mock type for the VoteProcessorFactory type
func NewVoteProcessorFactory ¶ added in v0.26.1
func NewVoteProcessorFactory(t mockConstructorTestingTNewVoteProcessorFactory) *VoteProcessorFactory
NewVoteProcessorFactory creates a new instance of VoteProcessorFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*VoteProcessorFactory) Create ¶ added in v0.23.9
func (_m *VoteProcessorFactory) Create(log zerolog.Logger, proposal *model.Proposal) (hotstuff.VerifyingVoteProcessor, error)
Create provides a mock function with given fields: log, proposal
type Voter ¶
Voter is an autogenerated mock type for the Voter type
type WeightedSignatureAggregator ¶ added in v0.23.9
WeightedSignatureAggregator is an autogenerated mock type for the WeightedSignatureAggregator type
func NewWeightedSignatureAggregator ¶ added in v0.26.1
func NewWeightedSignatureAggregator(t mockConstructorTestingTNewWeightedSignatureAggregator) *WeightedSignatureAggregator
NewWeightedSignatureAggregator creates a new instance of WeightedSignatureAggregator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*WeightedSignatureAggregator) Aggregate ¶ added in v0.23.9
func (_m *WeightedSignatureAggregator) Aggregate() ([]flow.Identifier, []byte, error)
Aggregate provides a mock function with given fields:
func (*WeightedSignatureAggregator) TotalWeight ¶ added in v0.23.9
func (_m *WeightedSignatureAggregator) TotalWeight() uint64
TotalWeight provides a mock function with given fields:
func (*WeightedSignatureAggregator) TrustedAdd ¶ added in v0.23.9
func (_m *WeightedSignatureAggregator) TrustedAdd(signerID flow.Identifier, sig crypto.Signature) (uint64, error)
TrustedAdd provides a mock function with given fields: signerID, sig
func (*WeightedSignatureAggregator) Verify ¶ added in v0.23.9
func (_m *WeightedSignatureAggregator) Verify(signerID flow.Identifier, sig crypto.Signature) error
Verify provides a mock function with given fields: signerID, sig
type Workerpool ¶ added in v0.23.9
Workerpool is an autogenerated mock type for the Workerpool type
func NewWorkerpool ¶ added in v0.26.1
func NewWorkerpool(t mockConstructorTestingTNewWorkerpool) *Workerpool
NewWorkerpool creates a new instance of Workerpool. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Workerpool) StopWait ¶ added in v0.23.9
func (_m *Workerpool) StopWait()
StopWait provides a mock function with given fields:
func (*Workerpool) Submit ¶ added in v0.23.9
func (_m *Workerpool) Submit(task func())
Submit provides a mock function with given fields: task
type Workers ¶ added in v0.23.9
Workers is an autogenerated mock type for the Workers type
func NewWorkers ¶ added in v0.26.1
func NewWorkers(t mockConstructorTestingTNewWorkers) *Workers
NewWorkers creates a new instance of Workers. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
Source Files ¶
- block_producer.go
- block_signer.go
- block_signer_decoder.go
- committee.go
- communicator.go
- consumer.go
- dkg.go
- event_handler.go
- event_handler_v2.go
- event_loop.go
- finalization_consumer.go
- follower_logic.go
- forks.go
- forks_reader.go
- on_qc_created.go
- pace_maker.go
- packer.go
- persister.go
- qc_created_consumer.go
- random_beacon_inspector.go
- random_beacon_reconstructor.go
- random_beacon_signer.go
- signer.go
- validator.go
- verifier.go
- verifying_vote_processor.go
- vote_aggregator.go
- vote_collector.go
- vote_collector_state.go
- vote_collectors.go
- vote_consumer.go
- vote_processor.go
- vote_processor_factory.go
- voter.go
- weighted_signature_aggregator.go
- workerpool.go
- workers.go