factories

Documentation

Index

• type BuilderFactory
  • func NewBuilderFactory(db *badger.DB, mainChainHeaders storage.Headers, trace module.Tracer, ...) (*BuilderFactory, error)
  • func (f *BuilderFactory) Create(clusterHeaders storage.Headers, clusterPayloads storage.ClusterPayloads, ...) (module.Builder, *finalizer.Finalizer, error)
• type ClusterStateFactory
  • func NewClusterStateFactory(db *badger.DB, metrics module.CacheMetrics, tracer module.Tracer) (*ClusterStateFactory, error)
  • func (f *ClusterStateFactory) Create(stateRoot *clusterkv.StateRoot) (*clusterkv.MutableState, *bstorage.Headers, *bstorage.ClusterPayloads, ...)
• type ComplianceEngineFactory
  • func NewComplianceEngineFactory(log zerolog.Logger, net network.Network, me module.Local, ...) (*ComplianceEngineFactory, error)
  • func (f *ComplianceEngineFactory) Create(hotstuffMetrics module.HotstuffMetrics, clusterState cluster.MutableState, ...) (*compliance.Engine, error)
• type EpochComponentsFactory
  • func NewEpochComponentsFactory(me module.Local, pools *epochs.TransactionPools, builder *BuilderFactory, ...) *EpochComponentsFactory
  • func (factory *EpochComponentsFactory) Create(epoch protocol.Epoch) (state cluster.State, compliance component.Component, ...)
• type HotStuffFactory
  • func NewHotStuffFactory(log zerolog.Logger, me module.Local, db *badger.DB, protoState protocol.State, ...) (*HotStuffFactory, error)
  • func (f *HotStuffFactory) Create(cluster protocol.Cluster, clusterState cluster.State, ...) (module.HotStuff, error)
  • func (f *HotStuffFactory) CreateModules(epoch protocol.Epoch, cluster protocol.Cluster, clusterState cluster.State, ...) (*consensus.HotstuffModules, module.HotstuffMetrics, error)
• type HotStuffMetricsFunc
• type MessageHubFactory
  • func NewMessageHubFactory(log zerolog.Logger, net network.Network, me module.Local, ...) *MessageHubFactory
  • func (f *MessageHubFactory) Create(clusterState cluster.State, payloads storage.ClusterPayloads, ...) (*message_hub.MessageHub, error)
• type SyncCoreFactory
  • func NewSyncCoreFactory(log zerolog.Logger, conf chainsync.Config) (*SyncCoreFactory, error)
  • func (f *SyncCoreFactory) Create(chainID flow.ChainID) (*chainsync.Core, error)
• type SyncEngineFactory
  • func NewSyncEngineFactory(log zerolog.Logger, metrics module.EngineMetrics, net network.Network, ...) (*SyncEngineFactory, error)
  • func (f *SyncEngineFactory) Create(participants flow.IdentityList, state cluster.State, ...) (*syncengine.Engine, error)

Types

type BuilderFactory

type BuilderFactory struct {
	// contains filtered or unexported fields
}

func NewBuilderFactory

func NewBuilderFactory(
	db *badger.DB,
	mainChainHeaders storage.Headers,
	trace module.Tracer,
	metrics module.CollectionMetrics,
	pusher network.Engine,
	log zerolog.Logger,
	opts ...builder.Opt,
) (*BuilderFactory, error)

func (*BuilderFactory) Create

func (f *BuilderFactory) Create(
	clusterHeaders storage.Headers,
	clusterPayloads storage.ClusterPayloads,
	pool mempool.Transactions,
) (module.Builder, *finalizer.Finalizer, error)

type ClusterStateFactory

type ClusterStateFactory struct {
	// contains filtered or unexported fields
}

func NewClusterStateFactory

func NewClusterStateFactory(
	db *badger.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

type ComplianceEngineFactory struct {
	// contains filtered or unexported fields
}

func NewComplianceEngineFactory

func NewComplianceEngineFactory(
	log zerolog.Logger,
	net network.Network,
	me module.Local,
	colMetrics module.CollectionMetrics,
	engMetrics module.EngineMetrics,
	mempoolMetrics module.MempoolMetrics,
	protoState protocol.State,
	transactions storage.Transactions,
	complianceOpts ...modulecompliance.Opt,
) (*ComplianceEngineFactory, error)

NewComplianceEngineFactory returns a new collection compliance engine factory.

func (*ComplianceEngineFactory) Create

func (f *ComplianceEngineFactory) Create(
	hotstuffMetrics module.HotstuffMetrics,
	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 *badger.DB,
	protoState protocol.State,
	engineMetrics module.EngineMetrics,
	mempoolMetrics module.MempoolMetrics,
	createMetrics HotStuffMetricsFunc,
	opts ...consensus.Option,
) (*HotStuffFactory, error)

func (*HotStuffFactory) Create

func (f *HotStuffFactory) Create(
	cluster protocol.Cluster,
	clusterState cluster.State,
	metrics module.HotstuffMetrics,
	builder module.Builder,
	headers storage.Headers,
	hotstuffModules *consensus.HotstuffModules,
) (module.HotStuff, error)

func (*HotStuffFactory) CreateModules

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

type HotStuffMetricsFunc func(chainID flow.ChainID) module.HotstuffMetrics

type MessageHubFactory

type MessageHubFactory struct {
	// contains filtered or unexported fields
}

func NewMessageHubFactory

func NewMessageHubFactory(log zerolog.Logger,
	net network.Network,
	me module.Local,
	engineMetrics module.EngineMetrics,
	protoState protocol.State) *MessageHubFactory

func (*MessageHubFactory) Create

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

type SyncCoreFactory struct {
	// contains filtered or unexported fields
}

func NewSyncCoreFactory

func NewSyncCoreFactory(
	log zerolog.Logger,
	conf chainsync.Config,
) (*SyncCoreFactory, error)

func (*SyncCoreFactory) Create

func (f *SyncCoreFactory) Create(chainID flow.ChainID) (*chainsync.Core, error)

type SyncEngineFactory

type SyncEngineFactory struct {
	// contains filtered or unexported fields
}

func NewSyncEngineFactory

func NewSyncEngineFactory(
	log zerolog.Logger,
	metrics module.EngineMetrics,
	net network.Network,
	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)