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(clusterID flow.ChainID) (*clusterkv.State, *bstorage.Headers, *bstorage.ClusterPayloads, ...)
• type EpochComponentsFactory
  • func NewEpochComponentsFactory(me module.Local, pools *epochs.TransactionPools, builder *BuilderFactory, ...) *EpochComponentsFactory
  • func (factory *EpochComponentsFactory) Create(epoch protocol.Epoch) (state cluster.State, proposal module.Engine, sync module.Engine, ...)
• type HotStuffFactory
  • func NewHotStuffFactory(log zerolog.Logger, me module.Local, db *badger.DB, protoState protocol.State, ...) (*HotStuffFactory, error)
  • func (f *HotStuffFactory) Create(clusterID flow.ChainID, cluster flow.IdentityList, clusterState cluster.State, ...) (*hotstuff.EventLoop, error)
• type ProposalEngineFactory
  • func NewProposalEngineFactory(log zerolog.Logger, net module.Network, me module.Local, ...) (*ProposalEngineFactory, error)
  • func (f *ProposalEngineFactory) Create(clusterState cluster.State, headers storage.Headers, ...) (*proposal.Engine, error)
• type SyncEngineFactory
  • func NewSyncEngineFactory(log zerolog.Logger, metrics module.EngineMetrics, net module.Network, ...) (*SyncEngineFactory, error)
  • func (f *SyncEngineFactory) Create(participants flow.IdentityList, state cluster.State, ...) (*chainsync.Core, *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,
	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(clusterID flow.ChainID) (
	*clusterkv.State,
	*bstorage.Headers,
	*bstorage.ClusterPayloads,
	*bstorage.ClusterBlocks,
	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,
	proposal *ProposalEngineFactory,
	sync *SyncEngineFactory,
) *EpochComponentsFactory

func (*EpochComponentsFactory) Create

func (factory *EpochComponentsFactory) Create(
	epoch protocol.Epoch,
) (
	state cluster.State,
	proposal module.Engine,
	sync module.Engine,
	hotstuff module.HotStuff,
	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,
	opts ...consensus.Option,
) (*HotStuffFactory, error)

func (*HotStuffFactory) Create

func (f *HotStuffFactory) Create(
	clusterID flow.ChainID,
	cluster flow.IdentityList,
	clusterState cluster.State,
	headers storage.Headers,
	payloads storage.ClusterPayloads,
	seed []byte,
	builder module.Builder,
	updater module.Finalizer,
	communicator hotstuff.Communicator,
	rootHeader *flow.Header,
	rootQC *flow.QuorumCertificate,
) (*hotstuff.EventLoop, error)

type ProposalEngineFactory

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

func NewProposalEngineFactory

func NewProposalEngineFactory(
	log zerolog.Logger,
	net module.Network,
	me module.Local,
	colMetrics module.CollectionMetrics,
	engMetrics module.EngineMetrics,
	mempoolMetrics module.MempoolMetrics,
	protoState protocol.State,
	transactions storage.Transactions,
) (*ProposalEngineFactory, error)

NewFactory returns a new collection proposal engine factory.

func (*ProposalEngineFactory) Create

func (f *ProposalEngineFactory) Create(clusterState cluster.State, headers storage.Headers, payloads storage.ClusterPayloads) (*proposal.Engine, error)

type SyncEngineFactory

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

func NewSyncEngineFactory

func NewSyncEngineFactory(
	log zerolog.Logger,
	metrics module.EngineMetrics,
	net module.Network,
	me module.Local,
	conf chainsync.Config,
) (*SyncEngineFactory, error)

func (*SyncEngineFactory) Create

func (f *SyncEngineFactory) Create(
	participants flow.IdentityList,
	state cluster.State,
	blocks storage.ClusterBlocks,
	comp network.Engine,
) (*chainsync.Core, *syncengine.Engine, error)