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.

extract_sql_server_change_lsn_from_offset_str

Extract SQL Server change_lsn from a CDC offset JSON string.

extract_sql_server_commit_lsn_from_offset_str

Extract SQL Server commit_lsn from a CDC offset JSON string.

parse_sql_server_lsn_str

Parse SQL Server LSN string (XXXXXXXX:XXXXXXXX:XXXX) into a comparable integer.