Struct PipelineBuilder

pub struct PipelineBuilder<B, P, T, D>
where
    B: AttributesBuilder + Send + Debug,
    P: ChainProvider + Send + Sync + Debug,
    T: L2ChainProvider + Clone + Send + Sync + Debug,
    D: DataAvailabilityProvider + Send + Sync + Debug,
{ /* private fields */ }

The PipelineBuilder constructs a DerivationPipeline using a builder pattern.

Implementations

impl<B, P, T, D> PipelineBuilder<B, P, T, D>

where B: AttributesBuilder + Send + Debug, P: ChainProvider + Send + Sync + Debug, T: L2ChainProvider + Clone + Send + Sync + Debug, D: DataAvailabilityProvider + Send + Sync + Debug,

pub fn new() -> Self

Creates a new pipeline builder.

pub fn rollup_config(self, rollup_config: Arc<RollupConfig>) -> Self

Sets the rollup config for the pipeline.

pub const fn origin(self, origin: BlockInfo) -> Self

Sets the origin L1 block for the pipeline.

pub fn dap_source(self, dap_source: D) -> Self

Sets the data availability provider for the pipeline.

pub fn builder(self, builder: B) -> Self

Sets the builder for the pipeline.

pub fn l2_chain_provider(self, l2_chain_provider: T) -> Self

Sets the l2 chain provider for the pipeline.

pub fn chain_provider(self, chain_provider: P) -> Self

Sets the chain provider for the pipeline.

pub fn build( self, ) -> DerivationPipeline<AttributesQueue<BatchProvider<BatchStream<ChannelReader<ChannelProvider<FrameQueue<L1Retrieval<D, L1Traversal<P>>>>>, T>, T>, B>, T>

Builds the pipeline.

Trait Implementations

impl<B, P, T, D> Debug for PipelineBuilder<B, P, T, D>

where B: AttributesBuilder + Send + Debug + Debug, P: ChainProvider + Send + Sync + Debug + Debug, T: L2ChainProvider + Clone + Send + Sync + Debug + Debug, D: DataAvailabilityProvider + Send + Sync + Debug + Debug,

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

Formats the value using the given formatter.

impl<B, P, T, D> Default for PipelineBuilder<B, P, T, D>

where B: AttributesBuilder + Send + Debug, P: ChainProvider + Send + Sync + Debug, T: L2ChainProvider + Clone + Send + Sync + Debug, D: DataAvailabilityProvider + Send + Sync + Debug,

fn default() -> Self

Returns the “default value” for a type.

impl<B, P, T, D> From<PipelineBuilder<B, P, T, D>> for DerivationPipeline<AttributesQueue<BatchProvider<BatchStream<ChannelReader<ChannelProvider<FrameQueue<L1Retrieval<D, L1Traversal<P>>>>>, T>, T>, B>, T>

where B: AttributesBuilder + Send + Debug, P: ChainProvider + Send + Sync + Debug, T: L2ChainProvider + Clone + Send + Sync + Debug, D: DataAvailabilityProvider + Send + Sync + Debug,

fn from(builder: PipelineBuilder<B, P, T, D>) -> Self

Converts to this type from the input type.