feat(k8s): add autohealing to pools (scaleway#266)

Author: Sh4d1

scaleway/resource_k8s_cluster_beta.go

@@ -93,6 +93,12 @@ func resourceScalewayK8SClusterBeta() *schema.Resource {
 							Default:     false,
 							Description: "Enable the autoscaling on the default pool",
 						},
+						"autohealing": {
+							Type:        schema.TypeBool,
+							Optional:    true,
+							Default:     false,
+							Description: "Enable the autohealing on the default pool",
+						},
 						"size": {
 							Type:        schema.TypeInt,
 							Required:    true,
@@ -284,6 +290,7 @@ func resourceScalewayK8SClusterBetaCreate(d *schema.ResourceData, m interface{})
 	defaultPoolReq := &k8s.CreateClusterRequestDefaultPoolConfig{
 		NodeType:    d.Get("default_pool.0.node_type").(string),
 		Autoscaling: d.Get("default_pool.0.autoscaling").(bool),
+		Autohealing: d.Get("default_pool.0.autohealing").(bool),
 		Size:        uint32(d.Get("default_pool.0.size").(int)),
 	}
 
@@ -363,6 +370,7 @@ func resourceScalewayK8SClusterBetaDefaultPoolRead(d *schema.ResourceData, m int
 	defaultPool["pool_id"] = pool.ID
 	defaultPool["node_type"] = pool.NodeType
 	defaultPool["autoscaling"] = pool.Autoscaling
+	defaultPool["autohealing"] = pool.Autohealing
 	defaultPool["size"] = pool.Size
 	defaultPool["min_size"] = pool.MinSize
 	defaultPool["max_size"] = pool.MaxSize
@@ -480,6 +488,10 @@ func resourceScalewayK8SClusterBetaDefaultPoolUpdate(d *schema.ResourceData, m i
 			updateRequest.Autoscaling = scw.BoolPtr(autoscaling.(bool))
 		}
 
+		if autohealing, ok := d.GetOk("default_pool.0.autohealing"); ok {
+			updateRequest.Autohealing = scw.BoolPtr(autohealing.(bool))
+		}
+
 		if minSize, ok := d.GetOk("default_pool.0.min_size"); ok {
 			updateRequest.MinSize = scw.Uint32Ptr(uint32(minSize.(int)))
 		}
@@ -503,6 +515,7 @@ func resourceScalewayK8SClusterBetaDefaultPoolUpdate(d *schema.ResourceData, m i
 				Name:        "default",
 				NodeType:    d.Get("default_pool.0.node_type").(string),
 				Autoscaling: d.Get("default_pool.0.autoscaling").(bool),
+				Autohealing: d.Get("default_pool.0.autohealing").(bool),
 				Size:        uint32(d.Get("default_pool.0.size").(int)),
 			}
 			if placementGroupID, ok := d.GetOk("default_pool.0.placement_group_id"); ok {

scaleway/resource_k8s_cluster_beta_test.go

@@ -124,6 +124,7 @@ func TestAccScalewayK8SClusterBetaDefaultPool(t *testing.T) {
 					resource.TestCheckResourceAttr("scaleway_k8s_cluster_beta.pool", "default_pool.0.min_size", "1"),
 					resource.TestCheckResourceAttr("scaleway_k8s_cluster_beta.pool", "default_pool.0.max_size", "2"),
 					resource.TestCheckResourceAttr("scaleway_k8s_cluster_beta.pool", "default_pool.0.autoscaling", "true"),
+					resource.TestCheckResourceAttr("scaleway_k8s_cluster_beta.pool", "default_pool.0.autohealing", "true"),
 					resource.TestCheckResourceAttr("scaleway_k8s_cluster_beta.pool", "default_pool.0.container_runtime", "docker"),
 					resource.TestCheckResourceAttrSet("scaleway_k8s_cluster_beta.pool", "kubeconfig.0.config_file"),
 					resource.TestCheckResourceAttrSet("scaleway_k8s_cluster_beta.pool", "kubeconfig.0.host"),
@@ -242,6 +243,7 @@ resource "scaleway_k8s_cluster_beta" "pool" {
 		min_size = 1
 		max_size = 2
 		autoscaling = true
+		autohealing = true
 		container_runtime = "docker"
 	}
 	tags = [ "terraform-test", "scaleway_k8s_cluster_beta", "default-pool" ]

scaleway/resource_k8s_pool_beta.go

@@ -40,6 +40,12 @@ func resourceScalewayK8SPoolBeta() *schema.Resource {
 				Default:     false,
 				Description: "Enable the autoscaling on the pool",
 			},
+			"autohealing": {
+				Type:        schema.TypeBool,
+				Optional:    true,
+				Default:     false,
+				Description: "Enable the autohealing on the pool",
+			},
 			"size": {
 				Type:        schema.TypeInt,
 				Required:    true,
@@ -112,6 +118,7 @@ func resourceScalewayK8SPoolBetaCreate(d *schema.ResourceData, m interface{}) er
 		Name:        name.(string),
 		NodeType:    d.Get("node_type").(string),
 		Autoscaling: d.Get("autoscaling").(bool),
+		Autohealing: d.Get("autohealing").(bool),
 		Size:        uint32(d.Get("size").(int)),
 	}
 
@@ -168,6 +175,7 @@ func resourceScalewayK8SPoolBetaRead(d *schema.ResourceData, m interface{}) erro
 	d.Set("name", pool.Name)
 	d.Set("node_type", pool.NodeType)
 	d.Set("autoscaling", pool.Autoscaling)
+	d.Set("autohealing", pool.Autohealing)
 	d.Set("size", pool.Size)
 	d.Set("version", pool.Version)
 	d.Set("min_size", pool.MinSize)
@@ -197,6 +205,10 @@ func resourceScalewayK8SPoolBetaUpdate(d *schema.ResourceData, m interface{}) er
 		updateRequest.Autoscaling = scw.BoolPtr(d.Get("autoscaling").(bool))
 	}
 
+	if d.HasChange("autohealing") {
+		updateRequest.Autohealing = scw.BoolPtr(d.Get("autohealing").(bool))
+	}
+
 	if d.HasChange("min_size") {
 		updateRequest.MinSize = scw.Uint32Ptr(uint32(d.Get("min_size").(int)))
 	}

scaleway/resource_k8s_pool_beta_test.go

@@ -28,6 +28,8 @@ func TestAccScalewayK8SClusterPoolMinimal(t *testing.T) {
 					testAccCheckScalewayK8SPoolBetaExists("scaleway_k8s_pool_beta.minimal"),
 					resource.TestCheckResourceAttr("scaleway_k8s_pool_beta.minimal", "node_type", "gp1_xs"),
 					resource.TestCheckResourceAttr("scaleway_k8s_pool_beta.minimal", "size", "1"),
+					resource.TestCheckResourceAttr("scaleway_k8s_pool_beta.minimal", "autohealing", "true"),
+					resource.TestCheckResourceAttr("scaleway_k8s_pool_beta.minimal", "autoscaling", "true"),
 					resource.TestCheckResourceAttr("scaleway_k8s_pool_beta.minimal", "version", "1.16.0"),
 					resource.TestCheckResourceAttrSet("scaleway_k8s_pool_beta.minimal", "id"),
 				),
@@ -104,6 +106,8 @@ resource "scaleway_k8s_pool_beta" "minimal" {
     name = "minimal"
 	cluster_id = "${scaleway_k8s_cluster_beta.minimal.id}"
 	node_type = "gp1_xs"
+	autohealing = true
+	autoscaling = true
 	size = 1
 }`)
 	}