Crate faucet_source_mssql_cdc 

Microsoft SQL Server CDC (change data capture) source for the faucet-stream ecosystem.

Polls native SQL Server change data capture — sys.fn_cdc_get_max_lsn() for the high-water LSN, then cdc.fn_cdc_get_all_changes_<capture_instance>() per configured capture instance — and emits per-row change events as CDC envelopes, resumable via a per-instance LSN bookmark. Each committed transaction is emitted as its own StreamPage, giving per-transaction durability and exactly-once-capable replay.

Pair the emitted {op, before, after, …} envelopes with the cdc_unwrap transform stage and an upsert-capable sink to build a live mirror pipeline.

Structs

Bookmarks

Per-capture-instance LSN bookmark map. Ordered (BTreeMap) so serialization is deterministic.

Lsn

A SQL Server change data capture Log Sequence Number.

MssqlCdcSource

A configured Microsoft SQL Server CDC source.

MssqlCdcSourceConfig

Configuration for the Microsoft SQL Server CDC source.

Enums

OnGap

What to do when a run resumes behind the capture instance’s retained minimum LSN — the CDC cleanup job purged changes before they were read.

StartPosition

Where to start reading changes on a fresh run (no persisted bookmark).

Constants

DESCRIPTOR

The connector’s static descriptor (RFC 0013): its capabilities, answered from config alone.