pub async fn get_min_lsns(
client: &mut Client,
capture_instances: impl IntoIterator<Item = &str>,
) -> Result<BTreeMap<Arc<str>, Lsn>, SqlServerError>
Expand description
Retrieves the minumum Lsn
(start_lsn field) from cdc.change_tables
for the specified capture instances.
This is based on the sys.fn_cdc_get_min_lsn
implementation, which has logic
that we want to bypass. Specifically, sys.fn_cdc_get_min_lsn
returns NULL
if the start_lsn
in cdc.change_tables
is less than or equal to the LSN
returned by sys.fn_cdc_get_max_lsn
.