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)

pub async fn upsert_with_append( &self, view_id: &str, key: &str, patch: Value, append_paths: &[String], )

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_after( &self, view_id: &str, cursor: &str, limit: Option<usize>, ) -> Vec<(String, Value)>

Get entities with _seq greater than the provided cursor.

Returns entities that have been updated after the given cursor, sorted by _seq in ascending order. Useful for resuming from a specific point in the stream.

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

Get a specific entity from the cache

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

Remove one entity after a source-wide delete.

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 fn snapshot_config(&self) -> SnapshotBatchConfig

Get the snapshot batch configuration

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

Clear all cached entities for a view

pub async fn clear_all(&self)

pub async fn stats(&self) -> CacheStats

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.