Struct PostgresSessionService 

pub struct PostgresSessionService { /* private fields */ }

Session service backed by PostgreSQL.

Provides scalable, multi-process session persistence using PostgreSQL. Suitable for production deployments requiring horizontal scaling.

Delegates all storage operations to a DatabaseSessionService built from the configured connection string. The connection pool is opened lazily on first use; call initialize to open it eagerly and run the schema migration.

Implementations

impl PostgresSessionService

pub fn new(config: PostgresSessionConfig) -> Self

Create a new PostgreSQL session service.

This only creates the service struct. The pool connects lazily on first use, or eagerly via initialize.

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

Open the pool and run the schema migration.

Creates the sessions and events tables if they don’t exist. Safe to call multiple times.

pub fn connection_string(&self) -> &str

Returns the configured connection string.

pub fn max_connections(&self) -> u32

Returns the configured maximum number of pool connections.

Trait Implementations

impl SessionService for PostgresSessionService

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.