SDKQE-3396: Add ability to modify cloud columnar instances

deployment/clouddeploy/deployer.go

@@ -978,6 +978,36 @@ func (d *Deployer) ModifyCluster(ctx context.Context, clusterID string, def *clu
 		return err
 	}
 
+	if clusterInfo.Columnar != nil {
+		d.logger.Warn("can only modify the node count for a columnar cluster")
+
+		newSpec := &capellacontrol.UpdateColumnarInstanceRequest{
+			Name:        clusterInfo.Columnar.Name,
+			Description: clusterInfo.Columnar.Description,
+			Nodes:       def.NodeGroups[0].Count,
+		}
+		err = d.client.UpdateColumnarSpecs(ctx, clusterInfo.Columnar.TenantID, clusterInfo.Columnar.ProjectID, clusterInfo.Columnar.ID, newSpec)
+		if err != nil {
+			return errors.Wrap(err, "failed to update specs")
+		}
+
+		d.logger.Debug("waiting for columnar modification to begin")
+
+		err = d.mgr.WaitForClusterState(ctx, d.tenantID, clusterInfo.Columnar.ID, "scaling")
+		if err != nil {
+			return errors.Wrap(err, "failed to wait for columnar modification to begin")
+		}
+
+		d.logger.Debug("waiting for columnar to be healthy")
+
+		err = d.mgr.WaitForClusterState(ctx, d.tenantID, clusterInfo.Columnar.ID, "healthy")
+		if err != nil {
+			return errors.Wrap(err, "failed to wait for columnar to be healthy")
+		}
+
+		return nil
+	}
+
 	cloudProjectID := clusterInfo.Cluster.Project.Id
 	cloudClusterID := clusterInfo.Cluster.Id
 	cloudProvider := clusterInfo.Cluster.Provider.Name

utils/capellacontrol/controller.go

@@ -725,6 +725,12 @@ type CreateColumnarInstanceRequest struct {
 	AvailabilityZone string                `json:"availabilityZone"`
 }
 
+type UpdateColumnarInstanceRequest struct {
+	Name        string `json:"name"`
+	Description string `json:"description"`
+	Nodes       int    `json:"nodes"`
+}
+
 type ColumnarInstanceTypes struct {
 	VCPUs  string `json:"vcpus"`
 	Memory string `json:"memory"`
@@ -872,6 +878,18 @@ func (c *Controller) UpdateClusterSpecs(
 	return nil
 }
 
+func (c *Controller) UpdateColumnarSpecs(
+	ctx context.Context,
+	tenantID string,
+	projectID string,
+	columnarID string,
+	req *UpdateColumnarInstanceRequest,
+) error {
+	path := fmt.Sprintf("/v2/organizations/%s/projects/%s/instance/%s", tenantID, projectID, columnarID)
+	err := c.doBasicReq(ctx, false, "PATCH", path, req, nil)
+	return err
+}
+
 type ClusterJobInfo struct {
 	JobType              string    `json:"jobType"`
 	ID                   string    `json:"id"`