node_builder

type AccessNodeConfig struct {
	ExecutionNodeAddress string // deprecated
	HistoricalAccessRPCs []access.AccessAPIClient

	PublicNetworkConfig      PublicNetworkConfig
	TxResultCacheSize        uint
	TxErrorMessagesCacheSize uint
	// contains filtered or unexported fields
}

type FlowAccessNodeBuilder struct {
	*cmd.FlowNodeBuilder
	*AccessNodeConfig

	// components
	FollowerState                protocol.FollowerState
	SyncCore                     *chainsync.Core
	RpcEng                       *rpc.Engine
	FollowerDistributor          *consensuspubsub.FollowerDistributor
	CollectionRPC                access.AccessAPIClient
	TransactionTimings           *stdmap.TransactionTimings
	CollectionsToMarkFinalized   *stdmap.Times
	CollectionsToMarkExecuted    *stdmap.Times
	BlocksToMarkExecuted         *stdmap.Times
	BlockTransactions            *stdmap.IdentifierMap
	TransactionMetrics           *metrics.TransactionCollector
	TransactionValidationMetrics *metrics.TransactionValidationCollector
	RestMetrics                  *metrics.RestCollector
	AccessMetrics                module.AccessMetrics
	PingMetrics                  module.PingMetrics
	Committee                    hotstuff.DynamicCommittee
	Finalized                    *flow.Header // latest finalized block that the node knows of at startup time
	Pending                      []*flow.Header
	FollowerCore                 module.HotStuffFollower
	Validator                    hotstuff.Validator
	ExecutionDataDownloader      execution_data.Downloader
	PublicBlobService            network.BlobService
	ExecutionDataRequester       state_synchronization.ExecutionDataRequester
	ExecutionDataStore           execution_data.ExecutionDataStore
	ExecutionDataBlobstore       blobs.Blobstore
	ExecutionDataCache           *execdatacache.ExecutionDataCache
	ExecutionIndexer             *indexer.Indexer
	ExecutionIndexerCore         *indexer.IndexerCore
	ScriptExecutor               *backend.ScriptExecutor
	RegistersAsyncStore          *execution.RegistersAsyncStore
	Reporter                     *index.Reporter
	EventsIndex                  *index.EventsIndex
	TxResultsIndex               *index.TransactionResultsIndex
	IndexerDependencies          *cmd.DependencyList

	ExecutionDataPruner       *pruner.Pruner
	ExecutionDatastoreManager edstorage.DatastoreManager
	ExecutionDataTracker      tracker.Storage
	VersionControl            *version.VersionControl
	StopControl               *stop.StopControl

	// The sync engine participants provider is the libp2p peer store for the access node
	// which is not available until after the network has started.
	// Hence, a factory function that needs to be called just before creating the sync engine
	SyncEngineParticipantsProviderFactory func() module.IdentifierProvider

	// engines
	IngestEng      *ingestion.Engine
	RequestEng     *requester.Engine
	FollowerEng    *followereng.ComplianceEngine
	SyncEng        *synceng.Engine
	StateStreamEng *statestreambackend.Engine
	// contains filtered or unexported fields
}

type PublicNetworkConfig struct {
	// NetworkKey crypto.PublicKey // TODO: do we need a different key for the public network?
	BindAddress string
	Network     network.EngineRegistry
	Metrics     module.NetworkMetrics
}