Struct CdcLog 

pub struct CdcLog { /* private fields */ }

An ordered log of CDC events.

Events are kept in LSN order. The log supports appending, serialisation to a newline-delimited JSON file, and replay.

Implementations

impl CdcLog

pub fn new() -> Self

Create an empty log starting at LSN 0.

pub fn with_start_lsn(start: u64) -> Self

Create a log with a specific starting LSN.

pub fn push(&mut self, event: CdcEvent)

Append a pre-built event (its existing LSN is preserved; next_lsn is advanced if needed to stay consistent).

pub fn insert( &mut self, ts_ms: i64, table: impl Into<String>, after: RowImage, ) -> u64

Append an INSERT and auto-assign the next LSN.

pub fn update( &mut self, ts_ms: i64, table: impl Into<String>, before: RowImage, after: RowImage, ) -> u64

Append an UPDATE and auto-assign the next LSN.

pub fn delete( &mut self, ts_ms: i64, table: impl Into<String>, before: RowImage, ) -> u64

Append a DELETE and auto-assign the next LSN.

pub fn len(&self) -> usize

Number of events in the log.

pub fn is_empty(&self) -> bool

Returns true if the log contains no events.

pub fn events(&self) -> &[CdcEvent]

Iterate over all events in LSN order.

pub fn events_for_table(&self, table: &str) -> Vec<&CdcEvent>

Filter events for a single table.

pub fn write_ndjson<W: Write>(&self, writer: W) -> Result<()>

Serialize the log to newline-delimited JSON (NDJSON).

pub fn read_ndjson<R: BufRead>(reader: R) -> Result<Self>

Deserialize a log from newline-delimited JSON produced by write_ndjson.

Trait Implementations

impl Debug for CdcLog

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

Formats the value using the given formatter.

impl Default for CdcLog

fn default() -> CdcLog

Returns the “default value” for a type.