Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MatchingCore ¶ added in v0.17.6
type MatchingCore interface {
// ProcessReceipt processes a new execution receipt in blocking way.
// Returns:
// * exception in case of unexpected error
// * nil - successfully processed receipt
ProcessReceipt(receipt *flow.ExecutionReceipt) error
// ProcessFinalizedBlock processes finalization events in blocking way.
// Returns:
// * exception in case of unexpected error
// * nil - successfully processed finalized block
ProcessFinalizedBlock(finalizedBlockID flow.Identifier) error
}
MatchingCore collects inbound receipts from Execution Node for potential inclusion in future blocks. Implementations of MatchingCore are generally NOT concurrency safe.
type SealingCore ¶ added in v0.17.6
type SealingCore interface {
// ProcessApproval processes approval in blocking way. Concurrency safe.
// Returns:
// * exception in case of unexpected error
// * nil - successfully processed result approval
ProcessApproval(approval *flow.ResultApproval) error
// ProcessIncorporatedResult processes incorporated result in blocking way. Concurrency safe.
// Returns:
// * exception in case of unexpected error
// * nil - successfully processed incorporated result
ProcessIncorporatedResult(result *flow.IncorporatedResult) error
// ProcessFinalizedBlock processes finalization events in blocking way. Concurrency safe.
// Returns:
// * exception in case of unexpected error
// * nil - successfully processed finalized block
ProcessFinalizedBlock(finalizedBlockID flow.Identifier) error
}
SealingCore processes incoming execution results and result approvals. Accepts `flow.IncorporatedResult` to start processing approvals for particular result. Whenever enough approvals are collected produces a candidate seal and adds it to the mempool. Implementations of SealingCore are _concurrency safe_.
Click to show internal directories.
Click to hide internal directories.