Struct EntityCache 

pub struct EntityCache { /* private fields */ }

Entity cache that maintains full projected entities with LRU eviction.

The cache is populated as mutations flow through the projector, regardless of subscriber state. When a new subscriber connects, they receive snapshots of all cached entities for their requested view.

Implementations

impl EntityCache

pub fn new() -> Self

Create a new entity cache with default configuration

pub fn with_config(config: EntityCacheConfig) -> Self

Create a new entity cache with custom configuration

pub async fn upsert(&self, view_id: &str, key: &str, patch: &Value)

Upsert a patch into the cache, merging with existing entity data.

This method:

1. Gets or creates the LRU cache for the view
2. Gets or creates an empty entity for the key
3. Deep merges the patch into the entity (appending arrays)
4. Updates the LRU cache (promoting the key to most recently used)

pub async fn get_all(&self, view_id: &str) -> Vec<(String, Value)>

Get all cached entities for a view.

Returns a vector of (key, entity) pairs for sending as snapshots to new subscribers.

pub async fn get(&self, view_id: &str, key: &str) -> Option<Value>

Get a specific entity from the cache

pub async fn len(&self, view_id: &str) -> usize

Get the number of cached entities for a view

pub async fn is_empty(&self, view_id: &str) -> bool

Check if the cache for a view is empty

pub async fn clear(&self, view_id: &str)

Clear all cached entities for a view

pub async fn clear_all(&self)

Clear all caches

Trait Implementations

impl Clone for EntityCache

fn clone(&self) -> EntityCache

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for EntityCache

fn default() -> Self

Returns the “default value” for a type.