Struct Pipeline 

pub struct Pipeline { /* private fields */ }

A composable pipeline that passes a string through a sequence of named stages.

Guarantees

• Stages execute in insertion order
• First stage failure short-circuits remaining stages (unless an error handler is set)
• Non-panicking

Implementations

impl Pipeline

pub fn new() -> Self

Create a new empty pipeline.

pub fn with_error_handler( self, handler: impl Fn(&str, &str) -> String + Send + Sync + 'static, ) -> Self

Attach a recovery callback for stage failures.

When a stage fails, handler(stage_name, error_message) is called. The returned string becomes the input to the next stage. If no handler is set, stage failures propagate as errors.

pub fn add_stage( self, name: impl Into<String>, handler: impl Fn(String) -> Result<String, AgentRuntimeError> + Send + Sync + 'static, ) -> Self

Append a stage to the pipeline.

pub fn run(&self, input: String) -> Result<String, AgentRuntimeError>

Execute the pipeline, passing input through each stage in order.

pub fn execute_timed( &self, input: String, ) -> Result<PipelineResult, AgentRuntimeError>

Execute the pipeline with per-stage timing.

pub fn stage_count(&self) -> usize

Return the number of stages in the pipeline.

Trait Implementations

impl Debug for Pipeline

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Pipeline

fn default() -> Self

Returns the “default value” for a type.