Struct ChangeDataCapture 

pub struct ChangeDataCapture { /* private fields */ }

Change Data Capture engine.

Implementations

impl ChangeDataCapture

pub fn new(table: Table) -> Self

pub async fn changes_between( &self, from_snapshot_id: i64, to_snapshot_id: i64, ) -> Result<Vec<RowChange>>

Returns changes between two snapshots.

pub async fn changes_since(&self, snapshot_id: i64) -> Result<Vec<RowChange>>

Returns changes since a given snapshot up to the current snapshot.

pub async fn save_checkpoint( &self, checkpoint: &Checkpoint, name: &str, ) -> Result<()>

Saves a checkpoint for incremental reads.

pub async fn load_checkpoint(&self, name: &str) -> Result<Checkpoint>

Loads a checkpoint for incremental reads.

pub async fn changes_since_checkpoint( &self, name: &str, ) -> Result<Vec<RowChange>>

Returns changes since the last checkpoint.