Struct Pipeline 

pub struct Pipeline {
    pub name: String,
    pub orchestration: OrchestrationType,
    pub agents: Vec<Arc<Agent>>,
    pub max_iterations: u32,
}

A pipeline of agents

Fields

name: String

Pipeline name

orchestration: OrchestrationType

Orchestration type

agents: Vec<Arc<Agent>>

Agents in the pipeline

max_iterations: u32

Maximum iterations for loop orchestration

Implementations

impl Pipeline

pub fn sequential(name: impl Into<String>, agents: Vec<Agent>) -> Self

Create a sequential pipeline

pub fn parallel(name: impl Into<String>, agents: Vec<Agent>) -> Self

Create a parallel pipeline

pub fn loop_agent( name: impl Into<String>, agent: Agent, max_iterations: u32, ) -> Self

Create a loop pipeline with a single agent

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.