HDDS-15165. Recon: Add admin REST APIs to trigger, monitor, and cancel SCM DB snapshot sync. (#10186)

Author: devmadhuu

hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/TriggerDBSyncEndpoint.java

@@ -19,10 +19,13 @@
 
 import javax.inject.Inject;
 import javax.ws.rs.GET;
+import javax.ws.rs.POST;
 import javax.ws.rs.Path;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
 import javax.ws.rs.core.Response;
+import org.apache.hadoop.hdds.scm.server.OzoneStorageContainerManager;
+import org.apache.hadoop.ozone.recon.scm.ReconStorageContainerManagerFacade;
 import org.apache.hadoop.ozone.recon.spi.OzoneManagerServiceProvider;
 
 /**
@@ -34,11 +37,14 @@
 public class TriggerDBSyncEndpoint {
 
   private OzoneManagerServiceProvider ozoneManagerServiceProvider;
+  private ReconStorageContainerManagerFacade reconScm;
 
   @Inject
   public TriggerDBSyncEndpoint(
-      OzoneManagerServiceProvider ozoneManagerServiceProvider) {
+      OzoneManagerServiceProvider ozoneManagerServiceProvider,
+      OzoneStorageContainerManager reconScm) {
     this.ozoneManagerServiceProvider = ozoneManagerServiceProvider;
+    this.reconScm = (ReconStorageContainerManagerFacade) reconScm;
   }
 
   @GET
@@ -48,4 +54,30 @@ public Response triggerOMDBSync() {
         ozoneManagerServiceProvider.triggerSyncDataFromOMImmediately();
     return Response.ok(isSuccess).build();
   }
+
+  @POST
+  @Path("scm/snapshot")
+  public Response triggerSCMDBSnapshotSync() {
+    ReconStorageContainerManagerFacade.ScmDbSnapshotTriggerResponse response =
+        reconScm.triggerScmDbSnapshotSync();
+    return response.isAccepted()
+        ? Response.accepted(response).build()
+        : Response.status(Response.Status.CONFLICT).entity(response).build();
+  }
+
+  @GET
+  @Path("scm/snapshot/status")
+  public Response getSCMDBSnapshotSyncStatus() {
+    return Response.ok(reconScm.getScmDbSnapshotSyncStatus()).build();
+  }
+
+  @POST
+  @Path("scm/snapshot/cancel")
+  public Response cancelSCMDBSnapshotSync() {
+    ReconStorageContainerManagerFacade.ScmDbSnapshotCancelResponse response =
+        reconScm.cancelScmDbSnapshotSync();
+    return response.isCancelled()
+        ? Response.ok(response).build()
+        : Response.status(Response.Status.CONFLICT).entity(response).build();
+  }
 }