Struct AgentExecutor 

pub struct AgentExecutor { /* private fields */ }

Standard LLM-based agent executor

This executor handles the complete agent loop:

1. Build context with system prompt, history, and current message
2. Call LLM with tool definitions
3. Execute tools if called
4. Repeat until no more tool calls or max iterations reached

Uses composition with BaseAgent to avoid reimplementing MoFAAgent.

Architecture

AgentExecutor
├── BaseAgent (provides MoFAAgent implementation)
└── LLM-specific fields (llm, context, tools, sessions, config)

Example

use mofa_foundation::agent::executor::{AgentExecutor, AgentExecutorConfig};
use std::sync::Arc;

let llm = Arc::new(MyLLMProvider::new());
let executor = AgentExecutor::new(llm, "/path/to/workspace").await?;

let response = executor.process_message("session", "Hello").await?;

Implementations

impl AgentExecutor

pub async fn new( llm: Arc<dyn LLMProvider>, workspace: impl AsRef<Path>, ) -> Result<AgentExecutor, AgentError>

Create a new agent executor

pub async fn with_config( llm: Arc<dyn LLMProvider>, workspace: impl AsRef<Path>, config: AgentExecutorConfig, ) -> Result<AgentExecutor, AgentError>

Create with custom configuration

pub async fn register_tool(&self, tool: Arc<dyn Tool>) -> Result<(), AgentError>

Register a tool

pub async fn process_message( &mut self, session_key: &str, message: &str, ) -> Result<String, AgentError>

Process a user message

pub fn sessions(&self) -> &Arc<SessionManager>

Get the session manager

pub fn tools(&self) -> &Arc<RwLock<SimpleToolRegistry>>

Get the tool registry

pub fn context(&self) -> &Arc<RwLock<PromptContext>>

Get the prompt context

pub fn llm(&self) -> &Arc<dyn LLMProvider>

Get the LLM provider

pub fn config(&self) -> &AgentExecutorConfig

Get the configuration

pub fn base_mut(&mut self) -> &mut BaseAgent

Get mutable reference to base agent

pub fn base(&self) -> &BaseAgent

Get reference to base agent

Trait Implementations

impl MoFAAgent for AgentExecutor

fn id(&self) -> &str

获取唯一标识符

fn name(&self) -> &str

获取人类可读名称

fn capabilities(&self) -> &AgentCapabilities

获取能力描述

fn state(&self) -> AgentState

获取当前状态

fn initialize<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 AgentContext, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, AgentExecutor: 'async_trait,

初始化 Agent

fn execute<'life0, 'life1, 'async_trait>( &'life0 mut self, input: AgentInput, _ctx: &'life1 AgentContext, ) -> Pin<Box<dyn Future<Output = Result<AgentOutput, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, AgentExecutor: 'async_trait,

执行任务 - 核心方法

fn shutdown<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, AgentExecutor: 'async_trait,

关闭 Agent

fn interrupt<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<InterruptResult, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

中断 Agent