Enum ColumnarWalRecord 

#[non_exhaustive]
pub enum ColumnarWalRecord {
    InsertRow {
        collection: String,
        row_data: Vec<u8>,
    },
    DeleteRows {
        collection: String,
        segment_id: u64,
        row_indices: Vec<u32>,
    },
    CompactionCommit {
        collection: String,
        old_segment_ids: Vec<u64>,
        new_segment_ids: Vec<u64>,
    },
    MemtableFlushed {
        collection: String,
        segment_id: u64,
        row_count: u64,
    },
}

A WAL record for a columnar collection operation.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

InsertRow

A row was inserted into the memtable.

Contains the collection name and the row data as packed binary (the columnar wire format, not MessagePack). On replay, the row is re-inserted into the memtable.

Fields

collection: String

row_data: Vec<u8>

Row data as packed binary values. Each value is encoded per its column type: i64 as 8 LE bytes, f64 as 8 LE bytes, strings as length-prefixed UTF-8, etc.

DeleteRows

Rows were marked as deleted in a segment’s delete bitmap.

On replay, these row indices are re-applied to the segment’s delete bitmap.

Fields

collection: String

segment_id: u64

row_indices: Vec<u32>

CompactionCommit

A compaction was committed: old segments replaced with new ones.

This is the atomic commit point of the 3-phase compaction protocol. On replay:

• If new segments exist on disk: complete the metadata swap.
• If new segments don’t exist: the compaction was interrupted before writing; discard and treat old segments as authoritative.

Fields

collection: String

old_segment_ids: Vec<u64>

new_segment_ids: Vec<u64>

MemtableFlushed

The memtable was flushed to a new segment.

On replay, if the segment file exists, update metadata to include it. If it doesn’t exist, the flush was interrupted; rows are already in the memtable via InsertRow records.

Fields

collection: String

segment_id: u64

row_count: u64

Implementations

impl ColumnarWalRecord

pub fn collection(&self) -> &str

Collection name this record belongs to.

pub fn to_bytes(&self) -> Result<Vec<u8>, ColumnarError>

Serialize the record to bytes.

pub fn from_bytes(data: &[u8]) -> Result<Self, ColumnarError>

Deserialize a record from bytes.

Trait Implementations

impl Clone for ColumnarWalRecord

fn clone(&self) -> ColumnarWalRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ColumnarWalRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ColumnarWalRecord

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'__msgpack_de> FromMessagePack<'__msgpack_de> for ColumnarWalRecord

fn read<R: Read<'__msgpack_de>>(reader: &mut R) -> Result<Self, Error>

where Self: Sized,

Reads the MessagePack representation of this value from the provided reader.

impl Serialize for ColumnarWalRecord

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToMessagePack for ColumnarWalRecord

fn write<W: Write>(&self, writer: &mut W) -> Result<(), Error>

Writes the MessagePack representation of this value into the provided writer.