Struct ForkchoiceTask

pub struct ForkchoiceTask {
    pub client: Arc<EngineClient>,
    pub rollup: Arc<RollupConfig>,
    pub envelope: Option<OpAttributesWithParent>,
    pub state_update: EngineSyncStateUpdate,
}

The ForkchoiceTask executes an engine_forkchoiceUpdated call with the current EngineState’s forkchoice, and no payload attributes.

Fields

client: Arc<EngineClient>

The engine client.

rollup: Arc<RollupConfig>

The rollup config.

envelope: Option<OpAttributesWithParent>

Optional payload attributes to be used for the forkchoice update.

state_update: EngineSyncStateUpdate

The sync state update to apply to the engine state.

Implementations

impl ForkchoiceTask

pub const fn new( client: Arc<EngineClient>, rollup: Arc<RollupConfig>, state_update: EngineSyncStateUpdate, payload_attributes: Option<OpAttributesWithParent>, ) -> Self

Creates a new ForkchoiceTask.

Trait Implementations

impl Clone for ForkchoiceTask

fn clone(&self) -> ForkchoiceTask

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ForkchoiceTask

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EngineTaskExt for ForkchoiceTask

type Output = Option<PayloadId>

The output type of the task.

type Error = ForkchoiceTaskError

The error type of the task.

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 mut EngineState, ) -> Pin<Box<dyn Future<Output = Result<Self::Output, ForkchoiceTaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes the task, taking a shared lock on the engine state and self.