Struct RowMetaMap 

pub struct RowMetaMap { /* private fields */ }

An open, memory-mapped row meta map. lookup, lookup_meta, and lookup_count are lock-free and reentrant.

Implementations

impl RowMetaMap

pub fn path_for(cache_dir: &Path, store_key: &str, version: u64) -> PathBuf

Base segment path (-v{version}): the foot of the LSM chain.

pub fn delta_path(cache_dir: &Path, store_key: &str, version: u64) -> PathBuf

Delta segment path (-d{version}): rows appended since the previous segment, layered over the base.

pub fn build( path: &Path, version: u64, entries: Vec<RowMetaEntry>, ) -> Result<()>

pub fn open(path: &Path) -> Result<Self>

pub fn version(&self) -> u64

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn lookup(&self, row_id: u64) -> Option<(&str, &str)>

Resolve a row_id to (session_id, message_id) - the cheap arm- resolution path. Never decompresses a block. None for rows appended after the build (caller falls back to a data take).

pub fn lookup_meta( &self, row_id: u64, cache: &mut Option<(usize, Vec<u8>)>, ) -> Option<RowMeta<'_>>

Resolve a row_id to its full hydration meta, decompressing the row’s search_text block (reusing cache if it already holds that block). None if unmapped (caller falls back to take_rows).

pub fn entries(&self) -> Vec<RowMetaEntry>

Reconstruct every row as an owned RowMetaEntry, decompressing each block once. Used to merge segments into a fresh base at compaction without re-reading the store.

pub fn lookup_count(&self, session_id: &str) -> Option<usize>

Whole-session message count for session_id. None if the session is not in this map (caller falls back to the session_id IN (...) scan).

pub fn lookup_max_ts(&self, session_id: &str) -> Option<i64>

Max message timestamp (micros) stored for session_id - the watermark the sync skip oracle compares against the source’s latest message timestamp. None if the session is not in this map.

Trait Implementations

impl Debug for RowMetaMap

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

Formats the value using the given formatter.