Skip to main content

decode_remap_data_until_geq_external_frontier

mz_storage_controller::rtr

Function decode_remap_data_until_geq_external_frontier 

Source 
async fn decode_remap_data_until_geq_external_frontier<FromTime: SourceTimestamp>(
    id: GlobalId,
    external_frontier: Antichain<FromTime>,
    as_of: Antichain<Timestamp>,
    remap_subscribe: Subscribe<SourceData, (), Timestamp, StorageDiff>,
) -> Result<Timestamp, StorageError>