IKS storage support

Signed-off-by: Rohit Kulkarni <[email protected]>

Author: Rohit-Intel-Cloud

examples/resources/iks/create/main.tf

@@ -2,7 +2,7 @@ terraform {
   required_providers {
     intelcloud = {
       source = "intel/intelcloud"
-      version = "0.0.6"
+      version = "0.0.10"
     }
   }
 }
@@ -31,9 +31,9 @@ resource "intelcloud_iks_cluster" "cluster1" {
   availability_zone  = local.availability_zone
   kubernetes_version = "1.28"
 
-  # storage = {
-  #   size_in_gb = 30
-  # }
+  storage = {
+     size_in_tb = 30
+  }
 }
 
 resource "intelcloud_iks_node_group" "ng1" {

examples/resources/iks/create/terraform.tfstate

@@ -37,13 +37,13 @@ type IKSClusterModel struct {
 var UpgradableVersionAttributes = []types.String{}
 
 type IKSStorage struct {
-	Size            types.Int64  `tfsdk:"size_in_gb"`
+	Size            types.Int64  `tfsdk:"size_in_tb"`
 	State           types.String `tfsdk:"state"`
 	StorageProvider types.String `tfsdk:"storage_provider"`
 }
 
 var IKStorageAttributes = map[string]attr.Type{
-	"size_in_gb":       types.StringType,
+	"size_in_tb":       types.StringType,
 	"state":            types.StringType,
 	"storage_provider": types.StringType,
 }

internal/models/kubernetes.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"fmt"
 	"strconv"
+	"strings"
 	"terraform-provider-intelcloud/internal/models"
 	"terraform-provider-intelcloud/pkg/itacservices"
 
@@ -187,7 +188,8 @@ func (r *iksClusterResource) Create(ctx context.Context, req resource.CreateRequ
 			return
 		}
 
-		sizeNum, _ := strconv.ParseInt(storageResp.Size, 10, 64)
+		sizeStr := strings.Split(storageResp.Size, "TB")[0]
+		sizeNum, _ := strconv.ParseInt(sizeStr, 10, 64)
 		currV := models.IKSStorage{
 			Size:            types.Int64Value(sizeNum),
 			State:           types.StringValue(storageResp.State),
@@ -247,6 +249,19 @@ func (r *iksClusterResource) Read(ctx context.Context, req resource.ReadRequest,
 		ServiceCIDR: types.StringValue(iksClusterResp.Network.ServcieCIDR),
 	}
 	state.Network, diags = types.ObjectValueFrom(ctx, network.AttributeTypes(), network)
+
+	for _, v := range iksClusterResp.Storages {
+		sizeStr := strings.Split(v.Size, "TB")[0]
+		size, _ := strconv.ParseInt(sizeStr, 10, 64)
+
+		currV := models.IKSStorage{
+			Size:            types.Int64Value(size),
+			State:           types.StringValue(v.State),
+			StorageProvider: types.StringValue(v.Provider),
+		}
+		state.Storage = &currV
+	}
+
 	resp.Diagnostics.Append(diags...)
 	if resp.Diagnostics.HasError() {
 		return
@@ -333,6 +348,7 @@ func (r *iksClusterResource) Update(ctx context.Context, req resource.UpdateRequ
 			return
 		}
 	}
+
 	// Get refreshed order value from IDC Service irrespective of whether upgrade was done or skipped
 	cluster, cloudaccount, err := r.client.GetIKSClusterByClusterUUID(ctx, state.ID.ValueString())
 	if err != nil {

internal/provider/iks_cluster_resource.go

@@ -464,6 +464,7 @@ func (client *IDCServicesClient) CreateIKSStorage(ctx context.Context, in *IKSSt
 				if v.State == "Active" {
 					storage.Provider = v.Provider
 					storage.State = v.State
+					storage.Size = v.Size
 					return nil
 				} else if v.State == "Failed" {
 					return fmt.Errorf("file storage state failed")