Struct ChannelProvider

pub struct ChannelProvider<P>
where
    P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug,
{ /* private fields */ }

The ChannelProvider stage is a mux between the ChannelBank and ChannelAssembler stages.

Rules: When Holocene is not active, the ChannelBank is used. When Holocene is active, the ChannelAssembler is used.

Implementations

impl<P> ChannelProvider<P>

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

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

Creates a new ChannelProvider with the given configuration and previous stage.

Trait Implementations

impl<P> ChannelReaderProvider for ChannelProvider<P>

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

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

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

Pulls the next piece of data from the channel bank. Note that it attempts to pull data out of the channel bank prior to loading data in (unlike most other stages). This is to ensure maintain consistency around channel bank pruning which depends upon the order of operations.

impl<P> Debug for ChannelProvider<P>

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

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

Formats the value using the given formatter.

impl<P> OriginAdvancer for ChannelProvider<P>

where P: NextFrameProvider + 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 ChannelProvider<P>

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

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

Returns the optional L1 BlockInfo origin.

impl<P> SignalReceiver for ChannelProvider<P>

where P: NextFrameProvider + 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.