Struct StreamPipeline 

pub struct StreamPipeline { /* private fields */ }

Stream processing pipeline

Implementations

impl StreamPipeline

pub fn new() -> Self

Create a new streaming pipeline

pub fn with_buffer_size(self, size: usize) -> Self

Set buffer size for inter-stage communication

pub fn with_num_threads(self, threads: usize) -> Self

Set number of worker threads

pub fn add_stage<S: ProcessingStage>(self, stage: S) -> Self

Add a processing stage to the pipeline

pub fn process_stream<I>(&mut self, input: I) -> StreamProcessor

where I: Iterator<Item = Frame> + Send + 'static,

Process a stream of frames

pub fn metrics(&self) -> PipelineMetrics

Get current pipeline metrics

Trait Implementations

impl Default for StreamPipeline

fn default() -> Self

Returns the “default value” for a type.