Skip to main content

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. object_version_by_checkpoint and package_versions – history- cohort members whose floor rows are bulk-loaded from the live set (the history seed separately rewinds their watermarks so they also backfill (L, T]) – are registered only when layer.history_floors is set; a caller whose history cohort replays from genesis leaves them to the backfill. 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.