Struct ChainAgent 

pub struct ChainAgent { /* private fields */ }

链式 Agent 执行模式

多个 Agent 串行执行，前一个的输出作为后一个的输入

示例

let chain = ChainAgent::new()
    .add("step1", agent1)
    .add("step2", agent2)
    .add("step3", agent3);

let result = chain.run("Initial task").await?;

Implementations

impl ChainAgent

pub fn new() -> ChainAgent

创建新的链式 Agent

pub fn add(self, name: impl Into<String>, agent: Arc<ReActAgent>) -> ChainAgent

添加 ReAct Agent 到链中

pub fn add_llm( self, name: impl Into<String>, agent: Arc<LLMAgent>, ) -> ChainAgent

添加 LLM Agent 到链中

pub fn add_unit(self, name: impl Into<String>, unit: AgentUnit) -> ChainAgent

添加通用 AgentUnit

pub fn with_transform<F>(self, f: F) -> ChainAgent

where F: Fn(&str, &str) -> String + Send + Sync + 'static,

设置输入转换函数

转换函数接收前一个 Agent 的输出和下一个 Agent 的名称，返回转换后的输入

示例

chain.with_transform(|prev_output, next_name| {
    format!("Previous result: {}\n\nTask for {}: continue the analysis", prev_output, next_name)
})

pub fn with_continue_on_error(self, continue_on_error: bool) -> ChainAgent

设置是否在失败时继续执行

pub fn with_verbose(self, verbose: bool) -> ChainAgent

设置是否详细输出

pub async fn run( &self, initial_task: impl Into<String>, ) -> Result<ChainResult, LLMError>

执行链式 Agent

pub fn len(&self) -> usize

获取链中的 Agent 数量

pub fn is_empty(&self) -> bool

检查链是否为空

Trait Implementations

impl Default for ChainAgent

fn default() -> ChainAgent

Returns the “default value” for a type.