Struct SqliteSessionManager 

pub struct SqliteSessionManager { /* private fields */ }

SQLite-backed session manager

Persists session IDs to SQLite so clients can reconnect after server restart. The actual session workers are created on-demand, but session identity persists.

Implementations

impl SqliteSessionManager

pub async fn new( config: SqliteSessionConfig, ) -> Result<Self, SqliteSessionError>

Create a new SQLite session manager

pub async fn cleanup_old_sessions(&self) -> Result<usize, SqliteSessionError>

Clean up sessions older than max_session_age

Returns the number of sessions cleaned up

Trait Implementations

impl SessionManager for SqliteSessionManager

type Error = SqliteSessionError

type Transport = WorkerTransport<LocalSessionWorker>

async fn create_session( &self, ) -> Result<(SessionId, Self::Transport), Self::Error>

Create a new session with the given id and configuration.

async fn initialize_session( &self, id: &SessionId, message: ClientJsonRpcMessage, ) -> Result<ServerJsonRpcMessage, Self::Error>

async fn has_session(&self, id: &SessionId) -> Result<bool, Self::Error>

async fn close_session(&self, id: &SessionId) -> Result<(), Self::Error>

async fn create_stream( &self, id: &SessionId, message: ClientJsonRpcMessage, ) -> Result<impl Stream<Item = ServerSseMessage> + Send + 'static, Self::Error>

async fn create_standalone_stream( &self, id: &SessionId, ) -> Result<impl Stream<Item = ServerSseMessage> + Send + 'static, Self::Error>

async fn resume( &self, id: &SessionId, last_event_id: String, ) -> Result<impl Stream<Item = ServerSseMessage> + Send + 'static, Self::Error>

async fn accept_message( &self, id: &SessionId, message: ClientJsonRpcMessage, ) -> Result<(), Self::Error>