create version swap service in the controller

linkedin · Jan 15, 2025 · e6dbf34 · e6dbf34
1 parent aec7d8f
commit e6dbf34
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...ices/venice-controller/src/main/java/com/linkedin/venice/controller/VeniceController.java b/...ices/venice-controller/src/main/java/com/linkedin/venice/controller/VeniceController.java
@@ -162,6 +162,7 @@ public VeniceController(VeniceControllerContext ctx) {
     this.unusedValueSchemaCleanupService = createUnusedValueSchemaCleanupService();
     this.storeGraveyardCleanupService = createStoreGraveyardCleanupService();
     this.systemStoreRepairService = createSystemStoreRepairService();
+    this.deferredVersionSwapService = createDeferredVersionSwapService();
     if (multiClusterConfigs.isGrpcServerEnabled()) {
       initializeGrpcServer();
     }
@@ -275,6 +276,14 @@ private Optional<UnusedValueSchemaCleanupService> createUnusedValueSchemaCleanup
     return Optional.empty();
   }
 
+  private Optional<DeferredVersionSwapService> createDeferredVersionSwapService() {
+    if (multiClusterConfigs.isParent()) {
+      Admin admin = controllerService.getVeniceHelixAdmin();
+      return Optional.of(new DeferredVersionSwapService((VeniceParentHelixAdmin) admin, multiClusterConfigs));
+    }
+    return Optional.empty();
+  }
+
   // package-private for testing
   private void initializeGrpcServer() {
     LOGGER.info("Initializing gRPC server as it is enabled for the controller...");