Trait RecordStore 

pub trait RecordStore: Send + Sync {
    // Required methods
    fn insert(&self, record: Record);
    fn get(&self, id: RecordId) -> Option<Cow<'_, Record>>;
    fn len(&self) -> usize;

    // Provided methods
    fn get_many(&self, ids: &[RecordId]) -> Vec<Option<Cow<'_, Record>>> { ... }
    fn is_empty(&self) -> bool { ... }
}

Backing store for records used during ingestion and batch runs.

Required Methods

fn insert(&self, record: Record)

Persist a record. Must be callable from the ingester background task.

fn get(&self, id: RecordId) -> Option<Cow<'_, Record>>

Retrieve a single record by ID. Returns None if not present.

fn len(&self) -> usize

Total number of records held.

Provided Methods

fn get_many(&self, ids: &[RecordId]) -> Vec<Option<Cow<'_, Record>>>

Retrieve multiple records in one call (allows batch I/O optimisation). The default impl calls get in a loop; override for bulk reads.

fn is_empty(&self) -> bool

Implementors

impl RecordStore for VecRecordStore