Struct ExecutionEngine 

pub struct ExecutionEngine { /* private fields */ }

执行引擎

提供 Agent 执行、工作流编排等功能

示例

use mofa_runtime::agent::execution::{ExecutionEngine, ExecutionOptions};

let registry = AgentRegistry::new();
// ... 注册 Agent ...

let engine = ExecutionEngine::new(registry);

let result = engine.execute(
    "my-agent",
    AgentInput::text("Hello"),
    ExecutionOptions::default(),
).await?;

if result.is_success() {
    info!("Output: {:?}", result.output);
}

Implementations

impl ExecutionEngine

pub fn new(registry: Arc<AgentRegistry>) -> Self

创建新的执行引擎

pub fn with_plugin_registry( registry: Arc<AgentRegistry>, plugin_registry: Arc<dyn PluginRegistry>, ) -> Self

创建带有自定义插件注册中心的执行引擎

pub async fn execute( &self, agent_id: &str, input: AgentInput, options: ExecutionOptions, ) -> AgentResult<ExecutionResult>

执行 Agent

pub async fn execute_batch( &self, executions: Vec<(String, AgentInput)>, options: ExecutionOptions, ) -> Vec<AgentResult<ExecutionResult>>

批量执行

pub async fn execute_parallel( &self, executions: Vec<(String, AgentInput)>, options: ExecutionOptions, ) -> Vec<AgentResult<ExecutionResult>>

并行执行多个 Agent

pub async fn interrupt(&self, agent_id: &str) -> AgentResult<()>

中断执行

pub async fn interrupt_all(&self) -> AgentResult<Vec<String>>

中断所有执行中的 Agent

pub fn register_plugin(&self, plugin: Arc<dyn Plugin>) -> AgentResult<()>

注册插件

pub fn unregister_plugin(&self, name: &str) -> AgentResult<bool>

移除插件

pub fn list_plugins(&self) -> Vec<Arc<dyn Plugin>>

列出所有插件

pub fn plugin_count(&self) -> usize

插件数量

impl ExecutionEngine

pub async fn execute_workflow( &self, workflow: &Workflow, initial_input: AgentInput, options: ExecutionOptions, ) -> AgentResult<HashMap<String, ExecutionResult>>

执行工作流