Struct SqliteSessionStore 

pub struct SqliteSessionStore { /* private fields */ }

Session store backed by SQLite with connection pooling. Uses r2d2 for concurrent reads and spawn_blocking to avoid blocking the async runtime.

Implementations

impl SqliteSessionStore

pub fn new(db_path: impl AsRef<Path>, max_age_seconds: i64) -> Result<Self>

Create a new session store with SQLite database. Uses a connection pool (max 4 connections) with WAL mode.

pub fn in_memory(max_age_seconds: i64) -> Result<Self>

Create a new in-memory session store (for testing). Uses max_size=1 because in-memory DBs are per-connection.

pub async fn create(&self) -> Result<Session>

Create a new session

pub async fn get(&self, id: &str) -> Result<Option<Session>>

Get a session by ID

pub async fn get_or_create(&self, id: Option<&str>) -> Result<Session>

Get or create a session

pub async fn update(&self, id: &str, data: HashMap<String, Value>) -> Result<()>

Update session data

pub async fn touch(&self, id: &str) -> Result<()>

Update last accessed time

pub async fn delete(&self, id: &str) -> Result<()>

Delete a session

pub async fn cleanup_expired(&self) -> Result<u64>

Clean up expired sessions

pub async fn list_session_ids(&self) -> Result<Vec<String>>

List all active (non-expired) session IDs

pub async fn count(&self) -> Result<usize>

Get count of active sessions

pub async fn apply_atomic_mutation( &self, id: &str, mutation: &AtomicMutation, ) -> Result<HashMap<String, Value>>

Apply a single atomic mutation directly in SQL using json_set/json_extract. Returns the updated session data after the mutation.

Trait Implementations

impl Clone for SqliteSessionStore

fn clone(&self) -> SqliteSessionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.