Documentation
¶
Index ¶
- type Engine
- func (e *Engine) OnCollection(originID flow.Identifier, entity flow.Entity)
- func (e *Engine) OnFinalizedBlock(hb *model.Block)
- func (e *Engine) Process(_ channels.Channel, originID flow.Identifier, event interface{}) error
- func (e *Engine) ProcessLocal(event interface{}) error
- func (e *Engine) Start(parent irrecoverable.SignalerContext)
- func (e *Engine) Submit(_ channels.Channel, originID flow.Identifier, event interface{})
- func (e *Engine) SubmitLocal(event interface{})
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
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
func (*Engine) OnCollection ¶
func (e *Engine) OnCollection(originID flow.Identifier, entity flow.Entity)
OnCollection handles the response of the a collection request made earlier when a block was received. No errors expected during normal operations.
func (*Engine) OnFinalizedBlock ¶
OnFinalizedBlock is called by the follower engine after a block has been finalized and the state has been updated
func (*Engine) Process ¶
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.
func (*Engine) ProcessLocal ¶
ProcessLocal processes an event originating on the local node.
func (*Engine) Start ¶ added in v0.27.3
func (e *Engine) Start(parent irrecoverable.SignalerContext)
func (*Engine) Submit ¶
func (e *Engine) Submit(_ channels.Channel, originID flow.Identifier, event interface{})
Submit submits the given event from the node with the given origin ID for processing in a non-blocking manner. It returns instantly and logs a potential processing error internally when done.
func (*Engine) SubmitLocal ¶
func (e *Engine) SubmitLocal(event interface{})
SubmitLocal submits an event originating on the local node.
Source Files
Directories