Struct SqliteOperatorSessionStore 

pub struct SqliteOperatorSessionStore { /* private fields */ }

SQLite-backed persistent OperatorSessionStore.

Open with SqliteOperatorSessionStore::open (file path) or SqliteOperatorSessionStore::open_in_memory (tests). Both return the store plus an AsyncIsleDriver the caller must shutdown().await when done — same contract as every sibling sqlite store.

Implementations

impl SqliteOperatorSessionStore

pub async fn open( path: impl AsRef<Path>, ) -> Result<(Self, AsyncIsleDriver), OperatorSessionStoreError>

Open (or create) a SQLite database file and run the schema setup.

Also purges a pre-release plaintext-token table ([purge_legacy_plaintext_table]) and restricts the file to 0600 on unix ([harden_file_permissions]).

pub async fn open_in_memory() -> Result<(Self, AsyncIsleDriver), OperatorSessionStoreError>

Open an ephemeral in-memory database (tests, doctests).

Trait Implementations

impl OperatorSessionStore for SqliteOperatorSessionStore

fn get<'life0, 'life1, 'async_trait>( &'life0 self, sid: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<Option<OperatorSessionRecord>, OperatorSessionStoreError>> + Send + 'async_trait>>

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

Unfiltered by design (see the trait’s contract) — no expiry judgment, no delete.

A row that will not decode is an Err(Other) here rather than the None Self::list turns it into. The difference is what the two calls are for: list is boot rehydration, whose caller’s error path takes the whole server down, so one bad row must not be allowed to become one; this asks about a single named row, and answering “there is no such row” about one that is sitting in the file would be the same lie the undecodable-row warn exists to avoid.

fn name(&self) -> &str

Backend name — for diagnostics/logging.

fn put<'life0, 'async_trait>( &'life0 self, record: OperatorSessionRecord, ) -> Pin<Box<dyn Future<Output = Result<(), OperatorSessionStoreError>> + Send + 'async_trait>>

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

Insert or replace the row for record.sid. Upsert semantics: sids are freshly minted so a same-sid overwrite only happens on a deliberate re-put of the same session.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, sid: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<(), OperatorSessionStoreError>> + Send + 'async_trait>>

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

Delete the row for sid. NotFound when no such row exists.

fn list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<OperatorSessionRecord>, OperatorSessionStoreError>> + Send + 'async_trait>>

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

List the sessions this store can decode and that have not expired, ascending by joined_at_secs (mint order, stable for deterministic rehydration).