risingwave_meta::barrier::cdc_progress

Function restore_progress

Source 
async fn restore_progress(
    meta_store: &SqlMetaStore,
) -> MetaResult<HashMap<u32, (u64, bool)>>