Struct AgentSession 

pub struct AgentSession {
    pub agent: Agent,
    pub session: Arc<Mutex<Session>>,
    pub extensions: Option<ExtensionRegion>,
    /* private fields */
}

Fields

agent: Agent

session: Arc<Mutex<Session>>

extensions: Option<ExtensionRegion>

Extension lifecycle region — ensures the JS runtime thread is shut down when the session ends.

Implementations

impl AgentSession

pub const fn runtime_repair_mode_from_policy_mode( mode: RepairPolicyMode, ) -> RepairMode

pub fn new( agent: Agent, session: Arc<Mutex<Session>>, save_enabled: bool, compaction_settings: ResolvedCompactionSettings, ) -> Self

pub fn with_model_registry(self, registry: ModelRegistry) -> Self

pub fn with_auth_storage(self, auth: AuthStorage) -> Self

pub fn set_model_registry(&mut self, registry: ModelRegistry)

pub fn set_auth_storage(&mut self, auth: AuthStorage)

pub async fn set_provider_model( &mut self, provider_id: &str, model_id: &str, ) -> Result<()>

pub const fn save_enabled(&self) -> bool

pub async fn compact_now( &mut self, on_event: impl Fn(AgentEvent) + Send + Sync + 'static, ) -> Result<()>

Force-run compaction synchronously (used by /compact slash command).

pub async fn enable_extensions( &mut self, enabled_tools: &[&str], cwd: &Path, config: Option<&Config>, extension_entries: &[PathBuf], ) -> Result<()>

pub async fn enable_extensions_with_policy( &mut self, enabled_tools: &[&str], cwd: &Path, config: Option<&Config>, extension_entries: &[PathBuf], policy: Option<ExtensionPolicy>, repair_policy: Option<RepairPolicyMode>, pre_warmed: Option<PreWarmedExtensionRuntime>, ) -> Result<()>

pub async fn save_and_index(&mut self) -> Result<()>

pub async fn persist_session(&mut self) -> Result<()>

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

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

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

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>