Struct SqliteSessionRepository 

pub struct SqliteSessionRepository { /* private fields */ }

SQLite-backed session repository implementation.

Implementations

impl SqliteSessionRepository

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

Creates a repository backed by the provided async database handle.

Trait Implementations

impl SessionRepository for SqliteSessionRepository

fn insert_session<'life0, 'async_trait>( &'life0 self, session: OwnedNewSession, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Inserts a newly created session record.

fn update_session_state<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, state: &'life2 str, exit_code: Option<i64>, ended: bool, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Updates the session state and optionally stores exit information.

fn update_session_pid<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, pid: i64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Updates the OS process identifier associated with a session.

fn load_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SessionRow>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Loads one session by identifier.

fn load_active_session_for_task_step<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task_id: &'life1 str, step_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SessionRow>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Loads the active session for a task step, if one is attached.

fn list_task_sessions<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<SessionRow>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Lists all sessions associated with a task.

fn acquire_writer<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, client_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Attempts to acquire exclusive writer attachment for a client.

fn attach_reader<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, client_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Attaches a read-only client to a session.

fn cleanup_stale_sessions<'life0, 'async_trait>( &'life0 self, max_age_hours: u64, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Cleans up sessions considered stale according to the given age threshold.

fn release_attachment<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session_id: &'life1 str, client_id: &'life2 str, reason: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Releases a writer or reader attachment from a session.