Struct ConsolidateTask

pub struct ConsolidateTask {
    pub client: Arc<EngineClient>,
    pub cfg: Arc<RollupConfig>,
    pub attributes: OpAttributesWithParent,
    pub is_attributes_derived: bool,
}

The ConsolidateTask attempts to consolidate the engine state using the specified payload attributes and the oldest unsafe head.

If consolidation fails, payload attributes processing is attempted using the BuildTask.

Fields

client: Arc<EngineClient>

The engine client.

cfg: Arc<RollupConfig>

The RollupConfig.

attributes: OpAttributesWithParent

The OpAttributesWithParent to instruct the execution layer to build.

is_attributes_derived: bool

Whether or not the payload was derived, or created by the sequencer.

Implementations

impl ConsolidateTask

pub const fn new( client: Arc<EngineClient>, config: Arc<RollupConfig>, attributes: OpAttributesWithParent, is_attributes_derived: bool, ) -> Self

Creates a new ConsolidateTask.

pub async fn consolidate( &self, state: &mut EngineState, ) -> Result<(), ConsolidateTaskError>

Attempts consolidation on the engine state.

Trait Implementations

impl Clone for ConsolidateTask

fn clone(&self) -> ConsolidateTask

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsolidateTask

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

Formats the value using the given formatter.

impl EngineTaskExt for ConsolidateTask

type Output = ()

The output type of the task.

type Error = ConsolidateTaskError

The error type of the task.

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 mut EngineState, ) -> Pin<Box<dyn Future<Output = Result<(), ConsolidateTaskError>> + 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.