Struct RecordCache 

pub struct RecordCache { /* private fields */ }

Thread-safe in-memory cache of ingested records keyed by record id.

Implementations

impl RecordCache

pub fn new(max_records: usize) -> Self

Create a cache capped to at most max_records live records.

pub fn ingest<I>(&self, records: I)

where I: IntoIterator<Item = DataRecord>,

Ingest a batch of records, replacing existing entries by id.

pub fn ingest_with_version<I>(&self, records: I, version: u64)

where I: IntoIterator<Item = DataRecord>,

Ingest a batch of records with an explicit version number from the global counter.

pub fn clear(&self)

Remove all cached records.

pub fn snapshot(&self) -> Vec<Arc<DataRecord>>

Return a snapshot of current cached records as Arc references (cheap clone).

pub fn ingest_count(&self) -> u64

Return the number of completed ingest operations.

pub fn wait_for_ingest(&self, last_seen: u64, timeout: Duration) -> u64

Wait until ingest count exceeds last_seen, or until timeout elapses.

pub fn wait_for_ingest_blocking(&self, last_seen: u64) -> u64

Wait indefinitely until ingest count exceeds last_seen.

pub fn is_empty(&self) -> bool

Returns true when the cache has no records.

pub fn len(&self) -> usize

Return the number of records currently cached.

pub fn sync_delta( &self, last_version: u64, ) -> (u64, Vec<Arc<DataRecord>>, Vec<RecordId>)

Return a delta of records added since last_version and record IDs evicted since last_version.

Trait Implementations

impl Clone for RecordCache

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.