Help us shape the future of Go! Take the 2026 Go Developer Survey

mocks

package
v0.36.2 Latest Latest
Warning

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

 Go to latest Published: Jul 18, 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.