Struct MutationEngine 

pub struct MutationEngine { /* private fields */ }

Coordinates all columnar mutations for a single collection.

Owns the memtable, PK index, and per-segment delete bitmaps. Produces WAL records for each mutation that the caller must persist.

Implementations

impl MutationEngine

pub fn new(collection: String, schema: ColumnarSchema) -> Self

Create a new mutation engine for a collection.

pub fn insert( &mut self, values: &[Value], ) -> Result<MutationResult, ColumnarError>

Insert a row. Returns WAL record to persist.

Validates schema, checks PK uniqueness, adds to memtable and PK index.

pub fn delete( &mut self, pk_value: &Value, ) -> Result<MutationResult, ColumnarError>

Delete a row by PK value. Returns WAL record to persist.

Looks up PK in the index to find the segment + row, then marks the row in the segment’s delete bitmap.

pub fn update( &mut self, old_pk: &Value, new_values: &[Value], ) -> Result<MutationResult, ColumnarError>

Update a row by PK: DELETE old + INSERT new.

updates maps column names to new values. Columns not in the map retain their existing values from the old row.

Returns WAL records for both the delete and the insert.

NOTE: The caller must provide the full old row values for the re-insert. This method takes the complete new row (already merged with old values).

pub fn on_memtable_flushed(&mut self, new_segment_id: u32) -> MutationResult

Notify the engine that the memtable was flushed to a new segment.

Updates the PK index to remap memtable entries to the new segment. Returns the WAL record for the flush event.

pub fn on_compaction_complete( &mut self, old_segment_ids: &[u32], new_segment_id: u32, row_mapping: &HashMap<(u32, u32), u32>, ) -> MutationResult

Notify the engine that compaction completed.

Remaps PK index entries and removes old delete bitmaps.

pub fn memtable(&self) -> &ColumnarMemtable

Access the memtable.

pub fn memtable_mut(&mut self) -> &mut ColumnarMemtable

Mutable access to the memtable (for drain on flush).

pub fn pk_index(&self) -> &PkIndex

Access the PK index.

pub fn pk_index_mut(&mut self) -> &mut PkIndex

Mutable access to the PK index (for cold-start rebuild).

pub fn delete_bitmap(&self, segment_id: u32) -> Option<&DeleteBitmap>

Access a segment’s delete bitmap.

pub fn delete_bitmaps(&self) -> &HashMap<u32, DeleteBitmap>

Access all delete bitmaps.

pub fn collection(&self) -> &str

The collection name.

pub fn schema(&self) -> &ColumnarSchema

The schema.

pub fn should_flush(&self) -> bool

Whether the memtable should be flushed.

pub fn scan_memtable_rows(&self) -> impl Iterator<Item = Vec<Value>> + '_

Iterate non-deleted rows in the memtable as Vec<Value>.

Skips rows marked as deleted in the memtable’s virtual segment delete bitmap. For rows in flushed segments, use SegmentReader.

pub fn get_memtable_row(&self, row_idx: usize) -> Option<Vec<Value>>

Get a single row from the memtable by index (None if deleted).

pub fn should_compact(&self, segment_id: u32, total_rows: u64) -> bool

Whether a segment should be compacted based on its delete ratio.