Struct CdcEmitter 

pub struct CdcEmitter { /* private fields */ }

Helper struct for building CDC events during a transaction.

Usage (in the SQL execution layer):

let mut emitter = CdcEmitter::new(cdc_log.clone(), txn_id);
emitter.insert("users", key, value);
emitter.update("users", key, new_value);
emitter.delete("users", key);
emitter.flush(); // called after successful commit

Implementations

impl CdcEmitter

pub fn new(log: Arc<CdcLog>, txn_id: u64) -> Self

pub fn insert(&mut self, table: &str, key: Vec<u8>, value: Vec<u8>)

Record an INSERT event.

pub fn update(&mut self, table: &str, key: Vec<u8>, new_value: Vec<u8>)

Record an UPDATE event.

pub fn delete(&mut self, table: &str, key: Vec<u8>)

Record a DELETE event.

pub fn schema_change(&mut self, table: &str, ddl: String)

Record a schema change event.

pub fn flush(self)

Flush all pending events to the CDC log. Call this AFTER the transaction has been committed successfully.

pub fn discard(self)

Discard all pending events (e.g., on transaction abort).

pub fn pending_count(&self) -> usize

Number of pending events.