Struct Agent 

pub struct Agent { /* private fields */ }

Implementations

impl Agent

pub fn new( transport: Arc<dyn ProviderTransport>, tools: Arc<ToolRegistry>, memory: Arc<dyn MemoryStore>, config: Arc<AgentConfig>, ) -> Self

pub fn with_session_db(self, db: Arc<SessionDb>) -> Self

pub fn with_hooks(self, hooks: impl AgentHooks) -> Self

pub fn tools(&self) -> &ToolRegistry

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

pub fn tool_count(&self) -> usize

pub fn tool_names(&self) -> Vec<String>

pub fn tool_names_by_toolset(&self) -> BTreeMap<String, Vec<String>>

pub fn spawn_child(&self) -> Self

pub fn clear_session(&self, session_key: &str)

Clear the stored conversation history for a platform session (e.g. on /new or /clear). Removes both the in-memory cache and the on-disk file, and clears any active goal.

pub async fn set_goal(&self, session_key: &str, goal: &str) -> Result<()>

pub async fn get_goal(&self, session_key: &str) -> Option<String>

pub async fn clear_goal(&self, session_key: &str)

pub fn history_pairs(&self, session_key: &str) -> Vec<(String, String)>

Prior (user, assistant) conversation pairs for a session — warm cache first, disk fallback on miss. Lets an embedding app (e.g. the desktop) repopulate the chat view on launch from the same store the agent uses.

pub fn inject_history( &self, session_key: &str, user_msg: &str, assistant_msg: &str, )

Inject a (user, assistant) pair directly into conversation history without running the agent. Used by GatewayHandler to silently store image descriptions.

pub fn update_last_history(&self, session_key: &str, new_assistant: &str)

Update the assistant content of the most recently injected history pair. Used to replace a placeholder description with the actual view_image result after the (potentially slow) tool call completes.

pub async fn run_tool(&self, name: &str, args: Value) -> String

Call a single registered tool by name and return its output as a plain string. Intended for server-side preprocessing (e.g. gateway image pipeline) where the result must be available before the agent loop runs. Returns the tool’s content on success, or an error description on failure.

pub async fn run_tool_scoped( &self, name: &str, args: Value, conv_key: &str, ) -> String

Like run_tool but sets conv_key so storage-scoped tools (e.g. doc_ingest, doc_search) operate on the correct conversation bucket.

pub async fn run( &self, task: &str, approver: Arc<dyn CommandApprover>, platform: &str, hint: Option<&str>, session_key: Option<&str>, ) -> Result<AgentResult, AgentError>

pub async fn run_for_user( &self, task: &str, approver: Arc<dyn CommandApprover>, platform: &str, hint: Option<&str>, session_key: Option<&str>, user_id: &str, ) -> Result<AgentResult, AgentError>

pub async fn run_streaming( &self, task: &str, approver: Arc<dyn CommandApprover>, platform: &str, chunk_tx: UnboundedSender<String>, tool_tx: Option<UnboundedSender<String>>, hint: Option<&str>, session_key: Option<&str>, ) -> Result<AgentResult, AgentError>

Trait Implementations

impl Clone for Agent

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl SubAgentRunner for Agent

fn run_task<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task: &'life1 str, session_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<String, AgentError>> + Send + 'async_trait>>

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