create temp CG for consistent VM snapshot for the VM which is span across multiple flexvolumes

plugins/storage/volume/ontap/src/main/java/org/apache/cloudstack/storage/feign/client/SnapshotFeignClient.java

@@ -23,6 +23,8 @@
 import feign.QueryMap;
 import feign.RequestLine;
 import org.apache.cloudstack.storage.feign.model.CliSnapshotRestoreRequest;
+import org.apache.cloudstack.storage.feign.model.ConsistencyGroup;
+import org.apache.cloudstack.storage.feign.model.ConsistencyGroupSnapshot;
 import org.apache.cloudstack.storage.feign.model.FlexVolSnapshot;
 import org.apache.cloudstack.storage.feign.model.SnapshotFileRestoreRequest;
 import org.apache.cloudstack.storage.feign.model.response.JobResponse;
@@ -181,4 +183,96 @@ JobResponse restoreFileFromSnapshot(@Param("authHeader") String authHeader,
     @Headers({"Authorization: {authHeader}", "Content-Type: application/json"})
     JobResponse restoreFileFromSnapshotCli(@Param("authHeader") String authHeader,
                                            CliSnapshotRestoreRequest request);
+
+    /**
+     * Creates a consistency group.
+     *
+     * <p>ONTAP REST: {@code POST /api/application/consistency-groups}</p>
+     *
+     * @param authHeader Basic auth header
+     * @param request consistency group create request body
+     * @return JobResponse containing the async job reference
+     */
+    @RequestLine("POST /api/application/consistency-groups")
+    @Headers({"Authorization: {authHeader}", "Content-Type: application/json"})
+    JobResponse createConsistencyGroup(@Param("authHeader") String authHeader,
+                                       ConsistencyGroup request);
+
+    /**
+     * Lists consistency groups.
+     *
+     * <p>ONTAP REST: {@code GET /api/application/consistency-groups}</p>
+     *
+     * @param authHeader Basic auth header
+     * @param queryParams Optional query parameters
+     * @return Paginated consistency group records
+     */
+    @RequestLine("GET /api/application/consistency-groups")
+    @Headers({"Authorization: {authHeader}"})
+    OntapResponse<ConsistencyGroup> getConsistencyGroups(@Param("authHeader") String authHeader,
+                                                       @QueryMap Map<String, Object> queryParams);
+
+    /**
+     * Creates (starts) a consistency group snapshot.
+     *
+     * <p>ONTAP REST: {@code POST /api/application/consistency-groups/{cgUuid}/snapshots}</p>
+     *
+     * @param authHeader Basic auth header
+     * @param cgUuid consistency group UUID
+     * @param request snapshot start request body
+     * @return JobResponse containing the async job reference
+     */
+    @RequestLine("POST /api/application/consistency-groups/{cgUuid}/snapshots")
+    @Headers({"Authorization: {authHeader}", "Content-Type: application/json"})
+    JobResponse createConsistencyGroupSnapshot(@Param("authHeader") String authHeader,
+                                               @Param("cgUuid") String cgUuid,
+                                               ConsistencyGroupSnapshot request);
+
+    /**
+     * Lists snapshots for a consistency group.
+     *
+     * <p>ONTAP REST: {@code GET /api/application/consistency-groups/{cgUuid}/snapshots}</p>
+     *
+     * @param authHeader Basic auth header
+     * @param cgUuid consistency group UUID
+     * @param queryParams Optional query parameters
+     * @return Paginated consistency group snapshot records
+     */
+    @RequestLine("GET /api/application/consistency-groups/{cgUuid}/snapshots")
+    @Headers({"Authorization: {authHeader}"})
+    OntapResponse<ConsistencyGroupSnapshot> getConsistencyGroupSnapshots(@Param("authHeader") String authHeader,
+                                                                         @Param("cgUuid") String cgUuid,
+                                                                         @QueryMap Map<String, Object> queryParams);
+
+    /**
+     * Commits a started consistency group snapshot.
+     *
+     * <p>ONTAP REST: {@code PATCH /api/application/consistency-groups/{cgUuid}/snapshots/{snapshotUuid}}</p>
+     *
+     * @param authHeader Basic auth header
+     * @param cgUuid consistency group UUID
+     * @param snapshotUuid consistency group snapshot UUID
+     * @param request commit request body
+     * @return JobResponse containing the async job reference
+     */
+    @RequestLine("PATCH /api/application/consistency-groups/{cgUuid}/snapshots/{snapshotUuid}")
+    @Headers({"Authorization: {authHeader}", "Content-Type: application/json"})
+    JobResponse commitConsistencyGroupSnapshot(@Param("authHeader") String authHeader,
+                                               @Param("cgUuid") String cgUuid,
+                                               @Param("snapshotUuid") String snapshotUuid,
+                                               ConsistencyGroupSnapshot request);
+
+    /**
+     * Deletes a consistency group.
+     *
+     * <p>ONTAP REST: {@code DELETE /api/application/consistency-groups/{cgUuid}}</p>
+     *
+     * @param authHeader Basic auth header
+     * @param cgUuid consistency group UUID
+     * @return JobResponse containing the async job reference
+     */
+    @RequestLine("DELETE /api/application/consistency-groups/{cgUuid}")
+    @Headers({"Authorization: {authHeader}"})
+    JobResponse deleteConsistencyGroup(@Param("authHeader") String authHeader,
+                                       @Param("cgUuid") String cgUuid);
 }

plugins/storage/volume/ontap/src/main/java/org/apache/cloudstack/storage/lifecycle/OntapPrimaryDatastoreLifecycle.java

@@ -142,6 +142,9 @@ public DataStore initialize(Map<String, Object> dsInfos) {
             }
             logger.info("Using Data LIF for storage access: " + dataLIF);
             details.put(OntapStorageConstants.DATA_LIF, dataLIF);
+            if (storageStrategy.getResolvedSvmUuid() != null && !storageStrategy.getResolvedSvmUuid().isEmpty()) {
+                details.put(OntapStorageConstants.SVM_UUID, storageStrategy.getResolvedSvmUuid());
+            }
             logger.info("Creating ONTAP volume '" + storagePoolName + "' with size: " + capacityBytes + " bytes (" +
                     (capacityBytes / (1024 * 1024 * 1024)) + " GB)");
             try {