Struct ReactiveMap 

pub struct ReactiveMap<K, V>
where
    K: Clone + Eq + Hash + Send + Sync + 'static,
    V: Clone + Send + Sync + 'static,
{
    pub node_id: NodeId,
    /* private fields */
}

Reactive key-value map.

Emits Vec<(K, V)> snapshots via a Core state node on every mutation. (Vec of pairs rather than HashMap for serialization stability.)

Fields

node_id: NodeId

Implementations

impl<K, V> ReactiveMap<K, V>

where K: Clone + Eq + Hash + Send + Sync + 'static, V: Clone + Send + Sync + 'static,

pub fn new( core: &Core, intern: InternFn<Vec<(K, V)>>, opts: ReactiveMapOptions<K, V>, ) -> Result<Self, MapConfigError>

Create a new reactive map.

Errors

Returns MapConfigError if both max_size (LRU) and retention are set.

pub fn size(&self) -> usize

pub fn has(&self, core: &Core, key: &K) -> bool

Check if key exists. Expired keys are pruned (observable side-effect). LRU touch: live key is marked as most-recently-used (no emission).

pub fn get(&self, core: &Core, key: &K) -> Option<V>

Get value by key. Expired keys return None (observable side-effect). LRU touch: live key is marked as most-recently-used (no emission).

pub fn set(&self, core: &Core, key: K, value: V)

pub fn set_with_ttl(&self, core: &Core, key: K, value: V, ttl: Option<f64>)

Set a key with an optional per-call TTL override (seconds).

Panics

Panics if ttl is Some with a non-positive or non-finite value.

pub fn set_many(&self, core: &Core, entries: Vec<(K, V)>)

pub fn set_many_with_ttl( &self, core: &Core, entries: Vec<(K, V)>, ttl: Option<f64>, )

Batch set with optional per-call TTL override (seconds).

Panics

Panics if ttl is Some with a non-positive or non-finite value.

pub fn delete(&self, core: &Core, key: &K)

pub fn delete_many(&self, core: &Core, keys: &[K])

pub fn clear(&self, core: &Core)

pub fn prune_expired(&self, core: &Core) -> usize

Explicitly prune all expired keys. Returns the number of keys removed.

pub fn to_vec(&self) -> Vec<(K, V)>

pub fn mutation_log_snapshot(&self) -> Option<Vec<BaseChange<MapChange<K, V>>>>