Documentation ¶
Index ¶
- type BlockTimer
- type Cluster
- type ClusterEvents
- type ClusterIDUpdateConsumer
- type Consumer
- func (_m *Consumer) BlockFinalized(block *flow.Header)
- func (_m *Consumer) BlockProcessable(block *flow.Header, certifyingQC *flow.QuorumCertificate)
- func (_m *Consumer) EpochCommittedPhaseStarted(currentEpochCounter uint64, first *flow.Header)
- func (_m *Consumer) EpochEmergencyFallbackTriggered()
- func (_m *Consumer) EpochSetupPhaseStarted(currentEpochCounter uint64, first *flow.Header)
- func (_m *Consumer) EpochTransition(newEpochCounter uint64, first *flow.Header)
- type DKG
- type Epoch
- func (_m *Epoch) Cluster(index uint) (protocol.Cluster, error)
- func (_m *Epoch) ClusterByChainID(chainID flow.ChainID) (protocol.Cluster, error)
- func (_m *Epoch) Clustering() (flow.ClusterList, error)
- func (_m *Epoch) Counter() (uint64, error)
- func (_m *Epoch) DKG() (protocol.DKG, error)
- func (_m *Epoch) DKGPhase1FinalView() (uint64, error)
- func (_m *Epoch) DKGPhase2FinalView() (uint64, error)
- func (_m *Epoch) DKGPhase3FinalView() (uint64, error)
- func (_m *Epoch) FinalHeight() (uint64, error)
- func (_m *Epoch) FinalView() (uint64, error)
- func (_m *Epoch) FirstHeight() (uint64, error)
- func (_m *Epoch) FirstView() (uint64, error)
- func (_m *Epoch) InitialIdentities() (flow.IdentityList, error)
- func (_m *Epoch) RandomSource() ([]byte, error)
- type EpochQuery
- type FollowerState
- func (_m *FollowerState) AtBlockID(blockID flow.Identifier) protocol.Snapshot
- func (_m *FollowerState) AtHeight(height uint64) protocol.Snapshot
- func (_m *FollowerState) ExtendCertified(ctx context.Context, candidate *flow.Block, qc *flow.QuorumCertificate) error
- func (_m *FollowerState) Final() protocol.Snapshot
- func (_m *FollowerState) Finalize(ctx context.Context, blockID flow.Identifier) error
- func (_m *FollowerState) Params() protocol.Params
- func (_m *FollowerState) Sealed() protocol.Snapshot
- type GlobalParams
- func (_m *GlobalParams) ChainID() (flow.ChainID, error)
- func (_m *GlobalParams) EpochCommitSafetyThreshold() (uint64, error)
- func (_m *GlobalParams) ProtocolVersion() (uint, error)
- func (_m *GlobalParams) SporkID() (flow.Identifier, error)
- func (_m *GlobalParams) SporkRootBlockHeight() (uint64, error)
- type InstanceParams
- type Params
- func (_m *Params) ChainID() (flow.ChainID, error)
- func (_m *Params) EpochCommitSafetyThreshold() (uint64, error)
- func (_m *Params) EpochFallbackTriggered() (bool, error)
- func (_m *Params) FinalizedRoot() (*flow.Header, error)
- func (_m *Params) ProtocolVersion() (uint, error)
- func (_m *Params) Seal() (*flow.Seal, error)
- func (_m *Params) SealedRoot() (*flow.Header, error)
- func (_m *Params) SporkID() (flow.Identifier, error)
- func (_m *Params) SporkRootBlockHeight() (uint64, error)
- type ParticipantState
- func (_m *ParticipantState) AtBlockID(blockID flow.Identifier) protocol.Snapshot
- func (_m *ParticipantState) AtHeight(height uint64) protocol.Snapshot
- func (_m *ParticipantState) Extend(ctx context.Context, candidate *flow.Block) error
- func (_m *ParticipantState) ExtendCertified(ctx context.Context, candidate *flow.Block, qc *flow.QuorumCertificate) error
- func (_m *ParticipantState) Final() protocol.Snapshot
- func (_m *ParticipantState) Finalize(ctx context.Context, blockID flow.Identifier) error
- func (_m *ParticipantState) Params() protocol.Params
- func (_m *ParticipantState) Sealed() protocol.Snapshot
- type Snapshot
- func (_m *Snapshot) Commit() (flow.StateCommitment, error)
- func (_m *Snapshot) Descendants() ([]flow.Identifier, error)
- func (_m *Snapshot) Epochs() protocol.EpochQuery
- func (_m *Snapshot) Head() (*flow.Header, error)
- func (_m *Snapshot) Identities(selector flow.IdentityFilter) (flow.IdentityList, error)
- func (_m *Snapshot) Identity(nodeID flow.Identifier) (*flow.Identity, error)
- func (_m *Snapshot) Params() protocol.GlobalParams
- func (_m *Snapshot) Phase() (flow.EpochPhase, error)
- func (_m *Snapshot) QuorumCertificate() (*flow.QuorumCertificate, error)
- func (_m *Snapshot) RandomSource() ([]byte, error)
- func (_m *Snapshot) SealedResult() (*flow.ExecutionResult, *flow.Seal, error)
- func (_m *Snapshot) SealingSegment() (*flow.SealingSegment, error)
- func (_m *Snapshot) VersionBeacon() (*flow.SealedVersionBeacon, error)
- type State
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockTimer ¶ added in v0.20.0
BlockTimer is an autogenerated mock type for the BlockTimer type
func NewBlockTimer ¶ added in v0.26.1
func NewBlockTimer(t mockConstructorTestingTNewBlockTimer) *BlockTimer
NewBlockTimer creates a new instance of BlockTimer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
type Cluster ¶
Cluster is an autogenerated mock type for the Cluster type
func NewCluster ¶ added in v0.26.1
func NewCluster(t mockConstructorTestingTNewCluster) *Cluster
NewCluster creates a new instance of Cluster. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Cluster) EpochCounter ¶
EpochCounter provides a mock function with given fields:
func (*Cluster) Members ¶
func (_m *Cluster) Members() flow.IdentityList
Members provides a mock function with given fields:
func (*Cluster) RootQC ¶
func (_m *Cluster) RootQC() *flow.QuorumCertificate
RootQC provides a mock function with given fields:
type ClusterEvents ¶ added in v0.31.0
ClusterEvents is an autogenerated mock type for the ClusterEvents type
func NewClusterEvents ¶ added in v0.31.0
func NewClusterEvents(t mockConstructorTestingTNewClusterEvents) *ClusterEvents
NewClusterEvents creates a new instance of ClusterEvents. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ClusterEvents) ActiveClustersChanged ¶ added in v0.31.0
func (_m *ClusterEvents) ActiveClustersChanged(_a0 flow.ChainIDList)
ActiveClustersChanged provides a mock function with given fields: _a0
type ClusterIDUpdateConsumer ¶ added in v0.31.0
ClusterIDUpdateConsumer is an autogenerated mock type for the ClusterIDUpdateConsumer type
func NewClusterIDUpdateConsumer ¶ added in v0.31.0
func NewClusterIDUpdateConsumer(t mockConstructorTestingTNewClusterIDUpdateConsumer) *ClusterIDUpdateConsumer
NewClusterIDUpdateConsumer creates a new instance of ClusterIDUpdateConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ClusterIDUpdateConsumer) ActiveClustersChanged ¶ added in v0.31.0
func (_m *ClusterIDUpdateConsumer) ActiveClustersChanged(_a0 flow.ChainIDList)
ClusterIdsUpdated provides a mock function with given fields: _a0
type Consumer ¶
Consumer is an autogenerated mock type for the Consumer type
func NewConsumer ¶ added in v0.26.1
func NewConsumer(t mockConstructorTestingTNewConsumer) *Consumer
NewConsumer creates a new instance of Consumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Consumer) BlockFinalized ¶
BlockFinalized provides a mock function with given fields: block
func (*Consumer) BlockProcessable ¶
func (_m *Consumer) BlockProcessable(block *flow.Header, certifyingQC *flow.QuorumCertificate)
BlockProcessable provides a mock function with given fields: block, certifyingQC
func (*Consumer) EpochCommittedPhaseStarted ¶
EpochCommittedPhaseStarted provides a mock function with given fields: currentEpochCounter, first
func (*Consumer) EpochEmergencyFallbackTriggered ¶ added in v0.29.0
func (_m *Consumer) EpochEmergencyFallbackTriggered()
EpochEmergencyFallbackTriggered provides a mock function with given fields:
func (*Consumer) EpochSetupPhaseStarted ¶
EpochSetupPhaseStarted provides a mock function with given fields: currentEpochCounter, first
type DKG ¶
DKG is an autogenerated mock type for the DKG type
func NewDKG ¶ added in v0.26.1
func NewDKG(t mockConstructorTestingTNewDKG) *DKG
NewDKG creates a new instance of DKG. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*DKG) Index ¶
func (_m *DKG) Index(nodeID flow.Identifier) (uint, error)
Index provides a mock function with given fields: nodeID
type Epoch ¶
Epoch is an autogenerated mock type for the Epoch type
func NewEpoch ¶ added in v0.26.1
func NewEpoch(t mockConstructorTestingTNewEpoch) *Epoch
NewEpoch creates a new instance of Epoch. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Epoch) ClusterByChainID ¶ added in v0.26.1
ClusterByChainID provides a mock function with given fields: chainID
func (*Epoch) Clustering ¶
func (_m *Epoch) Clustering() (flow.ClusterList, error)
Clustering provides a mock function with given fields:
func (*Epoch) DKGPhase1FinalView ¶ added in v0.20.0
DKGPhase1FinalView provides a mock function with given fields:
func (*Epoch) DKGPhase2FinalView ¶ added in v0.20.0
DKGPhase2FinalView provides a mock function with given fields:
func (*Epoch) DKGPhase3FinalView ¶ added in v0.20.0
DKGPhase3FinalView provides a mock function with given fields:
func (*Epoch) FinalHeight ¶ added in v0.30.0
FinalHeight provides a mock function with given fields:
func (*Epoch) FirstHeight ¶ added in v0.30.0
FirstHeight provides a mock function with given fields:
func (*Epoch) InitialIdentities ¶
func (_m *Epoch) InitialIdentities() (flow.IdentityList, error)
InitialIdentities provides a mock function with given fields:
func (*Epoch) RandomSource ¶ added in v0.15.0
RandomSource provides a mock function with given fields:
type EpochQuery ¶
EpochQuery is an autogenerated mock type for the EpochQuery type
func NewEpochQuery ¶ added in v0.26.1
func NewEpochQuery(t mockConstructorTestingTNewEpochQuery) *EpochQuery
NewEpochQuery creates a new instance of EpochQuery. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*EpochQuery) Current ¶
func (_m *EpochQuery) Current() protocol.Epoch
Current provides a mock function with given fields:
func (*EpochQuery) Next ¶
func (_m *EpochQuery) Next() protocol.Epoch
Next provides a mock function with given fields:
func (*EpochQuery) Previous ¶ added in v0.13.0
func (_m *EpochQuery) Previous() protocol.Epoch
Previous provides a mock function with given fields:
type FollowerState ¶ added in v0.30.0
FollowerState is an autogenerated mock type for the FollowerState type
func NewFollowerState ¶ added in v0.30.0
func NewFollowerState(t mockConstructorTestingTNewFollowerState) *FollowerState
NewFollowerState creates a new instance of FollowerState. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*FollowerState) AtBlockID ¶ added in v0.30.0
func (_m *FollowerState) AtBlockID(blockID flow.Identifier) protocol.Snapshot
AtBlockID provides a mock function with given fields: blockID
func (*FollowerState) AtHeight ¶ added in v0.30.0
func (_m *FollowerState) AtHeight(height uint64) protocol.Snapshot
AtHeight provides a mock function with given fields: height
func (*FollowerState) ExtendCertified ¶ added in v0.30.0
func (_m *FollowerState) ExtendCertified(ctx context.Context, candidate *flow.Block, qc *flow.QuorumCertificate) error
ExtendCertified provides a mock function with given fields: ctx, candidate, qc
func (*FollowerState) Final ¶ added in v0.30.0
func (_m *FollowerState) Final() protocol.Snapshot
Final provides a mock function with given fields:
func (*FollowerState) Finalize ¶ added in v0.30.0
func (_m *FollowerState) Finalize(ctx context.Context, blockID flow.Identifier) error
Finalize provides a mock function with given fields: ctx, blockID
func (*FollowerState) Params ¶ added in v0.30.0
func (_m *FollowerState) Params() protocol.Params
Params provides a mock function with given fields:
func (*FollowerState) Sealed ¶ added in v0.30.0
func (_m *FollowerState) Sealed() protocol.Snapshot
Sealed provides a mock function with given fields:
type GlobalParams ¶ added in v0.23.2
GlobalParams is an autogenerated mock type for the GlobalParams type
func NewGlobalParams ¶ added in v0.26.1
func NewGlobalParams(t mockConstructorTestingTNewGlobalParams) *GlobalParams
NewGlobalParams creates a new instance of GlobalParams. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*GlobalParams) ChainID ¶ added in v0.23.2
func (_m *GlobalParams) ChainID() (flow.ChainID, error)
ChainID provides a mock function with given fields:
func (*GlobalParams) EpochCommitSafetyThreshold ¶ added in v0.29.0
func (_m *GlobalParams) EpochCommitSafetyThreshold() (uint64, error)
EpochCommitSafetyThreshold provides a mock function with given fields:
func (*GlobalParams) ProtocolVersion ¶ added in v0.23.2
func (_m *GlobalParams) ProtocolVersion() (uint, error)
ProtocolVersion provides a mock function with given fields:
func (*GlobalParams) SporkID ¶ added in v0.23.2
func (_m *GlobalParams) SporkID() (flow.Identifier, error)
SporkID provides a mock function with given fields:
func (*GlobalParams) SporkRootBlockHeight ¶ added in v0.29.6
func (_m *GlobalParams) SporkRootBlockHeight() (uint64, error)
SporkRootBlockHeight provides a mock function with given fields:
type InstanceParams ¶ added in v0.23.2
InstanceParams is an autogenerated mock type for the InstanceParams type
func NewInstanceParams ¶ added in v0.26.1
func NewInstanceParams(t mockConstructorTestingTNewInstanceParams) *InstanceParams
NewInstanceParams creates a new instance of InstanceParams. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*InstanceParams) EpochFallbackTriggered ¶ added in v0.29.0
func (_m *InstanceParams) EpochFallbackTriggered() (bool, error)
EpochFallbackTriggered provides a mock function with given fields:
func (*InstanceParams) FinalizedRoot ¶ added in v0.30.7
func (_m *InstanceParams) FinalizedRoot() (*flow.Header, error)
FinalizedRoot provides a mock function with given fields:
func (*InstanceParams) Seal ¶ added in v0.23.2
func (_m *InstanceParams) Seal() (*flow.Seal, error)
Seal provides a mock function with given fields:
func (*InstanceParams) SealedRoot ¶ added in v0.30.7
func (_m *InstanceParams) SealedRoot() (*flow.Header, error)
SealedRoot provides a mock function with given fields:
type Params ¶
Params is an autogenerated mock type for the Params type
func NewParams ¶ added in v0.26.1
func NewParams(t mockConstructorTestingTNewParams) *Params
NewParams creates a new instance of Params. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Params) EpochCommitSafetyThreshold ¶ added in v0.29.0
EpochCommitSafetyThreshold provides a mock function with given fields:
func (*Params) EpochFallbackTriggered ¶ added in v0.29.0
EpochFallbackTriggered provides a mock function with given fields:
func (*Params) FinalizedRoot ¶ added in v0.30.7
FinalizedRoot provides a mock function with given fields:
func (*Params) ProtocolVersion ¶ added in v0.23.2
ProtocolVersion provides a mock function with given fields:
func (*Params) SealedRoot ¶ added in v0.30.7
SealedRoot provides a mock function with given fields:
func (*Params) SporkID ¶ added in v0.23.2
func (_m *Params) SporkID() (flow.Identifier, error)
SporkID provides a mock function with given fields:
func (*Params) SporkRootBlockHeight ¶ added in v0.29.6
SporkRootBlockHeight provides a mock function with given fields:
type ParticipantState ¶ added in v0.30.0
ParticipantState is an autogenerated mock type for the ParticipantState type
func NewParticipantState ¶ added in v0.30.0
func NewParticipantState(t mockConstructorTestingTNewParticipantState) *ParticipantState
NewParticipantState creates a new instance of ParticipantState. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ParticipantState) AtBlockID ¶ added in v0.30.0
func (_m *ParticipantState) AtBlockID(blockID flow.Identifier) protocol.Snapshot
AtBlockID provides a mock function with given fields: blockID
func (*ParticipantState) AtHeight ¶ added in v0.30.0
func (_m *ParticipantState) AtHeight(height uint64) protocol.Snapshot
AtHeight provides a mock function with given fields: height
func (*ParticipantState) Extend ¶ added in v0.30.0
Extend provides a mock function with given fields: ctx, candidate
func (*ParticipantState) ExtendCertified ¶ added in v0.30.0
func (_m *ParticipantState) ExtendCertified(ctx context.Context, candidate *flow.Block, qc *flow.QuorumCertificate) error
ExtendCertified provides a mock function with given fields: ctx, candidate, qc
func (*ParticipantState) Final ¶ added in v0.30.0
func (_m *ParticipantState) Final() protocol.Snapshot
Final provides a mock function with given fields:
func (*ParticipantState) Finalize ¶ added in v0.30.0
func (_m *ParticipantState) Finalize(ctx context.Context, blockID flow.Identifier) error
Finalize provides a mock function with given fields: ctx, blockID
func (*ParticipantState) Params ¶ added in v0.30.0
func (_m *ParticipantState) Params() protocol.Params
Params provides a mock function with given fields:
func (*ParticipantState) Sealed ¶ added in v0.30.0
func (_m *ParticipantState) Sealed() protocol.Snapshot
Sealed provides a mock function with given fields:
type Snapshot ¶
Snapshot is an autogenerated mock type for the Snapshot type
func NewSnapshot ¶ added in v0.26.1
func NewSnapshot(t mockConstructorTestingTNewSnapshot) *Snapshot
NewSnapshot creates a new instance of Snapshot. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Snapshot) Commit ¶
func (_m *Snapshot) Commit() (flow.StateCommitment, error)
Commit provides a mock function with given fields:
func (*Snapshot) Descendants ¶ added in v0.17.6
func (_m *Snapshot) Descendants() ([]flow.Identifier, error)
Descendants provides a mock function with given fields:
func (*Snapshot) Epochs ¶
func (_m *Snapshot) Epochs() protocol.EpochQuery
Epochs provides a mock function with given fields:
func (*Snapshot) Identities ¶
func (_m *Snapshot) Identities(selector flow.IdentityFilter) (flow.IdentityList, error)
Identities provides a mock function with given fields: selector
func (*Snapshot) Params ¶ added in v0.23.2
func (_m *Snapshot) Params() protocol.GlobalParams
Params provides a mock function with given fields:
func (*Snapshot) Phase ¶
func (_m *Snapshot) Phase() (flow.EpochPhase, error)
Phase provides a mock function with given fields:
func (*Snapshot) QuorumCertificate ¶ added in v0.15.0
func (_m *Snapshot) QuorumCertificate() (*flow.QuorumCertificate, error)
QuorumCertificate provides a mock function with given fields:
func (*Snapshot) RandomSource ¶ added in v0.25.0
RandomSource provides a mock function with given fields:
func (*Snapshot) SealedResult ¶ added in v0.15.0
SealedResult provides a mock function with given fields:
func (*Snapshot) SealingSegment ¶ added in v0.15.0
func (_m *Snapshot) SealingSegment() (*flow.SealingSegment, error)
SealingSegment provides a mock function with given fields:
func (*Snapshot) VersionBeacon ¶ added in v0.31.0
func (_m *Snapshot) VersionBeacon() (*flow.SealedVersionBeacon, error)
VersionBeacon provides a mock function with given fields:
type State ¶
State is an autogenerated mock type for the State type
func NewState ¶ added in v0.26.1
func NewState(t mockConstructorTestingTNewState) *State
NewState creates a new instance of State. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*State) AtBlockID ¶
func (_m *State) AtBlockID(blockID flow.Identifier) protocol.Snapshot
AtBlockID provides a mock function with given fields: blockID