kona_derive_alloy::prelude

Struct ChannelProvider

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

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§

Source§

impl<P> ChannelProvider<P>
where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug,

Source

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

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

Trait Implementations§

Source§

impl<P> ChannelReaderProvider for ChannelProvider<P>
where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

Source§

fn next_data<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<Bytes>, PipelineErrorKind>> + Send + 'async_trait>>
where 'life0: 'async_trait, ChannelProvider<P>: '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.
Source§

impl<P> Debug for ChannelProvider<P>
where P: Debug + NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver,

Source§

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

Formats the value using the given formatter. Read more
Source§

impl<P> OriginAdvancer for ChannelProvider<P>
where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

Source§

fn advance_origin<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), PipelineErrorKind>> + Send + 'async_trait>>
where 'life0: 'async_trait, ChannelProvider<P>: '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.
Source§

impl<P> OriginProvider for ChannelProvider<P>
where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug,

Source§

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

Returns the optional L1 BlockInfo origin.
Source§

impl<P> SignalReceiver for ChannelProvider<P>
where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

Source§

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

Receives a signal from the driver.

Auto Trait Implementations§

§

impl<P> Freeze for ChannelProvider<P>
where P: Freeze,

§

impl<P> RefUnwindSafe for ChannelProvider<P>
where P: RefUnwindSafe,

§

impl<P> Send for ChannelProvider<P>
where P: Send,

§

impl<P> Sync for ChannelProvider<P>
where P: Sync,

§

impl<P> Unpin for ChannelProvider<P>
where P: Unpin,

§

impl<P> UnwindSafe for ChannelProvider<P>
where P: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> MaybeSendSync for T