Struct FrameQueue

pub struct FrameQueue<P>
where
    P: FrameQueueProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug,
{
    pub prev: P,
    /* private fields */
}

The FrameQueue stage of the derivation pipeline. This stage takes the output of the L1Retrieval stage and parses it into frames.

Fields

prev: P

The previous stage in the pipeline.

Implementations

impl<P> FrameQueue<P>

where P: FrameQueueProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug,

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

Create a new FrameQueue stage with the given previous L1Retrieval stage.

pub fn is_holocene_active(&self, origin: BlockInfo) -> bool

Returns if holocene is active.

pub fn prune(&mut self, origin: BlockInfo)

Prunes frames if Holocene is active.

pub async fn load_frames(&mut self) -> PipelineResult<()>

Loads more frames into the FrameQueue.

Trait Implementations

impl<P> Debug for FrameQueue<P>

where P: FrameQueueProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug + Debug,

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

Formats the value using the given formatter.

impl<P> NextFrameProvider for FrameQueue<P>

where P: FrameQueueProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

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

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

Retrieves the next Frame from the FrameQueue stage.

impl<P> OriginAdvancer for FrameQueue<P>

where P: FrameQueueProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

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 lowest stage to the next l1 origin. This method is the equivalent of the reference implementation advance_l1_block.

impl<P> OriginProvider for FrameQueue<P>

where P: FrameQueueProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug,

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

Returns the optional L1 BlockInfo origin.

impl<P> SignalReceiver for FrameQueue<P>

where P: FrameQueueProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

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.