Struct AgentRunner 

pub struct AgentRunner<T: MoFAAgent> { /* private fields */ }

统一 Agent 运行器

可以运行任何实现了 MoFAAgent 的 Agent。

Implementations

impl<T: MoFAAgent> AgentRunner<T>

pub async fn new(agent: T) -> AgentResult<Self>

创建新的运行器

此方法会初始化 Agent。

pub async fn with_context(agent: T, context: AgentContext) -> AgentResult<Self>

使用自定义上下文创建运行器

pub fn agent(&self) -> &T

获取 Agent 引用

pub fn agent_mut(&mut self) -> &mut T

获取 Agent 可变引用

pub fn context(&self) -> &AgentContext

获取执行上下文

pub async fn state(&self) -> RunnerState

获取运行器状态

pub async fn stats(&self) -> RunnerStats

获取统计信息

pub async fn is_running(&self) -> bool

检查是否正在运行

pub async fn execute(&mut self, input: AgentInput) -> AgentResult<AgentOutput>

执行单个任务

参数

• input: 输入数据

返回

返回 Agent 的输出。

pub async fn execute_batch( &mut self, inputs: Vec<AgentInput>, ) -> Vec<AgentResult<AgentOutput>>

批量执行多个任务

参数

• inputs: 输入数据列表

返回

返回输出列表，如果某个任务失败，返回对应错误。

pub async fn pause(&mut self) -> AgentResult<()>

where T: AgentLifecycle,

暂停运行器

仅支持实现了 AgentLifecycle 的 Agent。

pub async fn resume(&mut self) -> AgentResult<()>

where T: AgentLifecycle,

恢复运行器

仅支持实现了 AgentLifecycle 的 Agent。

pub async fn shutdown(self) -> AgentResult<()>

关闭运行器

优雅关闭，释放资源。

pub async fn interrupt(&mut self) -> AgentResult<InterruptResult>

中断当前执行

pub fn into_inner(self) -> T

消耗运行器，返回内部 Agent

pub fn id(&self) -> &str

获取 Agent ID

pub fn name(&self) -> &str

获取 Agent 名称

pub fn capabilities(&self) -> &AgentCapabilities

获取 Agent 能力

pub fn agent_state(&self) -> AgentState

获取 Agent 状态

impl<T: MoFAAgent + AgentMessaging> AgentRunner<T>

为支持消息处理的 Agent 提供的扩展方法

pub async fn handle_event(&mut self, event: AgentEvent) -> AgentResult<()>

处理单个事件

pub async fn send_message( &mut self, msg: AgentMessage, ) -> AgentResult<AgentMessage>

发送消息给 Agent