Module cdc

Source

Re-exports§

pub use enumerator::*;
pub use source::*;

Modules§

enumerator
external
jni_source
source
split

Structs§

CdcProperties
Citus
Mongodb
Mysql
Postgres
SqlServer

Enums§

CdcSourceType

Constants§

CDC_AUTO_SCHEMA_CHANGE_KEY
CDC_BACKFILL_ENABLE_KEY
CDC_BACKFILL_SNAPSHOT_BATCH_SIZE_KEY
CDC_BACKFILL_SNAPSHOT_INTERVAL_KEY
CDC_CONNECTOR_NAME_SUFFIX
CDC_MONGODB_STRONG_SCHEMA_KEY
CDC_SHARING_MODE_KEY
CDC_SNAPSHOT_BACKFILL
CDC_SNAPSHOT_MODE_KEY
CDC_TRANSACTIONAL_KEY
CDC_WAIT_FOR_STREAMING_START_TIMEOUT
CITUS_CDC_CONNECTOR
MONGODB_CDC_CONNECTOR
MYSQL_CDC_CONNECTOR
POSTGRES_CDC_CONNECTOR
SQL_SERVER_CDC_CONNECTOR

Traits§

CdcSourceTypeTrait

Functions§

build_cdc_table_id
Build a unique CDC table identifier from a source ID and external table name
table_schema_exclude_additional_columns

Type Aliases§

CitusCdcProperties
MongodbCdcProperties
MysqlCdcProperties
PostgresCdcProperties
SqlServerCdcProperties