Struct JsonlRfMemory 

pub struct JsonlRfMemory { /* private fields */ }

A file-backed RfMemoryStore. See the module docs for the on-disk format.

Implementations

impl JsonlRfMemory

pub fn create(path: impl AsRef<Path>) -> Result<Self, RvcsiError>

Create a new, empty store at path, truncating any existing file.

pub fn open(path: impl AsRef<Path>) -> Result<Self, RvcsiError>

Open an existing store at path, replaying every line into the in-memory index, then positioning for appends. The file must exist (use JsonlRfMemory::create otherwise).

pub fn path(&self) -> &Path

Path the store is backed by.

pub fn flush(&mut self) -> Result<(), RvcsiError>

Flush buffered writes to disk.

Trait Implementations

impl Debug for JsonlRfMemory

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RfMemoryStore for JsonlRfMemory

fn store_window(&mut self, w: &CsiWindow) -> Result<EmbeddingId, RvcsiError>

Store the embedding of w, returning its newly-minted id.

fn store_event(&mut self, e: &CsiEvent) -> Result<EmbeddingId, RvcsiError>

Store the embedding of e, returning its newly-minted id.

fn query_similar( &self, query: &[f32], k: usize, ) -> Result<Vec<SimilarHit>, RvcsiError>

Return up to k stored records most similar to query, by descending cosine similarity. Records whose embedding length differs from query (e.g. events vs. window queries) score 0.0 and so sort last.

fn set_baseline( &mut self, room: &str, version: &str, embedding: Vec<f32>, ) -> Result<(), RvcsiError>

Set (or replace) the baseline embedding for room at version.

fn compute_drift( &self, room: &str, current: &[f32], threshold: f32, ) -> Result<Option<DriftReport>, RvcsiError>

Compare current against room’s baseline. Returns None if there is no baseline for room, otherwise a DriftReport with distance = 1 - cosine_similarity(baseline, current) and exceeded = distance > threshold.

fn len(&self) -> usize

Number of stored records (windows + events; baselines are not counted).

fn is_empty(&self) -> bool

Whether RfMemoryStore::len is zero.