Struct AttributesQueue

pub struct AttributesQueue<P, AB>
where
    P: AttributesProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug,
    AB: AttributesBuilder + Debug,
{ /* private fields */ }

AttributesQueue accepts batches from the BatchQueue stage and transforms them into OpPayloadAttributes.

The outputted payload attributes cannot be buffered because each batch->attributes transformation pulls in data about the current L2 safe head.

AttributesQueue also buffers batches that have been output because multiple batches can be created at once.

This stage can be reset by clearing its batch buffer. This stage does not need to retain any references to L1 blocks.

Implementations

impl<P, AB> AttributesQueue<P, AB>

where P: AttributesProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug, AB: AttributesBuilder + Debug,

pub const fn new( cfg: Arc<RollupConfig>, prev: P, builder: AB, ) -> AttributesQueue<P, AB>

Create a new AttributesQueue stage.

pub async fn load_batch( &mut self, parent: L2BlockInfo, ) -> Result<SingleBatch, PipelineErrorKind>

Loads a SingleBatch from the AttributesProvider if needed.

pub async fn next_attributes( &mut self, parent: L2BlockInfo, ) -> Result<OpAttributesWithParent, PipelineErrorKind>

Returns the next OpAttributesWithParent from the current batch.

pub async fn create_next_attributes( &mut self, batch: SingleBatch, parent: L2BlockInfo, ) -> Result<OpPayloadAttributes, PipelineErrorKind>

Creates the next attributes, transforming a SingleBatch into OpPayloadAttributes. This sets no_tx_pool and appends the batched txs to the attributes tx list.

Trait Implementations

impl<P, AB> Debug for AttributesQueue<P, AB>

where P: Debug + AttributesProvider + OriginAdvancer + OriginProvider + SignalReceiver, AB: Debug + AttributesBuilder,

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

Formats the value using the given formatter.

impl<P, AB> NextAttributes for AttributesQueue<P, AB>

where P: AttributesProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug + Send, AB: AttributesBuilder + Debug + Send,

fn next_attributes<'life0, 'async_trait>( &'life0 mut self, parent: L2BlockInfo, ) -> Pin<Box<dyn Future<Output = Result<OpAttributesWithParent, PipelineErrorKind>> + Send + 'async_trait>>

where 'life0: 'async_trait, AttributesQueue<P, AB>: 'async_trait,

Returns the next OpAttributesWithParent from the current batch.

impl<P, AB> OriginAdvancer for AttributesQueue<P, AB>

where P: AttributesProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug + Send, AB: AttributesBuilder + Debug + Send,

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

where 'life0: 'async_trait, AttributesQueue<P, AB>: 'async_trait,

Advances the internal state of the lowest stage to the next l1 origin. This method is the equivalent of the reference implementation advance_l1_block.

impl<P, AB> OriginProvider for AttributesQueue<P, AB>

where P: AttributesProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug, AB: AttributesBuilder + Debug,

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

Returns the optional L1 BlockInfo origin.

impl<P, AB> SignalReceiver for AttributesQueue<P, AB>

where P: AttributesProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug, AB: AttributesBuilder + Send + Debug,

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

where 'life0: 'async_trait, AttributesQueue<P, AB>: 'async_trait,

Receives a signal from the driver.