Struct Memtable 

pub struct Memtable { /* private fields */ }

Structurally shared committed overlays plus one small mutable write delta.

Implementations

impl Memtable

pub fn new() -> Self

pub fn upsert(&mut self, row: Row)

Append a row version (keyed by (row_id, committed_epoch)). Versions are never overwritten; the newest visible one wins at read time.

pub fn tombstone(&mut self, row_id: RowId, epoch: Epoch)

Append a tombstone version for row_id at epoch. The tombstone copies the columns from the newest live version so that engine-level HOT cleanup can recover the primary-key value during WAL replay.

pub fn get(&self, row_id: RowId, snapshot_epoch: Epoch) -> Option<Row>

Read the row at row_id visible to snapshot: the newest version with epoch <= snapshot. Returns None if that version is a tombstone (or no such version exists).

pub fn get_version( &self, row_id: RowId, snapshot_epoch: Epoch, ) -> Option<(Epoch, Row)>

Newest version of row_id with epoch <= snapshot, including tombstones (as a Row with deleted=true). Legacy epoch-only entry point; prefer Self::get_version_at when the caller holds a full crate::epoch::Snapshot.

pub fn get_version_at( &self, row_id: RowId, snapshot: Snapshot, ) -> Option<(Epoch, Row)>

Newest version of row_id visible under snapshot (including tombstones). Uses HLC authority when stamps are present (P0.5-T3).

Seeks each segment’s composite-key range for row_id so dual-model mixes (stamped + unstamped) and HLC/epoch order inversions stay correct without materializing every version in the memtable.

pub fn len(&self) -> usize

Number of stored versions.

pub fn is_empty(&self) -> bool

pub fn approx_bytes(&self) -> u64

pub fn visible_rows(&self, snapshot_epoch: Epoch) -> Vec<Row>

Visible rows at snapshot, deduplicated to the newest version per RowId (tombstones drop their row). Returned in ascending RowId order.

pub fn visible_versions(&self, snapshot_epoch: Epoch) -> Vec<Row>

Newest visible version per RowId at snapshot, including tombstones (as Rows with deleted=true). Used by the engine to merge versions across the memtable and sorted runs.

pub fn visible_versions_at(&self, snapshot: Snapshot) -> Vec<Row>

pub fn newest_visible_iter<'a>( &'a self, snapshot: &Snapshot, ) -> MemtableVisibleVersionCursor<'a>

pub fn drain_sorted(&mut self) -> Vec<Row>

Drain all versions (for a memtable-to-run flush). Returns them in ascending (RowId, Epoch) order.

Trait Implementations

impl Clone for Memtable

fn clone(&self) -> Memtable

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Memtable

fn default() -> Self

Returns the “default value” for a type.