Documentation ¶
Index ¶
- type BlockProducer
- type BlockSignerDecoder
- type CommunicatorConsumer
- type Consumer
- func (_m *Consumer) OnBlockIncorporated(_a0 *model.Block)
- func (_m *Consumer) OnCurrentViewDetails(currentView uint64, finalizedView uint64, currentLeader flow.Identifier)
- func (_m *Consumer) OnDoubleProposeDetected(_a0 *model.Block, _a1 *model.Block)
- func (_m *Consumer) OnEventProcessed()
- func (_m *Consumer) OnFinalizedBlock(_a0 *model.Block)
- func (_m *Consumer) OnInvalidBlockDetected(err flow.Slashable[model.InvalidProposalError])
- func (_m *Consumer) OnLocalTimeout(currentView uint64)
- func (_m *Consumer) OnOwnProposal(proposal *flow.Header, targetPublicationTime time.Time)
- func (_m *Consumer) OnOwnTimeout(timeout *model.TimeoutObject)
- func (_m *Consumer) OnOwnVote(blockID flow.Identifier, view uint64, sigData []byte, ...)
- func (_m *Consumer) OnPartialTc(currentView uint64, partialTc *hotstuff.PartialTcCreated)
- func (_m *Consumer) OnQcTriggeredViewChange(oldView uint64, newView uint64, qc *flow.QuorumCertificate)
- func (_m *Consumer) OnReceiveProposal(currentView uint64, proposal *model.Proposal)
- func (_m *Consumer) OnReceiveQc(currentView uint64, qc *flow.QuorumCertificate)
- func (_m *Consumer) OnReceiveTc(currentView uint64, tc *flow.TimeoutCertificate)
- func (_m *Consumer) OnStart(currentView uint64)
- func (_m *Consumer) OnStartingTimeout(_a0 model.TimerInfo)
- func (_m *Consumer) OnTcTriggeredViewChange(oldView uint64, newView uint64, tc *flow.TimeoutCertificate)
- func (_m *Consumer) OnViewChange(oldView uint64, newView uint64)
- type DKG
- type DynamicCommittee
- func (_m *DynamicCommittee) DKG(view uint64) (hotstuff.DKG, error)
- func (_m *DynamicCommittee) IdentitiesByBlock(blockID flow.Identifier) (flow.IdentityList, error)
- func (_m *DynamicCommittee) IdentitiesByEpoch(view uint64) (flow.IdentityList, error)
- func (_m *DynamicCommittee) IdentityByBlock(blockID flow.Identifier, participantID flow.Identifier) (*flow.Identity, error)
- func (_m *DynamicCommittee) IdentityByEpoch(view uint64, participantID flow.Identifier) (*flow.Identity, error)
- func (_m *DynamicCommittee) LeaderForView(view uint64) (flow.Identifier, error)
- func (_m *DynamicCommittee) QuorumThresholdForView(view uint64) (uint64, error)
- func (_m *DynamicCommittee) Self() flow.Identifier
- func (_m *DynamicCommittee) TimeoutThresholdForView(view uint64) (uint64, error)
- type EventHandler
- func (_m *EventHandler) OnLocalTimeout() error
- func (_m *EventHandler) OnPartialTcCreated(partialTC *hotstuff.PartialTcCreated) error
- func (_m *EventHandler) OnReceiveProposal(proposal *model.Proposal) error
- func (_m *EventHandler) OnReceiveQc(qc *flow.QuorumCertificate) error
- func (_m *EventHandler) OnReceiveTc(tc *flow.TimeoutCertificate) error
- func (_m *EventHandler) Start(ctx context.Context) error
- func (_m *EventHandler) TimeoutChannel() <-chan time.Time
- type EventLoop
- func (_m *EventLoop) Done() <-chan struct{}
- func (_m *EventLoop) OnNewQcDiscovered(certificate *flow.QuorumCertificate)
- func (_m *EventLoop) OnNewTcDiscovered(certificate *flow.TimeoutCertificate)
- func (_m *EventLoop) OnPartialTcCreated(view uint64, newestQC *flow.QuorumCertificate, ...)
- func (_m *EventLoop) OnQcConstructedFromVotes(_a0 *flow.QuorumCertificate)
- func (_m *EventLoop) OnTcConstructedFromTimeouts(certificate *flow.TimeoutCertificate)
- func (_m *EventLoop) OnTimeoutProcessed(timeout *model.TimeoutObject)
- func (_m *EventLoop) OnVoteProcessed(vote *model.Vote)
- func (_m *EventLoop) Ready() <-chan struct{}
- func (_m *EventLoop) Start(_a0 irrecoverable.SignalerContext)
- func (_m *EventLoop) SubmitProposal(proposal *model.Proposal)
- type FinalizationConsumer
- type FollowerConsumer
- func (_m *FollowerConsumer) OnBlockIncorporated(_a0 *model.Block)
- func (_m *FollowerConsumer) OnDoubleProposeDetected(_a0 *model.Block, _a1 *model.Block)
- func (_m *FollowerConsumer) OnFinalizedBlock(_a0 *model.Block)
- func (_m *FollowerConsumer) OnInvalidBlockDetected(err flow.Slashable[model.InvalidProposalError])
- type Forks
- func (_m *Forks) AddCertifiedBlock(certifiedBlock *model.CertifiedBlock) error
- func (_m *Forks) AddValidatedBlock(proposal *model.Block) error
- func (_m *Forks) FinalityProof() (*hotstuff.FinalityProof, bool)
- func (_m *Forks) FinalizedBlock() *model.Block
- func (_m *Forks) FinalizedView() uint64
- func (_m *Forks) GetBlock(blockID flow.Identifier) (*model.Block, bool)
- func (_m *Forks) GetBlocksForView(view uint64) []*model.Block
- type OnQCCreated
- type PaceMaker
- func (_m *PaceMaker) CurView() uint64
- func (_m *PaceMaker) LastViewTC() *flow.TimeoutCertificate
- func (_m *PaceMaker) NewestQC() *flow.QuorumCertificate
- func (_m *PaceMaker) ProcessQC(qc *flow.QuorumCertificate) (*model.NewViewEvent, error)
- func (_m *PaceMaker) ProcessTC(tc *flow.TimeoutCertificate) (*model.NewViewEvent, error)
- func (_m *PaceMaker) Start(ctx context.Context)
- func (_m *PaceMaker) TargetPublicationTime(proposalView uint64, timeViewEntered time.Time, parentBlockId flow.Identifier) time.Time
- func (_m *PaceMaker) TimeoutChannel() <-chan time.Time
- type Packer
- type ParticipantConsumer
- func (_m *ParticipantConsumer) OnCurrentViewDetails(currentView uint64, finalizedView uint64, currentLeader flow.Identifier)
- func (_m *ParticipantConsumer) OnEventProcessed()
- func (_m *ParticipantConsumer) OnLocalTimeout(currentView uint64)
- func (_m *ParticipantConsumer) OnPartialTc(currentView uint64, partialTc *hotstuff.PartialTcCreated)
- func (_m *ParticipantConsumer) OnQcTriggeredViewChange(oldView uint64, newView uint64, qc *flow.QuorumCertificate)
- func (_m *ParticipantConsumer) OnReceiveProposal(currentView uint64, proposal *model.Proposal)
- func (_m *ParticipantConsumer) OnReceiveQc(currentView uint64, qc *flow.QuorumCertificate)
- func (_m *ParticipantConsumer) OnReceiveTc(currentView uint64, tc *flow.TimeoutCertificate)
- func (_m *ParticipantConsumer) OnStart(currentView uint64)
- func (_m *ParticipantConsumer) OnStartingTimeout(_a0 model.TimerInfo)
- func (_m *ParticipantConsumer) OnTcTriggeredViewChange(oldView uint64, newView uint64, tc *flow.TimeoutCertificate)
- func (_m *ParticipantConsumer) OnViewChange(oldView uint64, newView uint64)
- type Persister
- type ProposalDurationProvider
- type ProposalViolationConsumer
- 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 Replicas
- func (_m *Replicas) DKG(view uint64) (hotstuff.DKG, error)
- func (_m *Replicas) IdentitiesByEpoch(view uint64) (flow.IdentityList, error)
- func (_m *Replicas) IdentityByEpoch(view uint64, participantID flow.Identifier) (*flow.Identity, error)
- func (_m *Replicas) LeaderForView(view uint64) (flow.Identifier, error)
- func (_m *Replicas) QuorumThresholdForView(view uint64) (uint64, error)
- func (_m *Replicas) Self() flow.Identifier
- func (_m *Replicas) TimeoutThresholdForView(view uint64) (uint64, error)
- type SafetyRules
- type Signer
- type TimeoutAggregationConsumer
- func (_m *TimeoutAggregationConsumer) OnDoubleTimeoutDetected(_a0 *model.TimeoutObject, _a1 *model.TimeoutObject)
- func (_m *TimeoutAggregationConsumer) OnInvalidTimeoutDetected(err model.InvalidTimeoutError)
- func (_m *TimeoutAggregationConsumer) OnNewQcDiscovered(certificate *flow.QuorumCertificate)
- func (_m *TimeoutAggregationConsumer) OnNewTcDiscovered(certificate *flow.TimeoutCertificate)
- func (_m *TimeoutAggregationConsumer) OnPartialTcCreated(view uint64, newestQC *flow.QuorumCertificate, ...)
- func (_m *TimeoutAggregationConsumer) OnTcConstructedFromTimeouts(certificate *flow.TimeoutCertificate)
- func (_m *TimeoutAggregationConsumer) OnTimeoutProcessed(timeout *model.TimeoutObject)
- type TimeoutAggregationViolationConsumer
- type TimeoutAggregator
- func (_m *TimeoutAggregator) AddTimeout(timeoutObject *model.TimeoutObject)
- func (_m *TimeoutAggregator) Done() <-chan struct{}
- func (_m *TimeoutAggregator) PruneUpToView(lowestRetainedView uint64)
- func (_m *TimeoutAggregator) Ready() <-chan struct{}
- func (_m *TimeoutAggregator) Start(_a0 irrecoverable.SignalerContext)
- type TimeoutCollector
- type TimeoutCollectorConsumer
- func (_m *TimeoutCollectorConsumer) OnNewQcDiscovered(certificate *flow.QuorumCertificate)
- func (_m *TimeoutCollectorConsumer) OnNewTcDiscovered(certificate *flow.TimeoutCertificate)
- func (_m *TimeoutCollectorConsumer) OnPartialTcCreated(view uint64, newestQC *flow.QuorumCertificate, ...)
- func (_m *TimeoutCollectorConsumer) OnTcConstructedFromTimeouts(certificate *flow.TimeoutCertificate)
- func (_m *TimeoutCollectorConsumer) OnTimeoutProcessed(timeout *model.TimeoutObject)
- type TimeoutCollectorFactory
- type TimeoutCollectors
- type TimeoutProcessor
- type TimeoutProcessorFactory
- type TimeoutSignatureAggregator
- func (_m *TimeoutSignatureAggregator) Aggregate() ([]hotstuff.TimeoutSignerInfo, crypto.Signature, error)
- func (_m *TimeoutSignatureAggregator) TotalWeight() uint64
- func (_m *TimeoutSignatureAggregator) VerifyAndAdd(signerID flow.Identifier, sig crypto.Signature, newestQCView uint64) (uint64, error)
- func (_m *TimeoutSignatureAggregator) View() uint64
- type Validator
- type Verifier
- func (_m *Verifier) VerifyQC(signers flow.IdentityList, sigData []byte, view uint64, ...) error
- func (_m *Verifier) VerifyTC(signers flow.IdentityList, sigData []byte, view uint64, highQCViews []uint64) error
- func (_m *Verifier) VerifyVote(voter *flow.Identity, sigData []byte, view uint64, blockID flow.Identifier) error
- type VerifyingVoteProcessor
- type VoteAggregationConsumer
- func (_m *VoteAggregationConsumer) OnDoubleVotingDetected(_a0 *model.Vote, _a1 *model.Vote)
- func (_m *VoteAggregationConsumer) OnInvalidVoteDetected(err model.InvalidVoteError)
- func (_m *VoteAggregationConsumer) OnQcConstructedFromVotes(_a0 *flow.QuorumCertificate)
- func (_m *VoteAggregationConsumer) OnVoteForInvalidBlockDetected(vote *model.Vote, invalidProposal *model.Proposal)
- func (_m *VoteAggregationConsumer) OnVoteProcessed(vote *model.Vote)
- type VoteAggregationViolationConsumer
- func (_m *VoteAggregationViolationConsumer) OnDoubleVotingDetected(_a0 *model.Vote, _a1 *model.Vote)
- func (_m *VoteAggregationViolationConsumer) OnInvalidVoteDetected(err model.InvalidVoteError)
- func (_m *VoteAggregationViolationConsumer) OnVoteForInvalidBlockDetected(vote *model.Vote, invalidProposal *model.Proposal)
- type VoteAggregator
- func (_m *VoteAggregator) AddBlock(block *model.Proposal)
- 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 VoteCollectorConsumer
- 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 WeightedSignatureAggregator
- func (_m *WeightedSignatureAggregator) Aggregate() (flow.IdentifierList, []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(view uint64, qc *flow.QuorumCertificate, lastViewTC *flow.TimeoutCertificate) (*flow.Header, error)
MakeBlockProposal provides a mock function with given fields: view, qc, lastViewTC
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 CommunicatorConsumer ¶ added in v0.29.0
CommunicatorConsumer is an autogenerated mock type for the CommunicatorConsumer type
func NewCommunicatorConsumer ¶ added in v0.29.0
func NewCommunicatorConsumer(t mockConstructorTestingTNewCommunicatorConsumer) *CommunicatorConsumer
NewCommunicatorConsumer creates a new instance of CommunicatorConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*CommunicatorConsumer) OnOwnProposal ¶ added in v0.29.0
func (_m *CommunicatorConsumer) OnOwnProposal(proposal *flow.Header, targetPublicationTime time.Time)
OnOwnProposal provides a mock function with given fields: proposal, targetPublicationTime
func (*CommunicatorConsumer) OnOwnTimeout ¶ added in v0.29.0
func (_m *CommunicatorConsumer) OnOwnTimeout(timeout *model.TimeoutObject)
OnOwnTimeout provides a mock function with given fields: timeout
func (*CommunicatorConsumer) OnOwnVote ¶ added in v0.29.0
func (_m *CommunicatorConsumer) OnOwnVote(blockID flow.Identifier, view uint64, sigData []byte, recipientID flow.Identifier)
OnOwnVote 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) OnCurrentViewDetails ¶ added in v0.29.6
func (_m *Consumer) OnCurrentViewDetails(currentView uint64, finalizedView uint64, currentLeader flow.Identifier)
OnCurrentViewDetails provides a mock function with given fields: currentView, finalizedView, currentLeader
func (*Consumer) OnDoubleProposeDetected ¶
OnDoubleProposeDetected provides a mock function with given fields: _a0, _a1
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) OnInvalidBlockDetected ¶ added in v0.31.0
func (_m *Consumer) OnInvalidBlockDetected(err flow.Slashable[model.InvalidProposalError])
OnInvalidBlockDetected provides a mock function with given fields: err
func (*Consumer) OnLocalTimeout ¶ added in v0.29.0
OnLocalTimeout provides a mock function with given fields: currentView
func (*Consumer) OnOwnProposal ¶ added in v0.29.0
OnOwnProposal provides a mock function with given fields: proposal, targetPublicationTime
func (*Consumer) OnOwnTimeout ¶ added in v0.29.0
func (_m *Consumer) OnOwnTimeout(timeout *model.TimeoutObject)
OnOwnTimeout provides a mock function with given fields: timeout
func (*Consumer) OnOwnVote ¶ added in v0.29.0
func (_m *Consumer) OnOwnVote(blockID flow.Identifier, view uint64, sigData []byte, recipientID flow.Identifier)
OnOwnVote provides a mock function with given fields: blockID, view, sigData, recipientID
func (*Consumer) OnPartialTc ¶ added in v0.29.0
func (_m *Consumer) OnPartialTc(currentView uint64, partialTc *hotstuff.PartialTcCreated)
OnPartialTc provides a mock function with given fields: currentView, partialTc
func (*Consumer) OnQcTriggeredViewChange ¶
func (_m *Consumer) OnQcTriggeredViewChange(oldView uint64, newView uint64, qc *flow.QuorumCertificate)
OnQcTriggeredViewChange provides a mock function with given fields: oldView, newView, qc
func (*Consumer) OnReceiveProposal ¶
OnReceiveProposal provides a mock function with given fields: currentView, proposal
func (*Consumer) OnReceiveQc ¶ added in v0.29.0
func (_m *Consumer) OnReceiveQc(currentView uint64, qc *flow.QuorumCertificate)
OnReceiveQc provides a mock function with given fields: currentView, qc
func (*Consumer) OnReceiveTc ¶ added in v0.29.0
func (_m *Consumer) OnReceiveTc(currentView uint64, tc *flow.TimeoutCertificate)
OnReceiveTc provides a mock function with given fields: currentView, tc
func (*Consumer) OnStart ¶ added in v0.29.0
OnStart provides a mock function with given fields: currentView
func (*Consumer) OnStartingTimeout ¶
OnStartingTimeout provides a mock function with given fields: _a0
func (*Consumer) OnTcTriggeredViewChange ¶ added in v0.29.0
func (_m *Consumer) OnTcTriggeredViewChange(oldView uint64, newView uint64, tc *flow.TimeoutCertificate)
OnTcTriggeredViewChange provides a mock function with given fields: oldView, newView, tc
func (*Consumer) OnViewChange ¶ added in v0.29.0
OnViewChange provides a mock function with given fields: oldView, newView
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 DynamicCommittee ¶ added in v0.29.0
DynamicCommittee is an autogenerated mock type for the DynamicCommittee type
func NewDynamicCommittee ¶ added in v0.29.0
func NewDynamicCommittee(t mockConstructorTestingTNewDynamicCommittee) *DynamicCommittee
NewDynamicCommittee creates a new instance of DynamicCommittee. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*DynamicCommittee) DKG ¶ added in v0.29.0
func (_m *DynamicCommittee) DKG(view uint64) (hotstuff.DKG, error)
DKG provides a mock function with given fields: view
func (*DynamicCommittee) IdentitiesByBlock ¶ added in v0.29.0
func (_m *DynamicCommittee) IdentitiesByBlock(blockID flow.Identifier) (flow.IdentityList, error)
IdentitiesByBlock provides a mock function with given fields: blockID
func (*DynamicCommittee) IdentitiesByEpoch ¶ added in v0.29.0
func (_m *DynamicCommittee) IdentitiesByEpoch(view uint64) (flow.IdentityList, error)
IdentitiesByEpoch provides a mock function with given fields: view
func (*DynamicCommittee) IdentityByBlock ¶ added in v0.29.0
func (_m *DynamicCommittee) IdentityByBlock(blockID flow.Identifier, participantID flow.Identifier) (*flow.Identity, error)
IdentityByBlock provides a mock function with given fields: blockID, participantID
func (*DynamicCommittee) IdentityByEpoch ¶ added in v0.29.0
func (_m *DynamicCommittee) IdentityByEpoch(view uint64, participantID flow.Identifier) (*flow.Identity, error)
IdentityByEpoch provides a mock function with given fields: view, participantID
func (*DynamicCommittee) LeaderForView ¶ added in v0.29.0
func (_m *DynamicCommittee) LeaderForView(view uint64) (flow.Identifier, error)
LeaderForView provides a mock function with given fields: view
func (*DynamicCommittee) QuorumThresholdForView ¶ added in v0.29.0
func (_m *DynamicCommittee) QuorumThresholdForView(view uint64) (uint64, error)
QuorumThresholdForView provides a mock function with given fields: view
func (*DynamicCommittee) Self ¶ added in v0.29.0
func (_m *DynamicCommittee) Self() flow.Identifier
Self provides a mock function with given fields:
func (*DynamicCommittee) TimeoutThresholdForView ¶ added in v0.29.0
func (_m *DynamicCommittee) TimeoutThresholdForView(view uint64) (uint64, error)
TimeoutThresholdForView provides a mock function with given fields: view
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) OnPartialTcCreated ¶ added in v0.29.0
func (_m *EventHandler) OnPartialTcCreated(partialTC *hotstuff.PartialTcCreated) error
OnPartialTcCreated provides a mock function with given fields: partialTC
func (*EventHandler) OnReceiveProposal ¶
func (_m *EventHandler) OnReceiveProposal(proposal *model.Proposal) error
OnReceiveProposal provides a mock function with given fields: proposal
func (*EventHandler) OnReceiveQc ¶ added in v0.29.0
func (_m *EventHandler) OnReceiveQc(qc *flow.QuorumCertificate) error
OnReceiveQc provides a mock function with given fields: qc
func (*EventHandler) OnReceiveTc ¶ added in v0.29.0
func (_m *EventHandler) OnReceiveTc(tc *flow.TimeoutCertificate) error
OnReceiveTc provides a mock function with given fields: tc
func (*EventHandler) Start ¶
func (_m *EventHandler) Start(ctx context.Context) error
Start provides a mock function with given fields: ctx
func (*EventHandler) TimeoutChannel ¶
func (_m *EventHandler) 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) OnNewQcDiscovered ¶ added in v0.29.0
func (_m *EventLoop) OnNewQcDiscovered(certificate *flow.QuorumCertificate)
OnNewQcDiscovered provides a mock function with given fields: certificate
func (*EventLoop) OnNewTcDiscovered ¶ added in v0.29.0
func (_m *EventLoop) OnNewTcDiscovered(certificate *flow.TimeoutCertificate)
OnNewTcDiscovered provides a mock function with given fields: certificate
func (*EventLoop) OnPartialTcCreated ¶ added in v0.29.0
func (_m *EventLoop) OnPartialTcCreated(view uint64, newestQC *flow.QuorumCertificate, lastViewTC *flow.TimeoutCertificate)
OnPartialTcCreated provides a mock function with given fields: view, newestQC, lastViewTC
func (*EventLoop) OnQcConstructedFromVotes ¶ added in v0.29.0
func (_m *EventLoop) OnQcConstructedFromVotes(_a0 *flow.QuorumCertificate)
OnQcConstructedFromVotes provides a mock function with given fields: _a0
func (*EventLoop) OnTcConstructedFromTimeouts ¶ added in v0.29.0
func (_m *EventLoop) OnTcConstructedFromTimeouts(certificate *flow.TimeoutCertificate)
OnTcConstructedFromTimeouts provides a mock function with given fields: certificate
func (*EventLoop) OnTimeoutProcessed ¶ added in v0.31.0
func (_m *EventLoop) OnTimeoutProcessed(timeout *model.TimeoutObject)
OnTimeoutProcessed provides a mock function with given fields: timeout
func (*EventLoop) OnVoteProcessed ¶ added in v0.31.0
OnVoteProcessed provides a mock function with given fields: vote
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
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) OnFinalizedBlock ¶
func (_m *FinalizationConsumer) OnFinalizedBlock(_a0 *model.Block)
OnFinalizedBlock provides a mock function with given fields: _a0
type FollowerConsumer ¶ added in v0.31.0
FollowerConsumer is an autogenerated mock type for the FollowerConsumer type
func NewFollowerConsumer ¶ added in v0.31.0
func NewFollowerConsumer(t mockConstructorTestingTNewFollowerConsumer) *FollowerConsumer
NewFollowerConsumer creates a new instance of FollowerConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*FollowerConsumer) OnBlockIncorporated ¶ added in v0.31.0
func (_m *FollowerConsumer) OnBlockIncorporated(_a0 *model.Block)
OnBlockIncorporated provides a mock function with given fields: _a0
func (*FollowerConsumer) OnDoubleProposeDetected ¶ added in v0.31.0
func (_m *FollowerConsumer) OnDoubleProposeDetected(_a0 *model.Block, _a1 *model.Block)
OnDoubleProposeDetected provides a mock function with given fields: _a0, _a1
func (*FollowerConsumer) OnFinalizedBlock ¶ added in v0.31.0
func (_m *FollowerConsumer) OnFinalizedBlock(_a0 *model.Block)
OnFinalizedBlock provides a mock function with given fields: _a0
func (*FollowerConsumer) OnInvalidBlockDetected ¶ added in v0.31.0
func (_m *FollowerConsumer) OnInvalidBlockDetected(err flow.Slashable[model.InvalidProposalError])
OnInvalidBlockDetected provides a mock function with given fields: err
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) AddCertifiedBlock ¶ added in v0.31.0
func (_m *Forks) AddCertifiedBlock(certifiedBlock *model.CertifiedBlock) error
AddCertifiedBlock provides a mock function with given fields: certifiedBlock
func (*Forks) AddValidatedBlock ¶ added in v0.31.0
AddValidatedBlock provides a mock function with given fields: proposal
func (*Forks) FinalityProof ¶ added in v0.31.0
func (_m *Forks) FinalityProof() (*hotstuff.FinalityProof, bool)
FinalityProof provides a mock function with given fields:
func (*Forks) FinalizedBlock ¶
FinalizedBlock provides a mock function with given fields:
func (*Forks) FinalizedView ¶
FinalizedView provides a mock function with given fields:
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) LastViewTC ¶ added in v0.29.0
func (_m *PaceMaker) LastViewTC() *flow.TimeoutCertificate
LastViewTC provides a mock function with given fields:
func (*PaceMaker) NewestQC ¶ added in v0.29.0
func (_m *PaceMaker) NewestQC() *flow.QuorumCertificate
NewestQC provides a mock function with given fields:
func (*PaceMaker) ProcessQC ¶ added in v0.29.0
func (_m *PaceMaker) ProcessQC(qc *flow.QuorumCertificate) (*model.NewViewEvent, error)
ProcessQC provides a mock function with given fields: qc
func (*PaceMaker) ProcessTC ¶ added in v0.29.0
func (_m *PaceMaker) ProcessTC(tc *flow.TimeoutCertificate) (*model.NewViewEvent, error)
ProcessTC provides a mock function with given fields: tc
func (*PaceMaker) TargetPublicationTime ¶ added in v0.31.0
func (_m *PaceMaker) TargetPublicationTime(proposalView uint64, timeViewEntered time.Time, parentBlockId flow.Identifier) time.Time
TargetPublicationTime provides a mock function with given fields: proposalView, timeViewEntered, parentBlockId
func (*PaceMaker) TimeoutChannel ¶
TimeoutChannel provides a mock function with given fields:
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) 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 ParticipantConsumer ¶ added in v0.31.0
ParticipantConsumer is an autogenerated mock type for the ParticipantConsumer type
func NewParticipantConsumer ¶ added in v0.31.0
func NewParticipantConsumer(t mockConstructorTestingTNewParticipantConsumer) *ParticipantConsumer
NewParticipantConsumer creates a new instance of ParticipantConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ParticipantConsumer) OnCurrentViewDetails ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnCurrentViewDetails(currentView uint64, finalizedView uint64, currentLeader flow.Identifier)
OnCurrentViewDetails provides a mock function with given fields: currentView, finalizedView, currentLeader
func (*ParticipantConsumer) OnEventProcessed ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnEventProcessed()
OnEventProcessed provides a mock function with given fields:
func (*ParticipantConsumer) OnLocalTimeout ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnLocalTimeout(currentView uint64)
OnLocalTimeout provides a mock function with given fields: currentView
func (*ParticipantConsumer) OnPartialTc ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnPartialTc(currentView uint64, partialTc *hotstuff.PartialTcCreated)
OnPartialTc provides a mock function with given fields: currentView, partialTc
func (*ParticipantConsumer) OnQcTriggeredViewChange ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnQcTriggeredViewChange(oldView uint64, newView uint64, qc *flow.QuorumCertificate)
OnQcTriggeredViewChange provides a mock function with given fields: oldView, newView, qc
func (*ParticipantConsumer) OnReceiveProposal ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnReceiveProposal(currentView uint64, proposal *model.Proposal)
OnReceiveProposal provides a mock function with given fields: currentView, proposal
func (*ParticipantConsumer) OnReceiveQc ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnReceiveQc(currentView uint64, qc *flow.QuorumCertificate)
OnReceiveQc provides a mock function with given fields: currentView, qc
func (*ParticipantConsumer) OnReceiveTc ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnReceiveTc(currentView uint64, tc *flow.TimeoutCertificate)
OnReceiveTc provides a mock function with given fields: currentView, tc
func (*ParticipantConsumer) OnStart ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnStart(currentView uint64)
OnStart provides a mock function with given fields: currentView
func (*ParticipantConsumer) OnStartingTimeout ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnStartingTimeout(_a0 model.TimerInfo)
OnStartingTimeout provides a mock function with given fields: _a0
func (*ParticipantConsumer) OnTcTriggeredViewChange ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnTcTriggeredViewChange(oldView uint64, newView uint64, tc *flow.TimeoutCertificate)
OnTcTriggeredViewChange provides a mock function with given fields: oldView, newView, tc
func (*ParticipantConsumer) OnViewChange ¶ added in v0.31.0
func (_m *ParticipantConsumer) OnViewChange(oldView uint64, newView uint64)
OnViewChange provides a mock function with given fields: oldView, newView
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) GetLivenessData ¶ added in v0.29.0
func (_m *Persister) GetLivenessData() (*hotstuff.LivenessData, error)
GetLivenessData provides a mock function with given fields:
func (*Persister) GetSafetyData ¶ added in v0.29.0
func (_m *Persister) GetSafetyData() (*hotstuff.SafetyData, error)
GetSafetyData provides a mock function with given fields:
func (*Persister) PutLivenessData ¶ added in v0.29.0
func (_m *Persister) PutLivenessData(livenessData *hotstuff.LivenessData) error
PutLivenessData provides a mock function with given fields: livenessData
func (*Persister) PutSafetyData ¶ added in v0.29.0
func (_m *Persister) PutSafetyData(safetyData *hotstuff.SafetyData) error
PutSafetyData provides a mock function with given fields: safetyData
type ProposalDurationProvider ¶ added in v0.31.0
ProposalDurationProvider is an autogenerated mock type for the ProposalDurationProvider type
func NewProposalDurationProvider ¶ added in v0.31.0
func NewProposalDurationProvider(t mockConstructorTestingTNewProposalDurationProvider) *ProposalDurationProvider
NewProposalDurationProvider creates a new instance of ProposalDurationProvider. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ProposalDurationProvider) TargetPublicationTime ¶ added in v0.31.0
func (_m *ProposalDurationProvider) TargetPublicationTime(proposalView uint64, timeViewEntered time.Time, parentBlockId flow.Identifier) time.Time
TargetPublicationTime provides a mock function with given fields: proposalView, timeViewEntered, parentBlockId
type ProposalViolationConsumer ¶ added in v0.31.0
ProposalViolationConsumer is an autogenerated mock type for the ProposalViolationConsumer type
func NewProposalViolationConsumer ¶ added in v0.31.0
func NewProposalViolationConsumer(t mockConstructorTestingTNewProposalViolationConsumer) *ProposalViolationConsumer
NewProposalViolationConsumer creates a new instance of ProposalViolationConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ProposalViolationConsumer) OnDoubleProposeDetected ¶ added in v0.31.0
func (_m *ProposalViolationConsumer) OnDoubleProposeDetected(_a0 *model.Block, _a1 *model.Block)
OnDoubleProposeDetected provides a mock function with given fields: _a0, _a1
func (*ProposalViolationConsumer) OnInvalidBlockDetected ¶ added in v0.31.0
func (_m *ProposalViolationConsumer) OnInvalidBlockDetected(err flow.Slashable[model.InvalidProposalError])
OnInvalidBlockDetected provides a mock function with given fields: err
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 Replicas ¶ added in v0.29.0
Replicas is an autogenerated mock type for the Replicas type
func NewReplicas ¶ added in v0.29.0
func NewReplicas(t mockConstructorTestingTNewReplicas) *Replicas
NewReplicas creates a new instance of Replicas. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Replicas) IdentitiesByEpoch ¶ added in v0.29.0
func (_m *Replicas) IdentitiesByEpoch(view uint64) (flow.IdentityList, error)
IdentitiesByEpoch provides a mock function with given fields: view
func (*Replicas) IdentityByEpoch ¶ added in v0.29.0
func (_m *Replicas) IdentityByEpoch(view uint64, participantID flow.Identifier) (*flow.Identity, error)
IdentityByEpoch provides a mock function with given fields: view, participantID
func (*Replicas) LeaderForView ¶ added in v0.29.0
func (_m *Replicas) LeaderForView(view uint64) (flow.Identifier, error)
LeaderForView provides a mock function with given fields: view
func (*Replicas) QuorumThresholdForView ¶ added in v0.29.0
QuorumThresholdForView provides a mock function with given fields: view
func (*Replicas) Self ¶ added in v0.29.0
func (_m *Replicas) Self() flow.Identifier
Self provides a mock function with given fields:
type SafetyRules ¶ added in v0.29.0
SafetyRules is an autogenerated mock type for the SafetyRules type
func NewSafetyRules ¶ added in v0.29.0
func NewSafetyRules(t mockConstructorTestingTNewSafetyRules) *SafetyRules
NewSafetyRules creates a new instance of SafetyRules. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*SafetyRules) ProduceTimeout ¶ added in v0.29.0
func (_m *SafetyRules) ProduceTimeout(curView uint64, newestQC *flow.QuorumCertificate, lastViewTC *flow.TimeoutCertificate) (*model.TimeoutObject, error)
ProduceTimeout provides a mock function with given fields: curView, newestQC, lastViewTC
func (*SafetyRules) ProduceVote ¶ added in v0.29.0
ProduceVote provides a mock function with given fields: proposal, curView
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
func (*Signer) CreateTimeout ¶ added in v0.29.0
func (_m *Signer) CreateTimeout(curView uint64, newestQC *flow.QuorumCertificate, lastViewTC *flow.TimeoutCertificate) (*model.TimeoutObject, error)
CreateTimeout provides a mock function with given fields: curView, newestQC, lastViewTC
type TimeoutAggregationConsumer ¶ added in v0.31.0
TimeoutAggregationConsumer is an autogenerated mock type for the TimeoutAggregationConsumer type
func NewTimeoutAggregationConsumer ¶ added in v0.31.0
func NewTimeoutAggregationConsumer(t mockConstructorTestingTNewTimeoutAggregationConsumer) *TimeoutAggregationConsumer
NewTimeoutAggregationConsumer creates a new instance of TimeoutAggregationConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TimeoutAggregationConsumer) OnDoubleTimeoutDetected ¶ added in v0.31.0
func (_m *TimeoutAggregationConsumer) OnDoubleTimeoutDetected(_a0 *model.TimeoutObject, _a1 *model.TimeoutObject)
OnDoubleTimeoutDetected provides a mock function with given fields: _a0, _a1
func (*TimeoutAggregationConsumer) OnInvalidTimeoutDetected ¶ added in v0.31.0
func (_m *TimeoutAggregationConsumer) OnInvalidTimeoutDetected(err model.InvalidTimeoutError)
OnInvalidTimeoutDetected provides a mock function with given fields: err
func (*TimeoutAggregationConsumer) OnNewQcDiscovered ¶ added in v0.31.0
func (_m *TimeoutAggregationConsumer) OnNewQcDiscovered(certificate *flow.QuorumCertificate)
OnNewQcDiscovered provides a mock function with given fields: certificate
func (*TimeoutAggregationConsumer) OnNewTcDiscovered ¶ added in v0.31.0
func (_m *TimeoutAggregationConsumer) OnNewTcDiscovered(certificate *flow.TimeoutCertificate)
OnNewTcDiscovered provides a mock function with given fields: certificate
func (*TimeoutAggregationConsumer) OnPartialTcCreated ¶ added in v0.31.0
func (_m *TimeoutAggregationConsumer) OnPartialTcCreated(view uint64, newestQC *flow.QuorumCertificate, lastViewTC *flow.TimeoutCertificate)
OnPartialTcCreated provides a mock function with given fields: view, newestQC, lastViewTC
func (*TimeoutAggregationConsumer) OnTcConstructedFromTimeouts ¶ added in v0.31.0
func (_m *TimeoutAggregationConsumer) OnTcConstructedFromTimeouts(certificate *flow.TimeoutCertificate)
OnTcConstructedFromTimeouts provides a mock function with given fields: certificate
func (*TimeoutAggregationConsumer) OnTimeoutProcessed ¶ added in v0.31.0
func (_m *TimeoutAggregationConsumer) OnTimeoutProcessed(timeout *model.TimeoutObject)
OnTimeoutProcessed provides a mock function with given fields: timeout
type TimeoutAggregationViolationConsumer ¶ added in v0.31.0
TimeoutAggregationViolationConsumer is an autogenerated mock type for the TimeoutAggregationViolationConsumer type
func NewTimeoutAggregationViolationConsumer ¶ added in v0.31.0
func NewTimeoutAggregationViolationConsumer(t mockConstructorTestingTNewTimeoutAggregationViolationConsumer) *TimeoutAggregationViolationConsumer
NewTimeoutAggregationViolationConsumer creates a new instance of TimeoutAggregationViolationConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TimeoutAggregationViolationConsumer) OnDoubleTimeoutDetected ¶ added in v0.31.0
func (_m *TimeoutAggregationViolationConsumer) OnDoubleTimeoutDetected(_a0 *model.TimeoutObject, _a1 *model.TimeoutObject)
OnDoubleTimeoutDetected provides a mock function with given fields: _a0, _a1
func (*TimeoutAggregationViolationConsumer) OnInvalidTimeoutDetected ¶ added in v0.31.0
func (_m *TimeoutAggregationViolationConsumer) OnInvalidTimeoutDetected(err model.InvalidTimeoutError)
OnInvalidTimeoutDetected provides a mock function with given fields: err
type TimeoutAggregator ¶ added in v0.29.0
TimeoutAggregator is an autogenerated mock type for the TimeoutAggregator type
func NewTimeoutAggregator ¶ added in v0.29.0
func NewTimeoutAggregator(t mockConstructorTestingTNewTimeoutAggregator) *TimeoutAggregator
NewTimeoutAggregator creates a new instance of TimeoutAggregator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TimeoutAggregator) AddTimeout ¶ added in v0.29.0
func (_m *TimeoutAggregator) AddTimeout(timeoutObject *model.TimeoutObject)
AddTimeout provides a mock function with given fields: timeoutObject
func (*TimeoutAggregator) Done ¶ added in v0.29.0
func (_m *TimeoutAggregator) Done() <-chan struct{}
Done provides a mock function with given fields:
func (*TimeoutAggregator) PruneUpToView ¶ added in v0.29.0
func (_m *TimeoutAggregator) PruneUpToView(lowestRetainedView uint64)
PruneUpToView provides a mock function with given fields: lowestRetainedView
func (*TimeoutAggregator) Ready ¶ added in v0.29.0
func (_m *TimeoutAggregator) Ready() <-chan struct{}
Ready provides a mock function with given fields:
func (*TimeoutAggregator) Start ¶ added in v0.29.0
func (_m *TimeoutAggregator) Start(_a0 irrecoverable.SignalerContext)
Start provides a mock function with given fields: _a0
type TimeoutCollector ¶ added in v0.29.0
TimeoutCollector is an autogenerated mock type for the TimeoutCollector type
func NewTimeoutCollector ¶ added in v0.29.0
func NewTimeoutCollector(t mockConstructorTestingTNewTimeoutCollector) *TimeoutCollector
NewTimeoutCollector creates a new instance of TimeoutCollector. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TimeoutCollector) AddTimeout ¶ added in v0.29.0
func (_m *TimeoutCollector) AddTimeout(timeoutObject *model.TimeoutObject) error
AddTimeout provides a mock function with given fields: timeoutObject
func (*TimeoutCollector) View ¶ added in v0.29.0
func (_m *TimeoutCollector) View() uint64
View provides a mock function with given fields:
type TimeoutCollectorConsumer ¶ added in v0.29.0
TimeoutCollectorConsumer is an autogenerated mock type for the TimeoutCollectorConsumer type
func NewTimeoutCollectorConsumer ¶ added in v0.29.0
func NewTimeoutCollectorConsumer(t mockConstructorTestingTNewTimeoutCollectorConsumer) *TimeoutCollectorConsumer
NewTimeoutCollectorConsumer creates a new instance of TimeoutCollectorConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TimeoutCollectorConsumer) OnNewQcDiscovered ¶ added in v0.29.0
func (_m *TimeoutCollectorConsumer) OnNewQcDiscovered(certificate *flow.QuorumCertificate)
OnNewQcDiscovered provides a mock function with given fields: certificate
func (*TimeoutCollectorConsumer) OnNewTcDiscovered ¶ added in v0.29.0
func (_m *TimeoutCollectorConsumer) OnNewTcDiscovered(certificate *flow.TimeoutCertificate)
OnNewTcDiscovered provides a mock function with given fields: certificate
func (*TimeoutCollectorConsumer) OnPartialTcCreated ¶ added in v0.29.0
func (_m *TimeoutCollectorConsumer) OnPartialTcCreated(view uint64, newestQC *flow.QuorumCertificate, lastViewTC *flow.TimeoutCertificate)
OnPartialTcCreated provides a mock function with given fields: view, newestQC, lastViewTC
func (*TimeoutCollectorConsumer) OnTcConstructedFromTimeouts ¶ added in v0.29.0
func (_m *TimeoutCollectorConsumer) OnTcConstructedFromTimeouts(certificate *flow.TimeoutCertificate)
OnTcConstructedFromTimeouts provides a mock function with given fields: certificate
func (*TimeoutCollectorConsumer) OnTimeoutProcessed ¶ added in v0.31.0
func (_m *TimeoutCollectorConsumer) OnTimeoutProcessed(timeout *model.TimeoutObject)
OnTimeoutProcessed provides a mock function with given fields: timeout
type TimeoutCollectorFactory ¶ added in v0.29.0
TimeoutCollectorFactory is an autogenerated mock type for the TimeoutCollectorFactory type
func NewTimeoutCollectorFactory ¶ added in v0.29.0
func NewTimeoutCollectorFactory(t mockConstructorTestingTNewTimeoutCollectorFactory) *TimeoutCollectorFactory
NewTimeoutCollectorFactory creates a new instance of TimeoutCollectorFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TimeoutCollectorFactory) Create ¶ added in v0.29.0
func (_m *TimeoutCollectorFactory) Create(view uint64) (hotstuff.TimeoutCollector, error)
Create provides a mock function with given fields: view
type TimeoutCollectors ¶ added in v0.29.0
TimeoutCollectors is an autogenerated mock type for the TimeoutCollectors type
func NewTimeoutCollectors ¶ added in v0.29.0
func NewTimeoutCollectors(t mockConstructorTestingTNewTimeoutCollectors) *TimeoutCollectors
NewTimeoutCollectors creates a new instance of TimeoutCollectors. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TimeoutCollectors) GetOrCreateCollector ¶ added in v0.29.0
func (_m *TimeoutCollectors) GetOrCreateCollector(view uint64) (hotstuff.TimeoutCollector, bool, error)
GetOrCreateCollector provides a mock function with given fields: view
func (*TimeoutCollectors) PruneUpToView ¶ added in v0.29.0
func (_m *TimeoutCollectors) PruneUpToView(lowestRetainedView uint64)
PruneUpToView provides a mock function with given fields: lowestRetainedView
type TimeoutProcessor ¶ added in v0.29.0
TimeoutProcessor is an autogenerated mock type for the TimeoutProcessor type
func NewTimeoutProcessor ¶ added in v0.29.0
func NewTimeoutProcessor(t mockConstructorTestingTNewTimeoutProcessor) *TimeoutProcessor
NewTimeoutProcessor creates a new instance of TimeoutProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TimeoutProcessor) Process ¶ added in v0.29.0
func (_m *TimeoutProcessor) Process(timeout *model.TimeoutObject) error
Process provides a mock function with given fields: timeout
type TimeoutProcessorFactory ¶ added in v0.29.0
TimeoutProcessorFactory is an autogenerated mock type for the TimeoutProcessorFactory type
func NewTimeoutProcessorFactory ¶ added in v0.29.0
func NewTimeoutProcessorFactory(t mockConstructorTestingTNewTimeoutProcessorFactory) *TimeoutProcessorFactory
NewTimeoutProcessorFactory creates a new instance of TimeoutProcessorFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TimeoutProcessorFactory) Create ¶ added in v0.29.0
func (_m *TimeoutProcessorFactory) Create(view uint64) (hotstuff.TimeoutProcessor, error)
Create provides a mock function with given fields: view
type TimeoutSignatureAggregator ¶ added in v0.29.0
TimeoutSignatureAggregator is an autogenerated mock type for the TimeoutSignatureAggregator type
func NewTimeoutSignatureAggregator ¶ added in v0.29.0
func NewTimeoutSignatureAggregator(t mockConstructorTestingTNewTimeoutSignatureAggregator) *TimeoutSignatureAggregator
NewTimeoutSignatureAggregator creates a new instance of TimeoutSignatureAggregator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TimeoutSignatureAggregator) Aggregate ¶ added in v0.29.0
func (_m *TimeoutSignatureAggregator) Aggregate() ([]hotstuff.TimeoutSignerInfo, crypto.Signature, error)
Aggregate provides a mock function with given fields:
func (*TimeoutSignatureAggregator) TotalWeight ¶ added in v0.29.0
func (_m *TimeoutSignatureAggregator) TotalWeight() uint64
TotalWeight provides a mock function with given fields:
func (*TimeoutSignatureAggregator) VerifyAndAdd ¶ added in v0.29.0
func (_m *TimeoutSignatureAggregator) VerifyAndAdd(signerID flow.Identifier, sig crypto.Signature, newestQCView uint64) (uint64, error)
VerifyAndAdd provides a mock function with given fields: signerID, sig, newestQCView
func (*TimeoutSignatureAggregator) View ¶ added in v0.29.0
func (_m *TimeoutSignatureAggregator) View() uint64
View provides a mock function with given fields:
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 ¶
func (_m *Validator) ValidateQC(qc *flow.QuorumCertificate) error
ValidateQC provides a mock function with given fields: qc
func (*Validator) ValidateTC ¶ added in v0.29.0
func (_m *Validator) ValidateTC(tc *flow.TimeoutCertificate) error
ValidateTC provides a mock function with given fields: tc
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.
func (*Verifier) VerifyQC ¶
func (_m *Verifier) VerifyQC(signers flow.IdentityList, sigData []byte, view uint64, blockID flow.Identifier) error
VerifyQC provides a mock function with given fields: signers, sigData, view, blockID
func (*Verifier) VerifyTC ¶ added in v0.29.0
func (_m *Verifier) VerifyTC(signers flow.IdentityList, sigData []byte, view uint64, highQCViews []uint64) error
VerifyTC provides a mock function with given fields: signers, sigData, view, highQCViews
func (*Verifier) VerifyVote ¶
func (_m *Verifier) VerifyVote(voter *flow.Identity, sigData []byte, view uint64, blockID flow.Identifier) error
VerifyVote provides a mock function with given fields: voter, sigData, view, blockID
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 VoteAggregationConsumer ¶ added in v0.31.0
VoteAggregationConsumer is an autogenerated mock type for the VoteAggregationConsumer type
func NewVoteAggregationConsumer ¶ added in v0.31.0
func NewVoteAggregationConsumer(t mockConstructorTestingTNewVoteAggregationConsumer) *VoteAggregationConsumer
NewVoteAggregationConsumer creates a new instance of VoteAggregationConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*VoteAggregationConsumer) OnDoubleVotingDetected ¶ added in v0.31.0
func (_m *VoteAggregationConsumer) OnDoubleVotingDetected(_a0 *model.Vote, _a1 *model.Vote)
OnDoubleVotingDetected provides a mock function with given fields: _a0, _a1
func (*VoteAggregationConsumer) OnInvalidVoteDetected ¶ added in v0.31.0
func (_m *VoteAggregationConsumer) OnInvalidVoteDetected(err model.InvalidVoteError)
OnInvalidVoteDetected provides a mock function with given fields: err
func (*VoteAggregationConsumer) OnQcConstructedFromVotes ¶ added in v0.31.0
func (_m *VoteAggregationConsumer) OnQcConstructedFromVotes(_a0 *flow.QuorumCertificate)
OnQcConstructedFromVotes provides a mock function with given fields: _a0
func (*VoteAggregationConsumer) OnVoteForInvalidBlockDetected ¶ added in v0.31.0
func (_m *VoteAggregationConsumer) OnVoteForInvalidBlockDetected(vote *model.Vote, invalidProposal *model.Proposal)
OnVoteForInvalidBlockDetected provides a mock function with given fields: vote, invalidProposal
func (*VoteAggregationConsumer) OnVoteProcessed ¶ added in v0.31.0
func (_m *VoteAggregationConsumer) OnVoteProcessed(vote *model.Vote)
OnVoteProcessed provides a mock function with given fields: vote
type VoteAggregationViolationConsumer ¶ added in v0.31.0
VoteAggregationViolationConsumer is an autogenerated mock type for the VoteAggregationViolationConsumer type
func NewVoteAggregationViolationConsumer ¶ added in v0.31.0
func NewVoteAggregationViolationConsumer(t mockConstructorTestingTNewVoteAggregationViolationConsumer) *VoteAggregationViolationConsumer
NewVoteAggregationViolationConsumer creates a new instance of VoteAggregationViolationConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*VoteAggregationViolationConsumer) OnDoubleVotingDetected ¶ added in v0.31.0
func (_m *VoteAggregationViolationConsumer) OnDoubleVotingDetected(_a0 *model.Vote, _a1 *model.Vote)
OnDoubleVotingDetected provides a mock function with given fields: _a0, _a1
func (*VoteAggregationViolationConsumer) OnInvalidVoteDetected ¶ added in v0.31.0
func (_m *VoteAggregationViolationConsumer) OnInvalidVoteDetected(err model.InvalidVoteError)
OnInvalidVoteDetected provides a mock function with given fields: err
func (*VoteAggregationViolationConsumer) OnVoteForInvalidBlockDetected ¶ added in v0.31.0
func (_m *VoteAggregationViolationConsumer) OnVoteForInvalidBlockDetected(vote *model.Vote, invalidProposal *model.Proposal)
OnVoteForInvalidBlockDetected provides a mock function with given fields: vote, invalidProposal
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)
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 VoteCollectorConsumer ¶ added in v0.31.0
VoteCollectorConsumer is an autogenerated mock type for the VoteCollectorConsumer type
func NewVoteCollectorConsumer ¶ added in v0.31.0
func NewVoteCollectorConsumer(t mockConstructorTestingTNewVoteCollectorConsumer) *VoteCollectorConsumer
NewVoteCollectorConsumer creates a new instance of VoteCollectorConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*VoteCollectorConsumer) OnQcConstructedFromVotes ¶ added in v0.31.0
func (_m *VoteCollectorConsumer) OnQcConstructedFromVotes(_a0 *flow.QuorumCertificate)
OnQcConstructedFromVotes provides a mock function with given fields: _a0
func (*VoteCollectorConsumer) OnVoteProcessed ¶ added in v0.31.0
func (_m *VoteCollectorConsumer) OnVoteProcessed(vote *model.Vote)
OnVoteProcessed provides a mock function with given fields: vote
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 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.IdentifierList, []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_decoder.go
- communicator_consumer.go
- consumer.go
- dkg.go
- dynamic_committee.go
- event_handler.go
- event_loop.go
- finalization_consumer.go
- follower_consumer.go
- forks.go
- on_qc_created.go
- pace_maker.go
- packer.go
- participant_consumer.go
- persister.go
- proposal_duration_provider.go
- proposal_violation_consumer.go
- random_beacon_inspector.go
- random_beacon_reconstructor.go
- replicas.go
- safety_rules.go
- signer.go
- timeout_aggregation_consumer.go
- timeout_aggregation_violation_consumer.go
- timeout_aggregator.go
- timeout_collector.go
- timeout_collector_consumer.go
- timeout_collector_factory.go
- timeout_collectors.go
- timeout_processor.go
- timeout_processor_factory.go
- timeout_signature_aggregator.go
- validator.go
- verifier.go
- verifying_vote_processor.go
- vote_aggregation_consumer.go
- vote_aggregation_violation_consumer.go
- vote_aggregator.go
- vote_collector.go
- vote_collector_consumer.go
- vote_collectors.go
- vote_consumer.go
- vote_processor.go
- vote_processor_factory.go
- weighted_signature_aggregator.go
- workerpool.go
- workers.go