Struct PostProcessorPipeline 

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

A pipeline of post-processors applied in sequence.

Implementations

impl<R, L> PostProcessorPipeline<R, L>

pub fn new() -> Self

Create a new empty pipeline.

pub fn add<P>(&mut self, processor: P)

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

Add a processor to the pipeline.

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

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

Add a processor and return self for chaining.

pub fn process( &mut self, record: &mut R, context: &ProcessContext, ) -> SynthResult<Vec<L>>

Process a single record through all processors.

pub fn process_batch( &mut self, records: &mut [R], base_context: &ProcessContext, ) -> SynthResult<Vec<L>>

Process a batch of records through all processors.

pub fn stats(&self) -> ProcessorStats

Get aggregate statistics for the pipeline.

Returns the pipeline’s own stats tracking records processed through the entire pipeline. Use processor_stats() to get individual processor statistics.

pub fn processor_stats(&self) -> Vec<(&'static str, ProcessorStats)>

Get individual processor statistics.

pub fn has_enabled_processors(&self) -> bool

Check if pipeline has any enabled processors.

pub fn len(&self) -> usize

Get number of processors in the pipeline.

pub fn is_empty(&self) -> bool

Check if pipeline is empty.

pub fn reset_stats(&mut self)

Reset all statistics.

Trait Implementations

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

fn default() -> Self

Returns the “default value” for a type.