Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Engine ¶
type Engine struct {
*component.ComponentManager
// contains filtered or unexported fields
}
Engine represents the ingestion engine, used to funnel data from other nodes to a centralized location that can be queried by a user
No errors are expected during normal operation.
func New ¶
func New( log zerolog.Logger, net network.EngineRegistry, state protocol.State, me module.Local, blocks storage.Blocks, executionResults storage.ExecutionResults, executionReceipts storage.ExecutionReceipts, finalizedProcessedHeight storage.ConsumerProgressInitializer, collectionSyncer *collections.Syncer, collectionIndexer *collections.Indexer, collectionExecutedMetric module.CollectionExecutedMetric, txErrorMessagesCore *tx_error_messages.TxErrorMessagesCore, ) (*Engine, error)
New creates a new access ingestion engine
No errors are expected during normal operation.
func (*Engine) OnFinalizedBlock ¶
OnFinalizedBlock is called by the follower engine after a block has been finalized and the state has been updated. Receives block finalized events from the finalization distributor and forwards them to the finalizedBlockConsumer.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.