v1.16.0

pkg/cloudbroker/disks/migrate.go

@@ -26,16 +26,51 @@ type MigrateRequest struct {
 	StoragePolicyID uint64 `url:"storage_policy_id" json:"storage_policy_id" validate:"required"`
 }
 
-// Move moves disk to another sep, pool and storage policy
+type wrapperMigrateRequest struct {
+	MigrateRequest
+
+	AsyncMode bool `url:"async_mode" json:"async_mode"`
+}
+
+// Move moves disk to another sep, pool and storage policy in sync mode
 func (c Disks) Migrate(ctx context.Context, req MigrateRequest) (string, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
 		return "", validators.ValidationErrors(validators.GetErrors(err))
 	}
 
+	wrappedReq := wrapperMigrateRequest{
+		MigrateRequest: req,
+		AsyncMode:      false,
+	}
+
 	url := "/cloudbroker/disks/migrate"
 
-	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, wrappedReq)
+	if err != nil {
+		return "", err
+	}
+
+	result := string(res)
+
+	return result, nil
+}
+
+// Move moves disk to another sep, pool and storage policy in async mode
+func (c Disks) MigrateAsync(ctx context.Context, req MigrateRequest) (string, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return "", validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	wrappedReq := wrapperMigrateRequest{
+		MigrateRequest: req,
+		AsyncMode:      true,
+	}
+
+	url := "/cloudbroker/disks/migrate"
+
+	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, wrappedReq)
 	if err != nil {
 		return "", err
 	}