Struct InMemoryBackend 

pub struct InMemoryBackend { /* private fields */ }

Single-process, Mutex-guarded. Rejects stale fetches so the same semantics as the Postgres impl hold in tests.

Implementations

impl InMemoryBackend

pub fn new() -> Self

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Debug for InMemoryBackend

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

Formats the value using the given formatter.

impl Default for InMemoryBackend

fn default() -> InMemoryBackend

Returns the “default value” for a type.

impl PersistenceBackend for InMemoryBackend

fn persist<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, state: &'life2 CognitiveState, ttl: ChronoDuration, ) -> Pin<Box<dyn Future<Output = Result<(), PersistenceError>> + Send + 'async_trait>>

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

Persist the state under session_id. ttl is advisory; the backend is free to honour it via a scheduled eviction job (the Postgres impl) or a best-effort timer (in-memory).

fn restore<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<CognitiveState, PersistenceError>> + Send + 'async_trait>>

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

Fetch a previously persisted state. Returns PersistenceError::NotFound when no record exists and PersistenceError::Expired when one exists but its TTL lapsed.

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

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

Irreversibly delete the state. Idempotent — no-op when the session has no stored state.

fn evict_expired<'life0, 'async_trait>( &'life0 self, before: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<u64, PersistenceError>> + Send + 'async_trait>>

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

Evict every state whose TTL lapsed at or before before. Returns the count of rows removed for observability. Called periodically by the eviction worker in production; in-memory impl sweeps on-demand.