Struct MutationEvents 

pub struct MutationEvents { /* private fields */ }

In-memory, untyped event log drained from tx_l0. Held by value across the commit boundary and filtered per-route on dispatch.

Implementations

impl MutationEvents

pub fn from_l0(l0: &L0Buffer) -> Self

Drain the tx-private L0 buffer into a typed event log without a committed-state probe. Every non-tombstoned write emits an UPDATE event; old_value is None. Equivalent to Self::from_l0_with_probe with probe = None.

pub fn from_l0_with_probe( l0: &L0Buffer, probe: Option<&PreExistingProbe>, properties_referenced: &HashSet<String>, ) -> Self

Drain the tx-private L0 buffer into a typed event log.

When probe is supplied, the probe distinguishes CREATE from UPDATE per-VID/EID and supplies the pre-image bytes used to populate old_value for BeforeCommit triggers. When probe is None, every write emits UPDATE and old_value stays None (legacy behavior — kept for callers that don’t yet build a probe).

Multi-label vertices emit one row per label so a label-filtered trigger fires exactly once per (vid, matching-label) pair. Vertices with no labels emit a single row with an empty label so unfiltered triggers still observe them.

pub fn materialize_all(&self) -> Option<RecordBatch>

Project every captured row into the canonical event_row_schema RecordBatch, with no per-route filtering and no predicate.

Used by the CDC delivery path to hand subscribers the full stream of mutations for a committed transaction (M11 FU-4). The per-trigger filtered shape is built by Self::filter_for.

Returns None when there are zero rows (lets callers skip constructing an empty CdcBatch).