Struct TimestampTableConfig 

pub struct TimestampTableConfig {
    pub table_name: String,
    pub created_at_column: String,
    pub updated_at_column: String,
    pub primary_key: Vec<String>,
    pub columns: Vec<String>,
}

Per-table configuration for timestamp-based CDC polling.

Identifies the columns that the consumer reads to build the watermark predicate and to classify events as inserts vs updates.

Fields

table_name: String

Name of the table in the external source database.

created_at_column: String

Column that records when the row was first created.

Used together with Self::updated_at_column for the INSERT/UPDATE heuristic: if created_at == updated_at the row is treated as a new insert; otherwise it is treated as an update.

updated_at_column: String

Column that records when the row was last modified.

This is the primary watermark column. The poll query filters WHERE updated_at > watermark_ts (with composite-PK tie-breaking).

primary_key: Vec<String>

Names of the primary key columns, in declaration order.

Must contain at least one entry. Used for:

• Watermark tie-breaking when multiple rows share the same updated_at.
• Setting rhei_core::CdcEvent::row_id from the first PK column.
• SQL tuple comparison in the poll predicate for composite PKs.

columns: Vec<String>

Explicit list of columns to include in SELECT.

When empty the consumer issues SELECT * and all columns are included. Provide an explicit list to reduce bandwidth or exclude columns irrelevant to the OLAP workload.

Trait Implementations

impl Clone for TimestampTableConfig

fn clone(&self) -> TimestampTableConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TimestampTableConfig

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

Formats the value using the given formatter.