Enum Op 

pub enum Op {
    Put {
        table_id: u64,
        rows: Vec<u8>,
    },
    Delete {
        table_id: u64,
        row_ids: Vec<RowId>,
    },
    TruncateTable {
        table_id: u64,
    },
    ExternalTableState {
        name: String,
        state: Vec<u8>,
    },
    Flush {
        table_id: u64,
        flushed_epoch: u64,
    },
    TxnCommit {
        epoch: u64,
        added_runs: Vec<AddedRun>,
    },
    TxnAbort,
    Ddl(DdlOp),
    BeforeImage {
        table_id: u64,
        row_id: RowId,
        row: Vec<u8>,
    },
    CommitTimestamp {
        unix_nanos: u64,
    },
    SpilledRows {
        table_id: u64,
        rows: Vec<u8>,
    },
}

Variants

Put

Fields

table_id: u64

rows: Vec<u8>

Delete

Fields

table_id: u64

row_ids: Vec<RowId>

TruncateTable

Fields

table_id: u64

ExternalTableState

Durable module-owned state for an external table. The payload is opaque to the core; recovery writes the last committed payloads back under _vtab/<name>/state.json.

Fields

name: String

state: Vec<u8>

Flush

System marker (txn_id == SYSTEM_TXN_ID): everything up to flushed_epoch for table_id is durable in a sorted run, so recovery may skip replaying older records for that table.

Fields

table_id: u64

flushed_epoch: u64

TxnCommit

Seals a transaction: every earlier record with the same txn_id is committed and becomes visible at epoch.

Fields

epoch: u64

added_runs: Vec<AddedRun>

TxnAbort

Aborts a transaction; its staged records are discarded on recovery.

Ddl(DdlOp)

BeforeImage

Row image captured immediately before a Delete in the same committed transaction. Recovery ignores it; durable CDC uses it for delete/update deltas. Appended last to preserve all earlier bincode discriminants.

Fields

table_id: u64

row_id: RowId

row: Vec<u8>

CommitTimestamp

Commit-timestamp ledger record written immediately before TxnCommit. Carries the physical component of the commit’s HLC timestamp (spec §8.1, micros × 1_000) for transactions sequenced through the commit log, and wall-clock UTC nanoseconds on the legacy single-table/DDL append paths. PITR uses this durable ledger to map timestamp cutoffs to commit epochs.

Fields

unix_nanos: u64

SpilledRows

Logical rows for a transaction whose normal recovery path links an immutable spilled run. Ordinary recovery ignores this duplicate payload; PITR and CDC use it after the source run has been compacted or garbage-collected. Chunks stay below the WAL reader frame limit.

Fields

table_id: u64

rows: Vec<u8>

Trait Implementations

impl Clone for Op

fn clone(&self) -> Op

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Op

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Op

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Op

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

where __S: Serializer,

Serialize this value into the given Serde serializer.