Documentation
¶
Overview ¶
Package finalized_indexer implements a modular ingestion engine responsible for orchestrating the processing of finalized blockchain data and receiving execution receipts from the network.
The Engine coordinates several internal workers, each dedicated to a specific task:
- Receiving and persisting execution receipts from the network.
- Subscribing to finalized block events.
- Synchronizing collections associated with finalized blocks.
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
}
func New ¶
func New( log zerolog.Logger, net network.EngineRegistry, receipts storage.ExecutionReceipts, collectionExecutedMetric module.CollectionExecutedMetric, ) (*Engine, error)
func (*Engine) Process ¶
func (e *Engine) Process(chanName channels.Channel, originID flow.Identifier, event interface{}) error
Process processes the given event from the node with the given origin ID in a blocking manner. It returns the potential processing error when done.
No errors are expected during normal operations.
Source Files
Click to show internal directories.
Click to hide internal directories.