Struct AgentNode 

pub struct AgentNode {
    pub id: String,
    pub name: String,
    pub node_type: AgentNodeType,
    /* private fields */
}

Agent 工作流节点

Fields

id: String

节点 ID

name: String

节点名称

node_type: AgentNodeType

节点类型

Implementations

impl AgentNode

pub fn start() -> AgentNode

创建开始节点

pub fn end() -> AgentNode

创建结束节点

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

创建 Agent 节点

pub fn router<F, Fut>(id: impl Into<String>, router_fn: F) -> AgentNode

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

创建路由节点

pub fn parallel(id: impl Into<String>) -> AgentNode

创建并行节点

pub fn join(id: impl Into<String>, wait_for: Vec<String>) -> AgentNode

创建聚合节点

pub fn join_with<F, Fut>( id: impl Into<String>, wait_for: Vec<String>, join_fn: F, ) -> AgentNode

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

创建带自定义聚合函数的聚合节点

pub fn transform<F, Fut>(id: impl Into<String>, transform_fn: F) -> AgentNode

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

创建转换节点

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

设置名称

pub fn with_prompt_template(self, template: impl Into<String>) -> AgentNode

设置提示词模板

模板中可以使用 {input} 占位符

pub fn with_session(self, session_id: impl Into<String>) -> AgentNode

设置会话 ID