Struct Agent 

pub struct Agent { /* private fields */ }

The agent runtime that orchestrates LLM calls and tool execution.

Implementations

impl Agent

pub fn new( provider: Arc<dyn Provider>, tools: ToolRegistry, config: AgentConfig, ) -> Self

Create a new agent with the given provider and tools.

pub fn messages(&self) -> &[Message]

Get the current message history.

pub fn clear_messages(&mut self)

Clear the message history.

pub fn add_message(&mut self, message: Message)

Add a message to the history.

pub fn replace_messages(&mut self, messages: Vec<Message>)

Replace the message history.

pub fn set_provider(&mut self, provider: Arc<dyn Provider>)

Replace the provider implementation (used for model/provider switching).

pub fn register_message_fetchers( &mut self, steering: Option<MessageFetcher>, follow_up: Option<MessageFetcher>, )

Register async fetchers for queued steering/follow-up messages.

This is additive: multiple sources (e.g. RPC, extensions) can register fetchers, and the agent will poll all of them.

pub fn extend_tools<I>(&mut self, tools: I)

where I: IntoIterator<Item = Box<dyn Tool>>,

Extend the tool registry with additional tools (e.g. extension-registered tools).

pub fn queue_steering(&mut self, message: Message) -> u64

Queue a steering message (delivered after tool completion).

pub fn queue_follow_up(&mut self, message: Message) -> u64

Queue a follow-up message (delivered when agent becomes idle).

pub const fn set_queue_modes( &mut self, steering: QueueMode, follow_up: QueueMode, )

Configure queue delivery modes.

pub fn queued_message_count(&self) -> usize

Count queued messages (steering + follow-up).

pub fn provider(&self) -> Arc<dyn Provider>

pub const fn stream_options(&self) -> &StreamOptions

pub const fn stream_options_mut(&mut self) -> &mut StreamOptions

pub async fn run( &mut self, user_input: impl Into<String>, on_event: impl Fn(AgentEvent) + Send + Sync + 'static, ) -> Result<AssistantMessage>

Run the agent with a user message.

Returns a stream of events and the final assistant message.

pub async fn run_with_abort( &mut self, user_input: impl Into<String>, abort: Option<AbortSignal>, on_event: impl Fn(AgentEvent) + Send + Sync + 'static, ) -> Result<AssistantMessage>

Run the agent with a user message and abort support.

pub async fn run_with_content( &mut self, content: Vec<ContentBlock>, on_event: impl Fn(AgentEvent) + Send + Sync + 'static, ) -> Result<AssistantMessage>

Run the agent with structured content (text + images).

pub async fn run_with_content_with_abort( &mut self, content: Vec<ContentBlock>, abort: Option<AbortSignal>, on_event: impl Fn(AgentEvent) + Send + Sync + 'static, ) -> Result<AssistantMessage>

Run the agent with structured content (text + images) and abort support.

pub async fn run_with_message_with_abort( &mut self, message: Message, abort: Option<AbortSignal>, on_event: impl Fn(AgentEvent) + Send + Sync + 'static, ) -> Result<AssistantMessage>

Run the agent with a pre-constructed user message and abort support.

pub async fn run_continue_with_abort( &mut self, abort: Option<AbortSignal>, on_event: impl Fn(AgentEvent) + Send + Sync + 'static, ) -> Result<AssistantMessage>

Continue the agent loop without adding a new prompt message (used for retries).