KUBE-1393: EKS config - threads per cpu added (#557)

Author: cirisked

castai/resource_node_configuration.go

@@ -273,6 +273,12 @@ func resourceNodeConfiguration() *schema.Resource {
 								return oldValue == newValue
 							},
 						},
+						"threads_per_cpu": {
+							Type:             schema.TypeInt,
+							Optional:         true,
+							Description:      "Number of threads per core.",
+							ValidateDiagFunc: validation.ToDiagFunc(validation.IntBetween(0, 256)),
+						},
 						FieldNodeConfigurationEKSImageFamily: {
 							Type:     schema.TypeString,
 							Optional: true,
@@ -935,6 +941,10 @@ func toEKSConfig(obj map[string]interface{}) *sdk.NodeconfigV1EKSConfig {
 		out.IpsPerPrefix = toPtr(int32(v))
 	}
 
+	if v, ok := obj["threads_per_cpu"].(int); ok && v != 0 {
+		out.ThreadsPerCpu = toPtr(int32(v))
+	}
+
 	if v, ok := obj[FieldNodeConfigurationEKSTargetGroup].([]any); ok && len(v) > 0 {
 		resultTGs := make([]sdk.NodeconfigV1TargetGroup, 0, len(v))
 		for _, tgRaw := range v {
@@ -1024,6 +1034,10 @@ func flattenEKSConfig(config *sdk.NodeconfigV1EKSConfig) []map[string]interface{
 		m["ips_per_prefix"] = *config.IpsPerPrefix
 	}
 
+	if v := config.ThreadsPerCpu; v != nil {
+		m["threads_per_cpu"] = *config.ThreadsPerCpu
+	}
+
 	if v := config.TargetGroups; v != nil && len(*v) > 0 {
 		tgs := make([]any, 0, len(*v))
 		for _, tg := range *v {
@@ -1162,7 +1176,6 @@ func toAKSNodePublicIP(obj any) *sdk.NodeconfigV1AKSConfigPublicIP {
 	}
 
 	return publicIP
-
 }
 
 func toAKSEphemeralOSDisk(obj any) *sdk.NodeconfigV1AKSConfigOsDiskEphemeral {
@@ -1359,7 +1372,6 @@ func fromAKSNodePublicIP(sdkPublicIp *sdk.NodeconfigV1AKSConfigPublicIP) []map[s
 	}
 
 	return []map[string]any{m}
-
 }
 
 func fromAKSEphemeralOSDisk(sdkEph *sdk.NodeconfigV1AKSConfigOsDiskEphemeral) []map[string]interface{} {
@@ -1578,7 +1590,6 @@ func toGkeUnmanagedInstanceGroups(obj []interface{}) *[]sdk.NodeconfigV1GKEConfi
 	}
 
 	return &out
-
 }
 
 func flattenGKEConfig(config *sdk.NodeconfigV1GKEConfig) []map[string]interface{} {

castai/resource_node_configuration_eks_test.go

@@ -56,6 +56,7 @@ func TestAccResourceNodeConfiguration_eks(t *testing.T) {
 					resource.TestCheckResourceAttr(resourceName, "kops.#", "0"),
 					resource.TestCheckResourceAttr(resourceName, "gke.#", "0"),
 					resource.TestCheckResourceAttr(resourceName, "eks.0.node_group_arn", "arn:aws:iam::000000000000:role/aws_node_group"),
+					resource.TestCheckResourceAttr(resourceName, "eks.0.threads_per_cpu", "1"),
 				),
 			},
 			{
@@ -146,6 +147,7 @@ resource "castai_node_configuration" "test" {
 	  target_group {
 	    arn = "arn:aws:test"
     }
+		threads_per_cpu = 1
   }
 }