Struct PipelineBuilder 

pub struct PipelineBuilder<R, L> { /* private fields */ }

Builder for creating post-processor pipelines.

Implementations

impl<R, L> PipelineBuilder<R, L>

pub fn new() -> Self

Create a new pipeline builder.

pub fn add<P>(self, processor: P) -> Self

where P: PostProcessor<Record = R, Label = L> + 'static,

Add a processor to the pipeline.

pub fn add_if<P>(self, condition: bool, processor: P) -> Self

where P: PostProcessor<Record = R, Label = L> + 'static,

Conditionally add a processor.

pub fn build(self) -> PostProcessorPipeline<R, L>

Build the pipeline.

Trait Implementations

impl<R, L> Default for PipelineBuilder<R, L>

fn default() -> Self

Returns the “default value” for a type.