Struct L1Traversal

pub struct L1Traversal<Provider: ChainProvider> {
    pub block: Option<BlockInfo>,
    pub data_source: Provider,
    pub done: bool,
    pub system_config: SystemConfig,
    pub rollup_config: Arc<RollupConfig>,
}

The L1Traversal stage of the derivation pipeline.

This stage sits at the bottom of the pipeline, holding a handle to the data source (a ChainProvider implementation) and the current L1 BlockInfo in the pipeline, which are used to traverse the L1 chain. When the L1Traversal stage is advanced, it fetches the next L1 BlockInfo from the data source and updates the SystemConfig with the receipts from the block.

Fields

block: Option<BlockInfo>

The current block in the traversal stage.

data_source: Provider

The data source for the traversal stage.

done: bool

Signals whether or not the traversal stage is complete.

system_config: SystemConfig

The system config.

rollup_config: Arc<RollupConfig>

A reference to the rollup config.

Implementations

impl<F: ChainProvider> L1Traversal<F>

pub fn new(data_source: F, cfg: Arc<RollupConfig>) -> Self

Creates a new L1Traversal instance.

Trait Implementations

impl<Provider: Clone + ChainProvider> Clone for L1Traversal<Provider>

fn clone(&self) -> L1Traversal<Provider>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Provider: Debug + ChainProvider> Debug for L1Traversal<Provider>

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

Formats the value using the given formatter.

impl<F: ChainProvider + Send> L1RetrievalProvider for L1Traversal<F>

fn batcher_addr(&self) -> Address

Returns the batcher Address from the op_alloy_genesis::SystemConfig.

fn next_l1_block<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = PipelineResult<Option<BlockInfo>>> + Send + 'async_trait>>

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

Returns the next L1 BlockInfo in the L1Traversal stage, if the stage is not complete. This function can only be called once while the stage is in progress, and will return None on subsequent calls unless the stage is reset or complete. If the stage is complete and the BlockInfo has been consumed, an PipelineError::Eof error is returned.

impl<F: ChainProvider + Send> OriginAdvancer for L1Traversal<F>

fn advance_origin<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = PipelineResult<()>> + Send + 'async_trait>>

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

Advances the internal state of the L1Traversal stage to the next L1 block. This function fetches the next L1 BlockInfo from the data source and updates the SystemConfig with the receipts from the block.

impl<F: ChainProvider> OriginProvider for L1Traversal<F>

fn origin(&self) -> Option<BlockInfo>

Returns the optional L1 BlockInfo origin.

impl<F: ChainProvider + Send> SignalReceiver for L1Traversal<F>

fn signal<'life0, 'async_trait>( &'life0 mut self, signal: Signal, ) -> Pin<Box<dyn Future<Output = PipelineResult<()>> + Send + 'async_trait>>

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

Receives a signal from the driver.