Struct AsyncSessionStore 

pub struct AsyncSessionStore { /* private fields */ }

Async facade around a SessionRepository implementation.

Implementations

impl AsyncSessionStore

pub fn new(async_db: Arc<AsyncDatabase>) -> Self

Creates a SQLite-backed async session store.

pub fn with_repository(repository: Arc<dyn SessionRepository>) -> Self

Creates an async session store from a repository implementation.

pub async fn insert_session(&self, s: OwnedNewSession) -> Result<()>

Inserts a new session row.

pub async fn update_session_state( &self, session_id: &str, state: &str, exit_code: Option<i64>, ended: bool, ) -> Result<()>

Updates session state, exit code, and optional end time.

pub async fn update_session_pid(&self, session_id: &str, pid: i64) -> Result<()>

Updates the PID associated with a session.

pub async fn load_session(&self, session_id: &str) -> Result<Option<SessionRow>>

Loads a session row by identifier.

pub async fn load_active_session_for_task_step( &self, task_id: &str, step_id: &str, ) -> Result<Option<SessionRow>>

Loads the latest active or detached session for a task step.

pub async fn list_task_sessions(&self, task_id: &str) -> Result<Vec<SessionRow>>

Lists all sessions for a task.

pub async fn acquire_writer( &self, session_id: &str, client_id: &str, ) -> Result<bool>

Attempts to acquire the writer lease for a session.

pub async fn attach_reader( &self, session_id: &str, client_id: &str, ) -> Result<()>

Attaches a read-only client to a session.

pub async fn cleanup_stale_sessions(&self, max_age_hours: u64) -> Result<usize>

Deletes stale terminal sessions and returns the number removed.

pub async fn release_attachment( &self, session_id: &str, client_id: &str, reason: &str, ) -> Result<()>

Releases a reader or writer attachment for a client.