Struct AgentExecutor 

pub struct AgentExecutor { /* private fields */ }

Agent executor.

Responsible for executing the agent’s decision loop: Plan -> Act -> Observe.

Implementations

impl AgentExecutor

pub fn new(agent: Arc<dyn BaseAgent>, tools: Vec<Arc<dyn BaseTool>>) -> Self

Creates a new AgentExecutor.

pub fn with_max_iterations(self, max_iterations: usize) -> Self

Sets max iterations.

pub fn with_verbose(self, verbose: bool) -> Self

Sets verbose output.

pub fn with_memory(self, memory: Arc<Mutex<dyn BaseMemory>>) -> Self

Sets memory.

pub fn with_callbacks(self, callbacks: Arc<CallbackManager>) -> Self

Sets callback manager.

pub async fn invoke(&self, input: String) -> Result<String, AgentError>

Executes the agent.

pub fn stream( &self, input: String, ) -> Pin<Box<dyn Stream<Item = Result<AgentStreamEvent, AgentError>> + Send>>

Stream agent execution as a true async stream of events.

Each step of the agent loop (tool calls, observations, final answer) is emitted as an AgentStreamEvent as soon as it occurs.

Example

let mut stream = executor.stream("What is Rust?".to_string());
while let Some(event) = stream.next().await {
    match event {
        Ok(AgentStreamEvent::ToolStart { name, input }) => { /* show tool call */ }
        Ok(AgentStreamEvent::ToolEnd { name, output }) => { /* show result */ }
        Ok(AgentStreamEvent::FinalAnswer { content }) => { /* show answer */ }
        _ => {}
    }
}

Trait Implementations

impl Debug for AgentExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.