Struct CdcEvent 

pub struct CdcEvent {
    pub lsn: u64,
    pub source_ts_ms: i64,
    pub table: String,
    pub operation: CdcOperation,
    pub before: Option<RowImage>,
    pub after: Option<RowImage>,
    pub transaction_id: Option<String>,
}

A single CDC event with before/after row images.

Fields

lsn: u64

Log Sequence Number — monotonically increasing.

source_ts_ms: i64

Wall-clock timestamp (Unix millis) when the change occurred in the source.

table: String

Database/schema/table this event belongs to.

operation: CdcOperation

The type of change.

before: Option<RowImage>

Row image before the change (None for INSERT/READ).

after: Option<RowImage>

Row image after the change (None for DELETE).

transaction_id: Option<String>

Optional transaction identifier.

Implementations

impl CdcEvent

pub fn insert( lsn: u64, ts_ms: i64, table: impl Into<String>, after: RowImage, ) -> Self

Create an INSERT event.

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

Create an UPDATE event.

pub fn delete( lsn: u64, ts_ms: i64, table: impl Into<String>, before: RowImage, ) -> Self

Create a DELETE event.

Trait Implementations

impl Clone for CdcEvent

fn clone(&self) -> CdcEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CdcEvent

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

Formats the value using the given formatter.