async fn run_versioned_upgrade<V1: IntoStateUpdateKindJson, V2: IntoStateUpdateKindJson>(
unopened_catalog_state: &mut PersistHandle<StateUpdateKindJson, UnopenedCatalogStateInner>,
current_version: u64,
migration_logic: impl FnOnce(Vec<V1>) -> Vec<MigrationAction<V1, V2>>,
) -> Result<u64, CatalogError>
Expand description
Runs migration_logic
on the contents of the current catalog assuming a current version of
current_version
.
Returns the new version and upper.