Struct InMemorySessionStorage 

pub struct InMemorySessionStorage { /* private fields */ }

In-memory storage for sessions and events (SSE compliant)

Implementations

impl InMemorySessionStorage

pub fn new() -> Self

Create new in-memory session storage with default configuration

pub fn with_config(config: InMemoryConfig) -> Self

Create new in-memory session storage with custom configuration

pub async fn stats(&self) -> InMemoryStats

Get current statistics

Trait Implementations

impl Clone for InMemorySessionStorage

fn clone(&self) -> InMemorySessionStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemorySessionStorage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for InMemorySessionStorage

fn default() -> Self

Returns the “default value” for a type.

impl SessionStorage for InMemorySessionStorage

type Error = SessionStorageError

Error type for storage operations

fn backend_name(&self) -> &'static str

Get the backend name for logging and debugging

fn create_session<'life0, 'async_trait>( &'life0 self, capabilities: ServerCapabilities, ) -> Pin<Box<dyn Future<Output = Result<SessionInfo, Self::Error>> + Send + 'async_trait>>

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

Create a new session with automatically generated UUID v7

fn create_session_with_id<'life0, 'async_trait>( &'life0 self, session_id: String, capabilities: ServerCapabilities, ) -> Pin<Box<dyn Future<Output = Result<SessionInfo, Self::Error>> + Send + 'async_trait>>

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

Create session with a specific session ID

fn get_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SessionInfo>, Self::Error>> + Send + 'async_trait>>

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

Get session by ID

fn update_session<'life0, 'async_trait>( &'life0 self, session_info: SessionInfo, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Update entire session info

fn set_session_state<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, key: &'life2 str, value: Value, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Update session state value

fn get_session_state<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, Self::Error>> + Send + 'async_trait>>

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

Get session state value

fn remove_session_state<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, Self::Error>> + Send + 'async_trait>>

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

Remove session state value

fn delete_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Error>> + Send + 'async_trait>>

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

Delete session completely

fn list_sessions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Self::Error>> + Send + 'async_trait>>

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

List all session IDs

fn store_event<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, event: SseEvent, ) -> Pin<Box<dyn Future<Output = Result<SseEvent, Self::Error>> + Send + 'async_trait>>

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

Store an event for a session (assigns unique event ID)

fn get_events_after<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, after_event_id: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<SseEvent>, Self::Error>> + Send + 'async_trait>>

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

Get events after a specific event ID (for resumability)

fn get_recent_events<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<SseEvent>, Self::Error>> + Send + 'async_trait>>

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

Get recent events (for initial connection)

fn delete_events_before<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, before_event_id: u64, ) -> Pin<Box<dyn Future<Output = Result<u64, Self::Error>> + Send + 'async_trait>>

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

Delete old events (cleanup)

fn expire_sessions<'life0, 'async_trait>( &'life0 self, older_than: SystemTime, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Self::Error>> + Send + 'async_trait>>

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

Remove expired sessions (returns list of removed session IDs)

fn session_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize, Self::Error>> + Send + 'async_trait>>

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

Get session count for monitoring

fn event_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize, Self::Error>> + Send + 'async_trait>>

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

Get total event count across all sessions

fn maintenance<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Perform maintenance tasks (compaction, cleanup, etc.)