Type Alias OnlinePipeline

pub type OnlinePipeline = DerivationPipeline<OnlineAttributesQueue<OnlineDataProvider>, AlloyL2ChainProvider>;

An online derivation pipeline.

Aliased Type

struct OnlinePipeline {
    pub attributes: AttributesQueue<BatchProvider<BatchStream<ChannelReader<ChannelProvider<FrameQueue<L1Retrieval<EthereumDataSource<AlloyChainProvider, OnlineBlobProviderWithFallback<OnlineBeaconClient, OnlineBeaconClient>>, L1Traversal<AlloyChainProvider>>>>>, AlloyL2ChainProvider>, AlloyL2ChainProvider>, StatefulAttributesBuilder<AlloyChainProvider, AlloyL2ChainProvider>>,
    pub prepared: VecDeque<OpAttributesWithParent>,
    pub rollup_config: Arc<RollupConfig>,
    pub l2_chain_provider: AlloyL2ChainProvider,
}

Fields

attributes: AttributesQueue<BatchProvider<BatchStream<ChannelReader<ChannelProvider<FrameQueue<L1Retrieval<EthereumDataSource<AlloyChainProvider, OnlineBlobProviderWithFallback<OnlineBeaconClient, OnlineBeaconClient>>, L1Traversal<AlloyChainProvider>>>>>, AlloyL2ChainProvider>, AlloyL2ChainProvider>, StatefulAttributesBuilder<AlloyChainProvider, AlloyL2ChainProvider>>

A handle to the next attributes.

prepared: VecDeque<OpAttributesWithParent>

Reset provider for the pipeline. A list of prepared OpAttributesWithParent to be used by the derivation pipeline consumer.

rollup_config: Arc<RollupConfig>

The rollup config.

l2_chain_provider: AlloyL2ChainProvider

The L2 Chain Provider used to fetch the system config on reset.