node_builder

type ObserverServiceBuilder struct {
	*cmd.FlowNodeBuilder
	*ObserverServiceConfig

	LibP2PNode           p2p.LibP2PNode
	FollowerState        stateprotocol.FollowerState
	SyncCore             *chainsync.Core
	RpcEng               *rpc.Engine
	TransactionTimings   *stdmap.TransactionTimings
	FollowerDistributor  *pubsub.FollowerDistributor
	Committee            hotstuff.DynamicCommittee
	Finalized            *flow.Header
	Pending              []*flow.Header
	FollowerCore         module.HotStuffFollower
	ExecutionIndexer     *indexer.Indexer
	ExecutionIndexerCore *indexer.IndexerCore
	TxResultsIndex       *index.TransactionResultsIndex
	IndexerDependencies  *cmd.DependencyList
	VersionControl       *version.VersionControl
	StopControl          *stop.StopControl

	ExecutionDataDownloader   execution_data.Downloader
	ExecutionDataRequester    state_synchronization.ExecutionDataRequester
	ExecutionDataStore        execution_data.ExecutionDataStore
	ExecutionDataBlobstore    blobs.Blobstore
	ExecutionDataPruner       *pruner.Pruner
	ExecutionDatastoreManager edstorage.DatastoreManager
	ExecutionDataTracker      tracker.Storage

	RegistersAsyncStore *execution.RegistersAsyncStore
	Reporter            *index.Reporter
	EventsIndex         *index.EventsIndex
	ScriptExecutor      *backend.ScriptExecutor

	// 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
	FollowerEng    *follower.ComplianceEngine
	SyncEng        *synceng.Engine
	StateStreamEng *statestreambackend.Engine

	TransactionMetrics *metrics.TransactionCollector
	RestMetrics        *metrics.RestCollector
	AccessMetrics      module.AccessMetrics
	// contains filtered or unexported fields
}

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

type Option func(*ObserverServiceConfig)