Struct Agent 

pub struct Agent { /* private fields */ }

Implementations

impl Agent

pub fn builder() -> AgentBuilder

pub fn set_channel_name(&mut self, name: String)

pub fn history(&self) -> &[ConversationMessage]

pub fn channel_handles(&self) -> &AgentChannelHandles

pub fn populate_channels( &self, channel_map: &HashMap<String, Arc<dyn Channel>>, ) -> Vec<String>

pub fn attribution_fields(&self) -> (String, String, String)

Attribution fields for opening a turn span at external call sites (ACP, gateway WS) so every record inside a streamed turn carries the same agent_alias/model_provider/model the RPC dispatch path sets. Returns (agent_alias, model_provider, model).

pub fn clear_history(&mut self)

pub fn set_memory_session_id(&mut self, session_id: Option<String>)

pub fn set_temperature(&mut self, temperature: Option<f64>)

pub fn refresh_memory_embedder( &self, model_provider: &str, api_key: Option<&str>, model: &str, dimensions: usize, )

pub fn set_model_name(&mut self, model_name: String)

pub fn set_model_provider(&mut self, model_provider: Box<dyn ModelProvider>)

pub fn set_model_provider_name(&mut self, model_provider_name: String)

pub fn set_tool_dispatcher(&mut self, tool_dispatcher: Box<dyn ToolDispatcher>)

pub fn seed_history(&mut self, messages: &[ChatMessage])

pub fn seed_history_with_event( &mut self, messages: &[ChatMessage], ) -> Option<TurnEvent>

Hydrate prior chat messages and return a transport event when restoring the history enforces the structured message cap.

pub fn seed_conversation_history(&mut self, messages: Vec<ConversationMessage>)

Hydrate the agent with a full ConversationMessage history (e.g. restored from an ACP session store). Preserves all variants including AssistantToolCalls and ToolResults — use this for ACP restore; use seed_history for flat channel session hydration.

pub fn seed_conversation_history_with_event( &mut self, messages: Vec<ConversationMessage>, ) -> Option<TurnEvent>

Hydrate structured conversation history and return a transport event when restoring the history enforces the structured message cap.

pub async fn from_config( config: &Config, agent_alias: &str, ) -> Result<Agent, Error>

pub async fn from_config_with_session_cwd( config: &Config, agent_alias: &str, session_cwd: Option<&Path>, ) -> Result<Agent, Error>

pub async fn from_config_with_session_cwd_and_mcp( config: &Config, agent_alias: &str, session_cwd: Option<&Path>, initialize_mcp: bool, ) -> Result<Agent, Error>

pub async fn from_config_with_session_cwd_and_mcp_backchannel( config: &Config, agent_alias: &str, session_cwd: Option<&Path>, initialize_mcp: bool, exclude_memory: bool, sop_engine: Option<Arc<Mutex<SopEngine>>>, sop_audit: Option<Arc<SopAuditLogger>>, canvas_store: Option<CanvasStore>, ) -> Result<Agent, Error>

pub async fn from_live_config_with_session_cwd_and_mcp_backchannel( live_config: Arc<RwLock<RawRwLock, Config>>, agent_alias: &str, session_cwd: Option<&Path>, initialize_mcp: bool, exclude_memory: bool, sop_engine: Option<Arc<Mutex<SopEngine>>>, sop_audit: Option<Arc<SopAuditLogger>>, canvas_store: Option<CanvasStore>, ) -> Result<Agent, Error>

Build a daemon-backed ACP/WS Agent whose structured-history cap follows the shared config after reloads.

pub async fn from_config_with_tui_env( config: &Config, agent_alias: &str, session_cwd: Option<&Path>, initialize_mcp: bool, exclude_memory: bool, tui_env: Option<HashMap<String, String>>, sop_engine: Option<Arc<Mutex<SopEngine>>>, sop_audit: Option<Arc<SopAuditLogger>>, ) -> Result<Agent, Error>

Like Self::from_config_with_session_cwd_and_mcp_backchannel but also injects the TUI’s captured shell environment so that tools like ShellTool inherit the user’s real PATH, SSH_AUTH_SOCK, etc. rather than the daemon’s stripped-down process environment.

pub async fn from_live_config_with_tui_env( live_config: Arc<RwLock<RawRwLock, Config>>, agent_alias: &str, session_cwd: Option<&Path>, initialize_mcp: bool, exclude_memory: bool, tui_env: Option<HashMap<String, String>>, sop_engine: Option<Arc<Mutex<SopEngine>>>, sop_audit: Option<Arc<SopAuditLogger>>, ) -> Result<Agent, Error>

Build a daemon-backed TUI Agent whose structured-history cap follows the shared config after reloads.

pub async fn turn(&mut self, user_message: &str) -> Result<String, Error>

pub async fn turn_streamed( &mut self, user_message: &str, event_tx: Sender<TurnEvent>, cancel_token: Option<CancellationToken>, ) -> Result<(String, Vec<ConversationMessage>), Error>

pub async fn turn_streamed_with_steering_state( &mut self, user_message: &str, event_tx: Sender<TurnEvent>, cancel_token: Option<CancellationToken>, steering_rx: Option<&mut Receiver<String>>, ) -> Result<StreamedTurnSuccess, StreamedTurnError>

pub async fn run_single(&mut self, message: &str) -> Result<String, Error>

pub async fn run_interactive(&mut self) -> Result<(), Error>

Trait Implementations

impl Drop for Agent

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.