Struct AgentSessionRuntime 

pub struct AgentSessionRuntime { /* private fields */ }

Owns the current AgentSession plus cwd-bound services, and drives the replacement pipeline for new / switch / fork / import.

Not Clone. Callers hold it behind Arc<AgentSessionRuntime>; interior mutability covers session + services so replacement operations can run through a shared reference. A serializing async mutex prevents concurrent replacement operations from interleaving teardown / apply / rebind.

Implementations

impl AgentSessionRuntime

pub fn new( session: Arc<AgentSession>, services: AgentSessionRuntimeServices, factory: Arc<dyn CreateAgentSessionRuntimeFactory>, diagnostics: Vec<AgentSessionRuntimeDiagnostic>, model_fallback_message: Option<String>, ) -> Self

Construct the runtime from an initial session + services + factory.

pub fn session(&self) -> Arc<AgentSession>

Snapshot of the current session (cheap Arc clone).

pub fn cwd(&self) -> String

Effective cwd.

pub fn agent_dir(&self) -> String

Agent directory (preserved across replacements).

pub fn diagnostics(&self) -> Vec<AgentSessionRuntimeDiagnostic>

Snapshot of diagnostics.

pub fn model_fallback_message(&self) -> Option<String>

Snapshot of the model-fallback warning.

pub fn set_rebind_session(&self, callback: Option<RebindSessionCallback>)

Set the rebind callback invoked after each replacement.

pub fn set_before_session_invalidate( &self, callback: Option<BeforeSessionInvalidateCallback>, )

Set the synchronous pre-invalidate callback invoked during teardown.

pub async fn switch_session( &self, session_path: &str, options: SwitchSessionOptions, ) -> Result<SwitchOutcome, AgentSessionRuntimeError>

Switch to a different session file (resume).

Errors

See AgentSessionRuntimeError.

pub async fn new_session( &self, options: NewSessionOptions, ) -> Result<SwitchOutcome, AgentSessionRuntimeError>

Start a new session in the current cwd.

Errors

See AgentSessionRuntimeError.

pub async fn fork( &self, entry_id: &str, position: ForkPosition, ) -> Result<ForkOutcome, AgentSessionRuntimeError>

Fork the session at entry_id.

position = Before (default): the entry must be a user message; the fork point is that message’s parent and selected_text is returned. position = At: the fork point is the entry itself (clone subtree).

For persisted sessions, the forked branch is written to a new file under the session directory. For in-memory sessions, a fresh in-memory manager is constructed (the mutated branch on the old manager is not carried over — until AgentSession accepts a shared Arc<AsyncMutex<SessionManager>>, matching the TS single-reference pattern).

Errors

See AgentSessionRuntimeError.

pub async fn import_from_jsonl( &self, input_path: &str, cwd_override: Option<&str>, ) -> Result<SwitchOutcome, AgentSessionRuntimeError>

Import a JSONL session file and switch to it.

Errors

Returns AgentSessionRuntimeError::ImportNotFound when the input path does not exist.

pub async fn dispose(&self)

Dispose the current session and the runtime.