Struct Agent 

pub struct Agent { /* private fields */ }

Main Agent orchestrator

The Agent coordinates model calls, memory, tools, and sub-agents. It matches the structure from go-agent’s Agent struct.

Implementations

impl Agent

pub fn new( model: Arc<dyn LLM>, memory: Arc<SessionMemory>, options: AgentOptions, ) -> Self

Creates a new Agent with the given configuration

pub fn with_system_prompt(self, prompt: impl Into<String>) -> Self

Sets the system prompt

pub fn with_tools(self, catalog: Arc<ToolCatalog>) -> Self

Sets the tool catalog

pub fn with_codemode(self, engine: Arc<CodeModeUtcp>) -> Self

Enables CodeMode execution as a first-class tool (codemode.run_code).

pub fn with_codemode_orchestrator( self, engine: Arc<CodeModeUtcp>, orchestrator_model: Option<Arc<dyn LLM>>, ) -> Self

Enables CodeMode plus the Codemode orchestrator for automatic tool routing. If orchestrator_model is None, the primary agent model is reused.

pub async fn register_utcp_provider( &self, client: Arc<dyn UtcpClientInterface>, provider: Arc<dyn UtcpProvider>, ) -> Result<Vec<UtcpTool>>

Registers a UTCP provider and loads its tools into the agent’s catalog.

pub async fn register_utcp_provider_with_tools( &self, client: Arc<dyn UtcpClientInterface>, provider: Arc<dyn UtcpProvider>, tools: Vec<UtcpTool>, ) -> Result<Vec<UtcpTool>>

Registers a UTCP provider using a predefined set of tools and adds them to the catalog.

pub fn register_utcp_tools( &self, client: Arc<dyn UtcpClientInterface>, tools: Vec<UtcpTool>, ) -> Result<()>

Registers UTCP tools into the agent’s catalog without re-registering the provider.

pub fn as_utcp_tool( &self, name: impl Into<String>, description: impl Into<String>, ) -> UtcpTool

Returns a UTCP tool specification representing this agent as an in-process tool.

pub async fn register_as_utcp_provider( self: Arc<Self>, utcp_client: &dyn UtcpClientInterface, name: impl Into<String>, description: impl Into<String>, ) -> Result<()>

Registers this agent as a UTCP provider using an in-process CLI shim.

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

Generates a response for the given user input, encoded as TOON

pub async fn generate_with_files( &self, session_id: impl Into<String>, user_input: impl Into<String>, files: Vec<File>, ) -> Result<String>

Generates a response with file attachments

pub async fn generate_stream( &self, session_id: impl Into<String>, user_input: impl Into<String>, ) -> Result<BoxStream<'static, Result<GenerationChunk>>>

Generates a streaming response

pub async fn invoke_tool( &self, session_id: impl Into<String>, tool_name: &str, arguments: HashMap<String, Value>, ) -> Result<String>

Invokes a tool by name

pub async fn flush(&self, _session_id: &str) -> Result<()>

Flushes memory to persistent store

pub fn tools(&self) -> Arc<ToolCatalog>

Returns the tool catalog

pub async fn checkpoint(&self, session_id: &str) -> Result<Vec<u8>>

Checkpoints the agent state for persistence

pub async fn restore(&self, _session_id: &str, data: &[u8]) -> Result<()>

Restores agent state from checkpoint