restore_indexes

Function restore_indexes 

Source
pub fn restore_indexes<Src: RestoreSource>(
    db: Db,
    schema: Arc<RpcStoreSchema>,
    source: Src,
    config: RestoreDriverConfig,
    layer: RestoreLayer,
    metrics: Arc<RestoreMetrics>,
) -> Result<Service>
Expand description

Register every Restore-implementing pipeline opted in by layer on a [RestoreDriver] bound to db / schema and source, then run the resulting Service.

The live-cohort pipelines are always registered, plus object_version_by_checkpoint and package_versions – history- cohort members whose floor rows are bulk-loaded from the live set here (the history seed separately rewinds their watermarks so they also backfill (L, T]). The raw Objects pipeline is only registered when layer.objects is set. The returned Service’s primary task completes once every registered pipeline transitions to RestoreState::Complete.