Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BuilderFactory ¶
type BuilderFactory struct {
// contains filtered or unexported fields
}
func NewBuilderFactory ¶
func (*BuilderFactory) Create ¶
func (f *BuilderFactory) Create( clusterState clusterstate.State, clusterHeaders storage.Headers, clusterPayloads storage.ClusterPayloads, pool mempool.Transactions, epoch uint64, ) (module.Builder, *finalizer.FinalizerPebble, error)
type ClusterStateFactory ¶
type ClusterStateFactory struct {
// contains filtered or unexported fields
}
func NewClusterStateFactory ¶
func NewClusterStateFactory( db *pebble.DB, metrics module.CacheMetrics, tracer module.Tracer, ) (*ClusterStateFactory, error)
func (*ClusterStateFactory) Create ¶
func (f *ClusterStateFactory) Create(stateRoot *clusterkv.StateRoot) ( *clusterkv.MutableState, *bstorage.Headers, *bstorage.ClusterPayloads, *bstorage.ClusterBlocks, error, )
type ComplianceEngineFactory ¶ added in v0.29.0
type ComplianceEngineFactory struct {
// contains filtered or unexported fields
}
func NewComplianceEngineFactory ¶ added in v0.29.0
func NewComplianceEngineFactory( log zerolog.Logger, net network.EngineRegistry, me module.Local, colMetrics module.CollectionMetrics, engMetrics module.EngineMetrics, mempoolMetrics module.MempoolMetrics, protoState protocol.State, transactions storage.Transactions, config modulecompliance.Config, ) (*ComplianceEngineFactory, error)
NewComplianceEngineFactory returns a new collection compliance engine factory.
func (*ComplianceEngineFactory) Create ¶ added in v0.29.0
func (f *ComplianceEngineFactory) Create( hotstuffMetrics module.HotstuffMetrics, notifier hotstuff.ProposalViolationConsumer, clusterState cluster.MutableState, headers storage.Headers, payloads storage.ClusterPayloads, syncCore *chainsync.Core, hot module.HotStuff, voteAggregator hotstuff.VoteAggregator, timeoutAggregator hotstuff.TimeoutAggregator, validator hotstuff.Validator, ) (*compliance.Engine, error)
type EpochComponentsFactory ¶
type EpochComponentsFactory struct {
// contains filtered or unexported fields
}
func NewEpochComponentsFactory ¶
func NewEpochComponentsFactory( me module.Local, pools *epochs.TransactionPools, builder *BuilderFactory, state *ClusterStateFactory, hotstuff *HotStuffFactory, compliance *ComplianceEngineFactory, syncCore *SyncCoreFactory, sync *SyncEngineFactory, messageHub *MessageHubFactory, ) *EpochComponentsFactory
func (*EpochComponentsFactory) Create ¶
func (factory *EpochComponentsFactory) Create( epoch protocol.Epoch, ) ( state cluster.State, compliance component.Component, sync module.ReadyDoneAware, hotstuff module.HotStuff, voteAggregator hotstuff.VoteAggregator, timeoutAggregator hotstuff.TimeoutAggregator, messageHub component.Component, err error, )
type HotStuffFactory ¶
type HotStuffFactory struct {
// contains filtered or unexported fields
}
func NewHotStuffFactory ¶
func NewHotStuffFactory( log zerolog.Logger, me module.Local, db *pebble.DB, protoState protocol.State, engineMetrics module.EngineMetrics, mempoolMetrics module.MempoolMetrics, createMetrics HotStuffMetricsFunc, opts ...consensus.Option, ) (*HotStuffFactory, error)
func (*HotStuffFactory) CreateModules ¶ added in v0.23.9
func (f *HotStuffFactory) CreateModules( epoch protocol.Epoch, cluster protocol.Cluster, clusterState cluster.State, headers storage.Headers, payloads storage.ClusterPayloads, updater module.Finalizer, ) (*consensus.HotstuffModules, module.HotstuffMetrics, error)
type HotStuffMetricsFunc ¶ added in v0.20.0
type HotStuffMetricsFunc func(chainID flow.ChainID) module.HotstuffMetrics
type MessageHubFactory ¶ added in v0.29.0
type MessageHubFactory struct {
// contains filtered or unexported fields
}
func NewMessageHubFactory ¶ added in v0.29.0
func NewMessageHubFactory(log zerolog.Logger, net network.EngineRegistry, me module.Local, engineMetrics module.EngineMetrics, protoState protocol.State) *MessageHubFactory
func (*MessageHubFactory) Create ¶ added in v0.29.0
func (f *MessageHubFactory) Create( clusterState cluster.State, payloads storage.ClusterPayloads, hotstuff module.HotStuff, compliance collection.Compliance, hotstuffModules *consensus.HotstuffModules, ) (*message_hub.MessageHub, error)
type SyncCoreFactory ¶ added in v0.29.0
type SyncCoreFactory struct {
// contains filtered or unexported fields
}
func NewSyncCoreFactory ¶ added in v0.29.0
type SyncEngineFactory ¶
type SyncEngineFactory struct {
// contains filtered or unexported fields
}
func NewSyncEngineFactory ¶
func NewSyncEngineFactory( log zerolog.Logger, metrics module.EngineMetrics, net network.EngineRegistry, me module.Local, ) (*SyncEngineFactory, error)
func (*SyncEngineFactory) Create ¶
func (f *SyncEngineFactory) Create( participants flow.IdentityList, state cluster.State, blocks storage.ClusterBlocks, core *chainsync.Core, comp collection.Compliance, ) (*syncengine.Engine, error)
Click to show internal directories.
Click to hide internal directories.