Struct Pipeline 

pub struct Pipeline {
    pub steps: Vec<Composable>,
}

Sequential pipeline: execute steps in order, passing state between them.

Fields

steps: Vec<Composable>

Ordered steps to execute sequentially.

Implementations

impl Pipeline

pub fn new(steps: Vec<Composable>) -> Self

Create a pipeline from the given steps.

pub fn builder(_name: &str) -> Self

Create an empty named pipeline (fluent builder entry point).

Pipeline::builder("etl")
    .step(extract_agent)
    .step(transform_agent)
    .step(load_agent)

pub fn step(self, agent: impl Into<Composable>) -> Self

Add a sequential step to this pipeline (fluent builder).

pub fn sub_agent(self, agent: AgentBuilder) -> Self

Add a sub-agent step (alias for step — matches upstream naming).

pub fn describe(self, _desc: &str) -> Self

Set a description (metadata, not used at runtime).

Trait Implementations

impl Clone for Pipeline

fn clone(&self) -> Pipeline

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Pipeline

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

Formats the value using the given formatter.

impl From<Pipeline> for Composable

fn from(p: Pipeline) -> Self

Converts to this type from the input type.