Module split 

Macros

dispatch_cdc_split 🔒

dispatch_cdc_split_inner 🔒

Structs

CdcSplitBase

The base states of a CDC split, which will be persisted to checkpoint. CDC source only has single split, so we use the source_id to identify the split.

DebeziumCdcSplit

We use this struct to wrap the specific split, which act as an interface to other modules

MongoDbCdcSplit

MySqlCdcSplit

PostgresCdcSplit

SqlServerCdcSplit

Traits

CdcSplitTrait 🔒

Functions

extract_postgres_lsn_from_offset_str

Extract PostgreSQL LSN value from a CDC offset JSON string.