Struct Agent 

pub struct Agent<P: Provider> { /* private fields */ }

The main Agent struct

Implementations

impl<P: Provider> Agent<P>

pub fn builder(provider: P) -> AgentBuilder<P>

Create a new agent builder

pub fn subscribe(&self) -> Receiver<AgentEvent>

Subscribe to agent events

pub async fn notify(&self, channel: NotifyChannel, message: &str) -> Result<()>

Send a notification via the configured notifier

pub async fn checkpoint( &self, messages: &[Message], step: usize, status: SessionStatus, ) -> Result<()>

Save current state to persistent storage

pub async fn resume(&self, session_id: &str) -> Result<String>

Resume a previously saved session

pub async fn prompt(&self, prompt: impl Into<String>) -> Result<String>

Send a prompt and get a response (non-streaming)

pub async fn chat(&self, messages: Vec<Message>) -> Result<String>

Send messages and get a response (non-streaming)

pub async fn stream( &self, prompt: impl Into<String>, ) -> Result<StreamingResponse>

Stream a prompt response

pub async fn stream_chat( &self, messages: Vec<Message>, ) -> Result<StreamingResponse>

Stream a chat response

pub async fn call_tool(&self, name: &str, arguments: &str) -> Result<String>

Call a tool by name (Direct call helper)

pub fn has_tool(&self, name: &str) -> bool

Check if agent has a tool

pub async fn tool_definitions(&self) -> Vec<ToolDefinition>

Add tool definitions

pub fn config(&self) -> &AgentConfig

Get the agent’s configuration

pub fn model(&self) -> &str

Get the model name

pub async fn listen( &self, user_input: Receiver<String>, external_events: Receiver<AgentMessage>, ) -> Result<()>

Start a proactive loop that listens for tasks from multiple sources

Trait Implementations

impl<P: Provider> MultiAgent for Agent<P>

fn role(&self) -> AgentRole

Get this agent’s role

fn handle_message<'life0, 'async_trait>( &'life0 self, message: AgentMessage, ) -> Pin<Box<dyn Future<Output = Result<Option<AgentMessage>>> + Send + 'async_trait>>

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

Handle an incoming message from another agent

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

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

Process a user request