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.