Struct Pipeline 

pub struct Pipeline {
    pub steps: Vec<Composable>,
    pub name: Option<String>,
    pub description: Option<String>,
}

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

Fields

steps: Vec<Composable>

Ordered steps to execute sequentially.

name: Option<String>

Name given to the compiled agent (default "pipeline").

description: Option<String>

Human-readable description, shown in Debug output.

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). The name becomes the compiled SequentialTextAgent’s name.

let etl = Pipeline::builder("etl")
    .step(AgentBuilder::new("extract"))
    .step(AgentBuilder::new("transform"))
    .step(AgentBuilder::new("load"));
assert_eq!(etl.name.as_deref(), Some("etl"));

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: shown in Debug output, not sent to the model).

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 Default for Pipeline

fn default() -> Pipeline

Returns the “default value” for a type.

impl From<Pipeline> for Composable

fn from(p: Pipeline) -> Self

Converts to this type from the input type.