Struct DatabaseSessionService 

pub struct DatabaseSessionService { /* private fields */ }

SQL database-backed session service.

Supports SQLite and (with postgres-sessions) PostgreSQL via connection URL. The pool is opened lazily on first use and cached, so new stays synchronous and cheap.

Implementations

impl DatabaseSessionService

pub fn new(connection_url: impl Into<String>) -> Self

Create a new database session service.

The connection URL determines the backend by scheme:

• sqlite: / sqlite::memory: → SQLite
• postgres: / postgresql: → PostgreSQL (requires postgres-sessions)

This does not open a connection; the pool is created lazily on first use (or eagerly via initialize).

pub fn with_max_connections(self, max: u32) -> Self

Set the maximum number of pool connections (PostgreSQL only).

SQLite ignores this and always uses a single connection so that an in-memory database survives across calls.

pub fn connection_url(&self) -> &str

Returns the connection URL this service was configured with.

pub async fn initialize(&self) -> Result<(), SessionError>

Initialize the database: open the pool and create the schema.

Safe to call multiple times. Subsequent CRUD calls reuse the cached pool.

Trait Implementations

impl SessionService for DatabaseSessionService

fn create_session<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, app_name: &'life1 str, user_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Session, SessionError>> + Send + 'async_trait>>

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

Create a new session.

fn get_session<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<Option<Session>, SessionError>> + Send + 'async_trait>>

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

Get a session by ID.

fn list_sessions<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, app_name: &'life1 str, user_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Session>, SessionError>> + Send + 'async_trait>>

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

List sessions for an app + user.

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

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

Delete a session.

fn append_event<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, event: Event, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

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

Append an event to a session’s history.

fn get_events<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, SessionError>> + Send + 'async_trait>>

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

Get all events for a session.