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 clear(&self)

Remove all cached records.

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

Return a cloned snapshot of current cached records.

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.

Trait Implementations

impl Clone for RecordCache

fn clone(&self) -> RecordCache

Returns a duplicate of the value.

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

Performs copy-assignment from source.