Struct SessionManager 

pub struct SessionManager { /* private fields */ }

In-memory runtime run coordinator (not persistent session storage).

Implementations

impl SessionManager

pub fn new() -> Self

pub async fn state(&self, session_id: Uuid) -> SessionRuntimeState

pub async fn active_run_id(&self, session_id: Uuid) -> Option<Uuid>

pub async fn running_runs(&self) -> Vec<(Uuid, Uuid)>

pub async fn start_run<F, Fut>( &self, session_id: Uuid, spawn_actor: F, ) -> Result<Uuid, SessionManagerError>

where F: FnOnce(Uuid) -> Fut, Fut: Future<Output = Result<SessionHandle, String>>,

pub async fn mark_run_finished( &self, session_id: Uuid, run_id: Uuid, outcome: Result<(), String>, ) -> Result<(), SessionManagerError>

pub async fn send_command( &self, session_id: Uuid, run_id: Uuid, command: AgentCommand, ) -> Result<(), SessionManagerError>

pub async fn cancel_run( &self, session_id: Uuid, run_id: Uuid, ) -> Result<(), SessionManagerError>

Trait Implementations

impl Clone for SessionManager

fn clone(&self) -> SessionManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for SessionManager

fn default() -> SessionManager

Returns the “default value” for a type.