Struct ChangeReaderConfig 

pub struct ChangeReaderConfig {
    pub start_snapshot_id: Option<SnapshotId>,
    pub end_snapshot_id: Option<SnapshotId>,
    pub pk_columns: Vec<String>,
    pub coalesce_updates: bool,
}

Configuration for read_changes.

Fields

start_snapshot_id: Option<SnapshotId>

Start snapshot (inclusive). When None, the parent of end_snapshot_id is used.

end_snapshot_id: Option<SnapshotId>

End snapshot (inclusive). When None, the current snapshot is used.

pk_columns: Vec<String>

Primary-key column names. Required for update coalescing.

coalesce_updates: bool

When true, convert a DELETE + INSERT pair with the same PK within the same snapshot into UPDATE_BEFORE + UPDATE_AFTER.

Trait Implementations

impl Clone for ChangeReaderConfig

fn clone(&self) -> ChangeReaderConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangeReaderConfig

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

Formats the value using the given formatter.

impl Default for ChangeReaderConfig

fn default() -> ChangeReaderConfig

Returns the “default value” for a type.