Struct Pipeline 

pub struct Pipeline { /* private fields */ }

Execution pipeline connecting source → operators → sink.

Implementations

impl Pipeline

pub fn new( source: Box<dyn Source>, operators: Vec<Box<dyn PushOperator>>, sink: Box<dyn Sink>, ) -> Self

Create a new pipeline.

pub fn simple(source: Box<dyn Source>, sink: Box<dyn Sink>) -> Self

Create a simple pipeline with just source and sink.

pub fn with_operator(self, op: Box<dyn PushOperator>) -> Self

Add an operator to the pipeline.

pub fn execute(&mut self) -> Result<(), OperatorError>

Execute the pipeline.