Struct InMemoryStore 

pub struct InMemoryStore<V>
where
    V: Clone + Send + Sync + 'static,
{ /* private fields */ }

In-process Store<V> backed by a HashMap keyed by (rendered_namespace, key). Cheap to clone — internal state is Arc<Mutex<...>>-shared.

TTL is honoured: entries written via Store::put_with_options with a non-None ttl are dropped from get / list results once their absolute expiry passes. The sweep (Store::evict_expired) cleans the map structure; callers may run it from a periodic graph if memory pressure matters.

Implementations

impl<V> InMemoryStore<V>

where V: Clone + Send + Sync + 'static,

pub fn new() -> InMemoryStore<V>

Empty store.

pub fn total_entries(&self) -> usize

Total entry count across all namespaces, including not-yet- swept-but-expired ones. Useful for tests; production callers should run Store::evict_expired first if they care about the live count.

Trait Implementations

impl<V> Clone for InMemoryStore<V>

where V: Clone + Send + Sync + 'static,

fn clone(&self) -> InMemoryStore<V>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<V> Default for InMemoryStore<V>

where V: Clone + Send + Sync + 'static,

fn default() -> InMemoryStore<V>

Returns the “default value” for a type.

impl<V> Store<V> for InMemoryStore<V>

where V: Clone + Send + Sync + 'static,

fn put_with_options<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _ctx: &'life1 ExecutionContext, ns: &'life2 Namespace, key: &'life3 str, value: V, options: PutOptions, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, InMemoryStore<V>: 'async_trait,

Insert or replace value at (ns, key) with the supplied per-write options (TTL, future fields). This is the only required write — Self::put is a thin convenience that delegates here.

fn get<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _ctx: &'life1 ExecutionContext, ns: &'life2 Namespace, key: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<Option<V>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, InMemoryStore<V>: 'async_trait,

Look up (ns, key). Returns None if absent or expired.

fn delete<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _ctx: &'life1 ExecutionContext, ns: &'life2 Namespace, key: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, InMemoryStore<V>: 'async_trait,

Delete (ns, key). Idempotent — deleting an absent key succeeds.

fn list<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _ctx: &'life1 ExecutionContext, ns: &'life2 Namespace, prefix: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, InMemoryStore<V>: 'async_trait,

List keys under ns whose names start with prefix (or all keys if prefix is None). Order is unspecified.

fn list_namespaces<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 ExecutionContext, prefix: &'life2 NamespacePrefix, ) -> Pin<Box<dyn Future<Output = Result<Vec<Namespace>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, InMemoryStore<V>: 'async_trait,

List every Namespace under prefix that holds at least one entry. The default impl returns an empty list — backends override when they can enumerate cheaply (Postgres index scan, Redis SCAN). Order is unspecified.

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

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore<V>: 'async_trait,

Sweep expired entries. Returns the number of rows removed. Default impl returns Ok(0) — only backends that natively track TTL implement this. Operators schedule it on a timer (or trigger from cron / periodic graph) to bound store growth in deployments where the store does not auto-expire (e.g. plain put into Postgres without a TTL trigger).

fn put<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, ctx: &'life1 ExecutionContext, ns: &'life2 Namespace, key: &'life3 str, value: V, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Insert or replace value at (ns, key) with default options (no TTL). The default impl delegates to Self::put_with_options — backends only need to provide one.