ingestion

Documentation

Index

• type Engine
  • func New(log zerolog.Logger, net network.EngineRegistry, state protocol.State, ...) (*Engine, error)
  • func (e *Engine) OnCollection(originID flow.Identifier, entity flow.Entity)
  • func (e *Engine) OnFinalizedBlock(*model.Block)
  • func (e *Engine) Process(_ channels.Channel, originID flow.Identifier, event interface{}) error

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,
	request module.Requester,
	blocks storage.Blocks,
	headers storage.Headers,
	collections storage.Collections,
	transactions storage.Transactions,
	executionResults storage.ExecutionResults,
	executionReceipts storage.ExecutionReceipts,
	collectionExecutedMetric module.CollectionExecutedMetric,
	finalizedProcessedHeight storage.ConsumerProgress,
	lastFullBlockHeight *counters.PersistentStrictMonotonicCounter,
	txErrorMessagesCore *tx_error_messages.TxErrorMessagesCore,
) (*Engine, error)

New creates a new access ingestion engine

No errors are expected during normal operation.

func (*Engine) OnCollection

func (e *Engine) OnCollection(originID flow.Identifier, entity flow.Entity)

OnCollection handles the response of the collection request made earlier when a block was received. No errors expected during normal operations.

func (*Engine) OnFinalizedBlock

func (e *Engine) OnFinalizedBlock(*model.Block)

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.

func (*Engine) Process

func (e *Engine) Process(_ 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.