Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

Keeps everything in memory behind one mutex. Nothing survives a restart and nothing is shared between processes, so use it for tests, development and single-instance apps only.

Implementations

impl MemoryStore

pub fn new() -> Self

An empty store.

pub fn events(&self) -> Vec<SessionEvent>

Every recorded event, oldest first.

pub fn session_count(&self) -> usize

Number of stored sessions, including expired ones not yet purged.

Trait Implementations

impl Debug for MemoryStore

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

Formats the value using the given formatter.

impl Default for MemoryStore

fn default() -> Self

Returns the “default value” for a type.

impl SessionStore for MemoryStore

fn sharded(&self) -> bool

Whether the store partitions data into buckets that must be co-located.

fn insert_session( &self, session: &SessionRecord, token: &TokenHash, ) -> impl Future<Output = Result<(), StoreError>> + Send

Stores a new session with token as its current token (issued_at = created_at, unused, not superseded).

fn find_by_token( &self, token: &TokenHash, ) -> impl Future<Output = Result<Option<TokenLookup>, StoreError>> + Send

Finds the session holding token, current or superseded.

fn apply( &self, update: &SessionUpdate, ) -> impl Future<Output = Result<bool, StoreError>> + Send

Applies update atomically, in this order:

fn delete_session( &self, session_id: Uuid, ) -> impl Future<Output = Result<bool, StoreError>> + Send

Deletes a session and its tokens. Returns whether it existed.

fn delete_subject_sessions( &self, subject: &str, ) -> impl Future<Output = Result<Vec<Uuid>, StoreError>> + Send

Deletes every session of subject (canonical JSON). Returns the ids it deleted.

fn list_subject_sessions( &self, subject: &str, ) -> impl Future<Output = Result<Vec<SessionRecord>, StoreError>> + Send

Every session of subject (canonical JSON), including expired ones not yet purged.

fn delete_expired( &self, now: DateTime<Utc>, idle_cutoff: DateTime<Utc>, ) -> impl Future<Output = Result<u64, StoreError>> + Send

Deletes sessions with expires_at <= now or last_seen_at <= idle_cutoff. Returns how many.

fn record_event( &self, event: &SessionEvent, ) -> impl Future<Output = Result<(), StoreError>> + Send

Appends a security event. Stores without an event log may discard it.

fn delete_events_before( &self, cutoff: DateTime<Utc>, ) -> impl Future<Output = Result<u64, StoreError>> + Send

Deletes events with at < cutoff. Returns how many. Also deletes event claims older than cutoff.

fn claim_event( &self, scope: ClaimScope<'_>, kind: EventKind, now: DateTime<Utc>, window: TimeDelta, ) -> impl Future<Output = Result<bool, StoreError>> + Send

Claims the right to report a kind event for scope, for deduplication across processes. Succeeds (true) unless a claim for the same scope and kind was made after now - window, and records now as the new claim when it does. Session and subject claims are independent. Must be atomic across processes.