Struct AgentRunner 

pub struct AgentRunner<M> { /* private fields */ }

Runnable agent implementation.

Implementations

impl<M> AgentRunner<M>

where M: Memory,

pub fn new( llm: Arc<dyn LlmProvider>, memory: M, tools: ToolRegistry, system_prompt: Option<String>, config: AgentConfig, ) -> Self

Creates a new agent runner.

pub async fn run(&mut self, input: &str) -> Result<AgentOutput>

Runs the agent to completion.

pub async fn stream_run( &mut self, input: &str, ) -> Result<BoxStream<'_, Result<AgentEvent>>>

Runs the agent as a stream of events.

Trait Implementations

impl<M> Agent for AgentRunner<M>

where M: Memory,

fn run<'life0, 'life1, 'async_trait>( &'life0 mut self, input: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<AgentOutput>> + Send + 'async_trait>>

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

Runs the agent to completion for a user input.

fn stream_run<'life0, 'life1, 'async_trait>( &'life0 mut self, input: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'_, Result<AgentEvent>>>> + Send + 'async_trait>>

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

Runs the agent as an event stream.