Struct MemorySessionStore 

pub struct MemorySessionStore { /* private fields */ }

Available on crate features memory only.

In-memory session store backed by DashMap.

For testing and single-node development only. Not suitable for production:

• Data is lost on process restart.
• No encryption at rest.

Expired sessions are automatically purged every 1024 write operations. Call MemorySessionStore::purge_expired for on-demand cleanup.

Time injection

Stores created_at as chrono::DateTime<Utc> against the injected Clock (default SystemClock). DST tests can drive expiry deterministically by constructing the store with with_clock and a MockClock. In-memory session store. Suitable for tests and single-process examples; not durable across restarts and not shared across nodes.

Thin newtype around MemoryStore<SessionId, SessionData> (the shared Store<K, V> backend from axess_core::store). The session-domain SessionStore::cycle lives on this wrapper because Store<K, V> has no equivalent (cycle is a session-domain rename primitive, not a kv primitive); everything else delegates to the inner backend.

Implementations

impl MemorySessionStore

pub fn new() -> Self

Create an empty in-memory session store.

pub fn with_clock(self, clock: Arc<dyn Clock>) -> Self

Inject a Clock for deterministic simulation testing. In production, leave at the default SystemClock. Flows through to the underlying MemoryStore so TTL bookkeeping uses the same time source.

pub fn purge_expired(&self)

Remove all expired sessions. Call from a background task or let the auto-purge handle it (runs every 1024 writes).

Trait Implementations

impl Clone for MemorySessionStore

fn clone(&self) -> MemorySessionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemorySessionStore

fn default() -> Self

Returns the “default value” for a type.

impl HealthCheck for MemorySessionStore

fn check(&self) -> Pin<Box<dyn Future<Output = HealthStatus> + Send + '_>>

Probe the component and return its current health.

impl SessionStore for MemorySessionStore

type Error = Infallible

The error type returned by storage operations.

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

Load the session data for the given ID. Returns None if the session does not exist or has expired.

async fn save( &self, id: &SessionId, data: &SessionData, ttl: Duration, ) -> Result<(), Self::Error>

Persist session data with a time-to-live.

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

Delete the session. Idempotent; does not error if the session is absent.

async fn cycle( &self, old_id: &SessionId, new_id: &SessionId, data: &SessionData, ttl: Duration, ) -> Result<(), Self::Error>

Atomically delete the old session row and store the data under the caller-supplied new id.

async fn prune_expired(&self) -> Result<u64, Self::Error>

Bulk-delete every session row whose TTL has elapsed. Returns the number of rows reclaimed.

fn find_sessions_for_user( &self, user_id: &UserId, limit: usize, ) -> impl Future<Output = Result<Vec<(SessionId, SessionData)>, Self::Error>> + Send

Return active (non-expired) sessions for the given user, newest first.