mocks

package
v0.37.22 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2024 License: AGPL-3.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlockProducer 

type BlockProducer struct {
	mock.Mock
}

BlockProducer is an autogenerated mock type for the BlockProducer type

func NewBlockProducer added in v0.26.1 

func NewBlockProducer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type BlockSignerDecoder struct {
	mock.Mock
}

BlockSignerDecoder is an autogenerated mock type for the BlockSignerDecoder type

func NewBlockSignerDecoder added in v0.26.17 

func NewBlockSignerDecoder(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type CommunicatorConsumer struct {
	mock.Mock
}

CommunicatorConsumer is an autogenerated mock type for the CommunicatorConsumer type

func NewCommunicatorConsumer added in v0.29.0 

func NewCommunicatorConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type Consumer struct {
	mock.Mock
}

Consumer is an autogenerated mock type for the Consumer type

func NewConsumer added in v0.26.1 

func NewConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

func (*Consumer) OnBlockIncorporated 

func (_m *Consumer) OnBlockIncorporated(_a0 *model.Block)

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 

func (_m *Consumer) OnDoubleProposeDetected(_a0 *model.Block, _a1 *model.Block)

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 

func (_m *Consumer) OnFinalizedBlock(_a0 *model.Block)

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 

func (_m *Consumer) OnLocalTimeout(currentView uint64)

OnLocalTimeout provides a mock function with given fields: currentView

func (*Consumer) OnOwnProposal added in v0.29.0 

func (_m *Consumer) OnOwnProposal(proposal *flow.Header, targetPublicationTime time.Time)

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 

func (_m *Consumer) OnReceiveProposal(currentView uint64, proposal *model.Proposal)

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 

func (_m *Consumer) OnStart(currentView uint64)

OnStart provides a mock function with given fields: currentView

func (*Consumer) OnStartingTimeout 

func (_m *Consumer) OnStartingTimeout(_a0 model.TimerInfo)

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 

func (_m *Consumer) OnViewChange(oldView uint64, newView uint64)

OnViewChange provides a mock function with given fields: oldView, newView

type DKG 

type DKG struct {
	mock.Mock
}

DKG is an autogenerated mock type for the DKG type

func NewDKG added in v0.26.1 

func NewDKG(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

func (*DKG) GroupKey 

func (_m *DKG) GroupKey() crypto.PublicKey

GroupKey provides a mock function with given fields:

func (*DKG) Index 

func (_m *DKG) Index(nodeID flow.Identifier) (uint, error)

Index provides a mock function with given fields: nodeID

func (*DKG) KeyShare 

func (_m *DKG) KeyShare(nodeID flow.Identifier) (crypto.PublicKey, error)

KeyShare provides a mock function with given fields: nodeID

func (*DKG) Size 

func (_m *DKG) Size() uint

Size provides a mock function with given fields:

type DynamicCommittee added in v0.29.0 

type DynamicCommittee struct {
	mock.Mock
}

DynamicCommittee is an autogenerated mock type for the DynamicCommittee type

func NewDynamicCommittee added in v0.29.0 

func NewDynamicCommittee(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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.GenericIdentityList[flow.Identity], 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.GenericIdentityList[flow.IdentitySkeleton], 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.IdentitySkeleton, 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 

type EventHandler struct {
	mock.Mock
}

EventHandler is an autogenerated mock type for the EventHandler type

func NewEventHandler added in v0.26.1 

func NewEventHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type EventLoop struct {
	mock.Mock
}

EventLoop is an autogenerated mock type for the EventLoop type

func NewEventLoop added in v0.26.1 

func NewEventLoop(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

func (_m *EventLoop) OnVoteProcessed(vote *model.Vote)

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 

func (_m *EventLoop) SubmitProposal(proposal *model.Proposal)

SubmitProposal provides a mock function with given fields: proposal

type FinalizationConsumer 

type FinalizationConsumer struct {
	mock.Mock
}

FinalizationConsumer is an autogenerated mock type for the FinalizationConsumer type

func NewFinalizationConsumer added in v0.26.1 

func NewFinalizationConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type FollowerConsumer struct {
	mock.Mock
}

FollowerConsumer is an autogenerated mock type for the FollowerConsumer type

func NewFollowerConsumer added in v0.31.0 

func NewFollowerConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type Forks struct {
	mock.Mock
}

Forks is an autogenerated mock type for the Forks type

func NewForks added in v0.26.1 

func NewForks(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

func (_m *Forks) AddValidatedBlock(proposal *model.Block) error

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 

func (_m *Forks) FinalizedBlock() *model.Block

FinalizedBlock provides a mock function with given fields:

func (*Forks) FinalizedView 

func (_m *Forks) FinalizedView() uint64

FinalizedView provides a mock function with given fields:

func (*Forks) GetBlock 

func (_m *Forks) GetBlock(blockID flow.Identifier) (*model.Block, bool)

GetBlock provides a mock function with given fields: blockID

func (*Forks) GetBlocksForView 

func (_m *Forks) GetBlocksForView(view uint64) []*model.Block

GetBlocksForView provides a mock function with given fields: view

type OnQCCreated added in v0.26.1 

type OnQCCreated struct {
	mock.Mock
}

OnQCCreated is an autogenerated mock type for the OnQCCreated type

func NewOnQCCreated added in v0.26.1 

func NewOnQCCreated(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type PaceMaker struct {
	mock.Mock
}

PaceMaker is an autogenerated mock type for the PaceMaker type

func NewPaceMaker added in v0.26.1 

func NewPaceMaker(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

func (*PaceMaker) CurView 

func (_m *PaceMaker) CurView() uint64

CurView provides a mock function with given fields:

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) Start 

func (_m *PaceMaker) Start(ctx context.Context)

Start provides a mock function with given fields: ctx

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 

func (_m *PaceMaker) TimeoutChannel() <-chan time.Time

TimeoutChannel provides a mock function with given fields:

type Packer added in v0.23.9 

type Packer struct {
	mock.Mock
}

Packer is an autogenerated mock type for the Packer type

func NewPacker added in v0.26.1 

func NewPacker(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

func (*Packer) Pack added in v0.23.9 

func (_m *Packer) Pack(view uint64, sig *hotstuff.BlockSignatureData) ([]byte, []byte, error)

Pack provides a mock function with given fields: view, sig

func (*Packer) Unpack added in v0.23.9 

func (_m *Packer) Unpack(signerIdentities flow.GenericIdentityList[flow.IdentitySkeleton], sigData []byte) (*hotstuff.BlockSignatureData, error)

Unpack provides a mock function with given fields: signerIdentities, sigData

type ParticipantConsumer added in v0.31.0 

type ParticipantConsumer struct {
	mock.Mock
}

ParticipantConsumer is an autogenerated mock type for the ParticipantConsumer type

func NewParticipantConsumer added in v0.31.0 

func NewParticipantConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type Persister struct {
	mock.Mock
}

Persister is an autogenerated mock type for the Persister type

func NewPersister added in v0.26.1 

func NewPersister(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type ProposalDurationProvider struct {
	mock.Mock
}

ProposalDurationProvider is an autogenerated mock type for the ProposalDurationProvider type

func NewProposalDurationProvider added in v0.31.0 

func NewProposalDurationProvider(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type ProposalViolationConsumer struct {
	mock.Mock
}

ProposalViolationConsumer is an autogenerated mock type for the ProposalViolationConsumer type

func NewProposalViolationConsumer added in v0.31.0 

func NewProposalViolationConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type RandomBeaconInspector struct {
	mock.Mock
}

RandomBeaconInspector is an autogenerated mock type for the RandomBeaconInspector type

func NewRandomBeaconInspector added in v0.26.1 

func NewRandomBeaconInspector(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

func (_m *RandomBeaconInspector) TrustedAdd(signerIndex int, share crypto.Signature) (bool, error)

TrustedAdd provides a mock function with given fields: signerIndex, share

func (*RandomBeaconInspector) Verify added in v0.23.9 

func (_m *RandomBeaconInspector) Verify(signerIndex int, share crypto.Signature) error

Verify provides a mock function with given fields: signerIndex, share

type RandomBeaconReconstructor added in v0.23.9 

type RandomBeaconReconstructor struct {
	mock.Mock
}

RandomBeaconReconstructor is an autogenerated mock type for the RandomBeaconReconstructor type

func NewRandomBeaconReconstructor added in v0.26.1 

func NewRandomBeaconReconstructor(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type Replicas struct {
	mock.Mock
}

Replicas is an autogenerated mock type for the Replicas type

func NewReplicas added in v0.29.0 

func NewReplicas(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

func (*Replicas) DKG added in v0.29.0 

func (_m *Replicas) DKG(view uint64) (hotstuff.DKG, error)

DKG provides a mock function with given fields: view

func (*Replicas) IdentitiesByEpoch added in v0.29.0 

func (_m *Replicas) IdentitiesByEpoch(view uint64) (flow.GenericIdentityList[flow.IdentitySkeleton], 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.IdentitySkeleton, 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 

func (_m *Replicas) QuorumThresholdForView(view uint64) (uint64, error)

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:

func (*Replicas) TimeoutThresholdForView added in v0.29.0 

func (_m *Replicas) TimeoutThresholdForView(view uint64) (uint64, error)

TimeoutThresholdForView provides a mock function with given fields: view

type SafetyRules added in v0.29.0 

type SafetyRules struct {
	mock.Mock
}

SafetyRules is an autogenerated mock type for the SafetyRules type

func NewSafetyRules added in v0.29.0 

func NewSafetyRules(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

func (_m *SafetyRules) ProduceVote(proposal *model.Proposal, curView uint64) (*model.Vote, error)

ProduceVote provides a mock function with given fields: proposal, curView

type Signer 

type Signer struct {
	mock.Mock
}

Signer is an autogenerated mock type for the Signer type

func NewSigner added in v0.26.1 

func NewSigner(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

func (*Signer) CreateProposal 

func (_m *Signer) CreateProposal(block *model.Block) (*model.Proposal, error)

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

func (*Signer) CreateVote 

func (_m *Signer) CreateVote(block *model.Block) (*model.Vote, error)

CreateVote provides a mock function with given fields: block

type TimeoutAggregationConsumer added in v0.31.0 

type TimeoutAggregationConsumer struct {
	mock.Mock
}

TimeoutAggregationConsumer is an autogenerated mock type for the TimeoutAggregationConsumer type

func NewTimeoutAggregationConsumer added in v0.31.0 

func NewTimeoutAggregationConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type TimeoutAggregationViolationConsumer struct {
	mock.Mock
}

TimeoutAggregationViolationConsumer is an autogenerated mock type for the TimeoutAggregationViolationConsumer type

func NewTimeoutAggregationViolationConsumer added in v0.31.0 

func NewTimeoutAggregationViolationConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type TimeoutAggregator struct {
	mock.Mock
}

TimeoutAggregator is an autogenerated mock type for the TimeoutAggregator type

func NewTimeoutAggregator added in v0.29.0 

func NewTimeoutAggregator(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type TimeoutCollector struct {
	mock.Mock
}

TimeoutCollector is an autogenerated mock type for the TimeoutCollector type

func NewTimeoutCollector added in v0.29.0 

func NewTimeoutCollector(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type TimeoutCollectorConsumer struct {
	mock.Mock
}

TimeoutCollectorConsumer is an autogenerated mock type for the TimeoutCollectorConsumer type

func NewTimeoutCollectorConsumer added in v0.29.0 

func NewTimeoutCollectorConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type TimeoutCollectorFactory struct {
	mock.Mock
}

TimeoutCollectorFactory is an autogenerated mock type for the TimeoutCollectorFactory type

func NewTimeoutCollectorFactory added in v0.29.0 

func NewTimeoutCollectorFactory(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type TimeoutCollectors struct {
	mock.Mock
}

TimeoutCollectors is an autogenerated mock type for the TimeoutCollectors type

func NewTimeoutCollectors added in v0.29.0 

func NewTimeoutCollectors(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type TimeoutProcessor struct {
	mock.Mock
}

TimeoutProcessor is an autogenerated mock type for the TimeoutProcessor type

func NewTimeoutProcessor added in v0.29.0 

func NewTimeoutProcessor(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type TimeoutProcessorFactory struct {
	mock.Mock
}

TimeoutProcessorFactory is an autogenerated mock type for the TimeoutProcessorFactory type

func NewTimeoutProcessorFactory added in v0.29.0 

func NewTimeoutProcessorFactory(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type TimeoutSignatureAggregator struct {
	mock.Mock
}

TimeoutSignatureAggregator is an autogenerated mock type for the TimeoutSignatureAggregator type

func NewTimeoutSignatureAggregator added in v0.29.0 

func NewTimeoutSignatureAggregator(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type Validator struct {
	mock.Mock
}

Validator is an autogenerated mock type for the Validator type

func NewValidator added in v0.26.1 

func NewValidator(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

func (*Validator) ValidateProposal 

func (_m *Validator) ValidateProposal(proposal *model.Proposal) error

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

func (*Validator) ValidateVote 

func (_m *Validator) ValidateVote(vote *model.Vote) (*flow.IdentitySkeleton, error)

ValidateVote provides a mock function with given fields: vote

type Verifier 

type Verifier struct {
	mock.Mock
}

Verifier is an autogenerated mock type for the Verifier type

func NewVerifier added in v0.26.1 

func NewVerifier(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

func (*Verifier) VerifyQC 

func (_m *Verifier) VerifyQC(signers flow.GenericIdentityList[flow.IdentitySkeleton], 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.GenericIdentityList[flow.IdentitySkeleton], 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.IdentitySkeleton, 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 

type VerifyingVoteProcessor struct {
	mock.Mock
}

VerifyingVoteProcessor is an autogenerated mock type for the VerifyingVoteProcessor type

func NewVerifyingVoteProcessor added in v0.26.1 

func NewVerifyingVoteProcessor(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type VoteAggregationConsumer struct {
	mock.Mock
}

VoteAggregationConsumer is an autogenerated mock type for the VoteAggregationConsumer type

func NewVoteAggregationConsumer added in v0.31.0 

func NewVoteAggregationConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type VoteAggregationViolationConsumer struct {
	mock.Mock
}

VoteAggregationViolationConsumer is an autogenerated mock type for the VoteAggregationViolationConsumer type

func NewVoteAggregationViolationConsumer added in v0.31.0 

func NewVoteAggregationViolationConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type VoteAggregator struct {
	mock.Mock
}

VoteAggregator is an autogenerated mock type for the VoteAggregator type

func NewVoteAggregator added in v0.26.1 

func NewVoteAggregator(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type VoteCollector struct {
	mock.Mock
}

VoteCollector is an autogenerated mock type for the VoteCollector type

func NewVoteCollector added in v0.26.1 

func NewVoteCollector(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type VoteCollectorConsumer struct {
	mock.Mock
}

VoteCollectorConsumer is an autogenerated mock type for the VoteCollectorConsumer type

func NewVoteCollectorConsumer added in v0.31.0 

func NewVoteCollectorConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type VoteCollectors struct {
	mock.Mock
}

VoteCollectors is an autogenerated mock type for the VoteCollectors type

func NewVoteCollectors added in v0.26.1 

func NewVoteCollectors(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type VoteConsumer struct {
	mock.Mock
}

VoteConsumer is an autogenerated mock type for the VoteConsumer type

func NewVoteConsumer added in v0.26.1 

func NewVoteConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type VoteProcessor struct {
	mock.Mock
}

VoteProcessor is an autogenerated mock type for the VoteProcessor type

func NewVoteProcessor added in v0.26.1 

func NewVoteProcessor(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type VoteProcessorFactory struct {
	mock.Mock
}

VoteProcessorFactory is an autogenerated mock type for the VoteProcessorFactory type

func NewVoteProcessorFactory added in v0.26.1 

func NewVoteProcessorFactory(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type WeightedSignatureAggregator struct {
	mock.Mock
}

WeightedSignatureAggregator is an autogenerated mock type for the WeightedSignatureAggregator type

func NewWeightedSignatureAggregator added in v0.26.1 

func NewWeightedSignatureAggregator(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type Workerpool struct {
	mock.Mock
}

Workerpool is an autogenerated mock type for the Workerpool type

func NewWorkerpool added in v0.26.1 

func NewWorkerpool(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type Workers struct {
	mock.Mock
}

Workers is an autogenerated mock type for the Workers type

func NewWorkers added in v0.26.1 

func NewWorkers(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

func (*Workers) Submit added in v0.23.9 

func (_m *Workers) Submit(task func())

Submit provides a mock function with given fields: task

Source Files

View all Source files

Jump to

Keyboard shortcuts

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