Struct AgentWorkflowBuilder 

pub struct AgentWorkflowBuilder { /* private fields */ }

Agent 工作流构建器

Implementations

impl AgentWorkflowBuilder

pub fn new(id: impl Into<String>) -> AgentWorkflowBuilder

创建新的构建器

pub fn with_name(self, name: impl Into<String>) -> AgentWorkflowBuilder

设置名称

pub fn add_agent( self, id: impl Into<String>, agent: Arc<LLMAgent>, ) -> AgentWorkflowBuilder

添加 Agent 节点

pub fn add_agent_with_template( self, id: impl Into<String>, agent: Arc<LLMAgent>, template: impl Into<String>, ) -> AgentWorkflowBuilder

添加带提示词模板的 Agent 节点

pub fn add_router<F, Fut>( self, id: impl Into<String>, router_fn: F, ) -> AgentWorkflowBuilder

where F: Fn(AgentValue) -> Fut + Send + Sync + 'static, Fut: Future<Output = String> + Send + 'static,

添加路由节点

pub fn add_llm_router( self, id: impl Into<String>, router_agent: Arc<LLMAgent>, routes: Vec<String>, ) -> AgentWorkflowBuilder

添加基于 LLM 的智能路由节点

pub fn add_transform<F, Fut>( self, id: impl Into<String>, transform_fn: F, ) -> AgentWorkflowBuilder

where F: Fn(AgentValue) -> Fut + Send + Sync + 'static, Fut: Future<Output = AgentValue> + Send + 'static,

添加转换节点

pub fn add_parallel(self, id: impl Into<String>) -> AgentWorkflowBuilder

添加并行节点

pub fn add_join( self, id: impl Into<String>, wait_for: Vec<&str>, ) -> AgentWorkflowBuilder

添加聚合节点

pub fn add_join_with<F, Fut>( self, id: impl Into<String>, wait_for: Vec<&str>, join_fn: F, ) -> AgentWorkflowBuilder

where F: Fn(HashMap<String, AgentValue>) -> Fut + Send + Sync + 'static, Fut: Future<Output = AgentValue> + Send + 'static,

添加带自定义函数的聚合节点

pub fn connect( self, from: impl Into<String>, to: impl Into<String>, ) -> AgentWorkflowBuilder

添加边

pub fn connect_on( self, from: impl Into<String>, to: impl Into<String>, condition: impl Into<String>, ) -> AgentWorkflowBuilder

添加条件边

pub fn chain<S>( self, node_ids: impl IntoIterator<Item = S>, ) -> AgentWorkflowBuilder

where S: Into<String> + Clone,

链式连接多个节点

自动将 start 连接到第一个节点，并将最后一个节点连接到 end

pub fn parallel_agents( self, parallel_id: impl Into<String>, agent_ids: Vec<&str>, join_id: impl Into<String>, ) -> AgentWorkflowBuilder

配置并行执行

从 parallel_node 分发到多个 Agent，然后在 join_node 聚合

pub fn build(self) -> AgentWorkflow

构建工作流