Updated variable name

Signed-off-by: Arashad Ahamad <[email protected]>

Author: arahamad

Diff for: deploy/kubernetes/storageclass/ibmc-vpc-block-sdp-StorageClass.yaml

@@ -6,7 +6,7 @@ provisioner: vpc.block.csi.ibm.io
 parameters:
   profile: "sdp"
   iops: "100"
-  bandwidth: "1000"
+  throughput: "1000"
   csi.storage.k8s.io/fstype: "ext4"
   billingType: "hourly"
   encrypted: "false"

Diff for: pkg/ibmcsidriver/constants.go

@@ -129,8 +129,8 @@ const (
 	// MinimumSDPVolumeSizeInBytes ... This is minimum size require for sdp (acadia profile)
 	MinimumSDPVolumeSizeInBytes int64 = 1 * utils.GiB
 
-	// Bandwidth ...
-	Bandwidth = "bandwidth"
+	// Throughput ...
+	Throughput = "throughput"
 )
 
 // SupportedFS the supported FS types

Diff for: pkg/ibmcsidriver/controller_helper.go

@@ -168,7 +168,7 @@ func getVolumeParameters(logger *zap.Logger, req *csi.CreateVolumeRequest, confi
 				iops := value
 				volume.Iops = &iops
 			}
-		case Bandwidth: // getting bandwidth value from storage class if it is provided
+		case Throughput: // getting throughput value from storage class if it is provided
 			if len(value) != 0 {
 				bandwidth, err := strconv.ParseInt(value, 10, 32)
 				if err != nil {
@@ -326,6 +326,15 @@ func overrideParams(logger *zap.Logger, req *csi.CreateVolumeRequest, config *co
 				iops := value
 				volume.Iops = &iops
 			}
+		case Throughput: // getting throughput value from storage class if it is provided
+			if len(value) != 0 {
+				bandwidth, err := strconv.ParseInt(value, 10, 32)
+				if err != nil {
+					err = fmt.Errorf("'<%v>' is invalid, value of '%s' should be an int32 type", value, key)
+				} else {
+					volume.Bandwidth = int32(bandwidth)
+				}
+			}
 		default:
 			err = fmt.Errorf("<%s> is an invalid parameter", key)
 		}