Struct Pipeline 

pub struct Pipeline<I, O> { /* private fields */ }

Main pipeline structure

Implementations

impl<I, O> Pipeline<I, O>

pub fn new() -> Self

Create a new pipeline

pub fn with_config(self, config: PipelineConfig) -> Self

Set pipeline configuration

pub fn add_stage(self, stage: Box<dyn PipelineStage>) -> Self

Add a stage to the pipeline

pub fn execute(&self, input: I) -> Result<O>

where I: 'static + Send + Sync, O: 'static + Send + Sync,

Execute the pipeline

pub fn execute_with_progress<F>( &self, input: I, progress_callback: F, ) -> Result<O>

where I: 'static + Send + Sync, O: 'static + Send + Sync, F: Fn(usize, usize, &str),

Execute the pipeline with progress tracking

pub fn get_stats(&self, context: &PipelineContext) -> PipelineStats

Get pipeline statistics after execution

impl<I, O> Pipeline<I, O>

pub fn save_config(&self, path: impl AsRef<Path>) -> Result<()>

Save pipeline configuration to a file

pub fn load_config(path: impl AsRef<Path>) -> Result<SerializedPipeline>

Load pipeline configuration from a file

Trait Implementations

impl<I, O> Default for Pipeline<I, O>

fn default() -> Self

Returns the “default value” for a type.