Struct InMemorySessionStore 

pub struct InMemorySessionStore { /* private fields */ }

Simple in-memory implementation backed by hash maps.

Implementations

impl InMemorySessionStore

pub fn new() -> Self

Constructs an empty store.

Trait Implementations

impl Default for InMemorySessionStore

fn default() -> Self

Returns the “default value” for a type.

impl SessionStore for InMemorySessionStore

fn create_session( &self, ctx: &TenantCtx, data: SessionData, ) -> SessionResult<SessionKey>

Creates a new session associated with the supplied tenant context and returns its key.

fn get_session(&self, key: &SessionKey) -> SessionResult<Option<SessionData>>

Fetches the session payload for the provided key, if it exists.

fn update_session( &self, key: &SessionKey, data: SessionData, ) -> SessionResult<()>

Replaces the session payload for the provided key.

fn remove_session(&self, key: &SessionKey) -> SessionResult<()>

Removes the session entry and clears any lookup indices.

fn register_wait( &self, ctx: &TenantCtx, user_id: &UserId, scope: &ReplyScope, session_key: &SessionKey, data: SessionData, ttl: Option<Duration>, ) -> SessionResult<()>

Registers a paused flow wait, persisting the session and routing indices.

fn find_wait_by_scope( &self, ctx: &TenantCtx, user_id: &UserId, scope: &ReplyScope, ) -> SessionResult<Option<SessionKey>>

Finds a wait registered for the provided scope, if one exists.

fn list_waits_for_user( &self, ctx: &TenantCtx, user_id: &UserId, ) -> SessionResult<Vec<SessionKey>>

Lists all waits registered for the provided user.

fn clear_wait( &self, ctx: &TenantCtx, user_id: &UserId, scope: &ReplyScope, ) -> SessionResult<()>

Clears a wait registration for the provided scope.

fn find_by_user( &self, ctx: &TenantCtx, user: &UserId, ) -> SessionResult<Option<(SessionKey, SessionData)>>

👎Deprecated:

use find_wait_by_scope or list_waits_for_user instead

Finds the active session bound to the specified tenant + user combination.