feat(k8s): add cluster and pool datasource (#724)

Signed-off-by: Patrik Cyvoct <[email protected]>
Co-authored-by: Rémy Léone <[email protected]>

Author: Sh4d1

docs/data-sources/k8s_cluster.md

@@ -0,0 +1,108 @@
+---
+page_title: "Scaleway: scaleway_k8s_cluster"
+description: |-
+  Gets information about a Kubernetes Cluster.
+---
+
+# scaleway_k8s_cluster
+
+Gets information about a Kubernetes Cluster.
+
+## Example Usage
+
+```hcl
+# Get info by cluster name
+data "scaleway_k8s_cluster" "my_key" {
+  name  = "my-cluster-name"
+}
+
+# Get info by cluster id
+data "scaleway_k8s_cluster" "my_key" {
+  cluster_id = "11111111-1111-1111-1111-111111111111"
+}
+```
+
+## Argument Reference
+
+- `name` - (Optional) The cluster name. Only one of `name` and `cluster_id` should be specified.
+
+- `cluster_id` - (Optional) The cluster ID. Only one of `name` and `cluster_id` should be specified.
+
+- `region` - (Defaults to [provider](../index.md#region) `region`) The [region](../guides/regions_and_zones.md#regions) in which the cluster exists.
+
+## Attributes Reference
+
+In addition to all above arguments, the following attributes are exported:
+
+- `id` - The ID of the cluster.
+
+- `created_at` - The creation date of the cluster.
+
+- `updated_at` - The last update date of the cluster.
+
+- `apiserver_url` - The URL of the Kubernetes API server.
+
+- `wildcard_dns` - The DNS wildcard that points to all ready nodes.
+
+- `kubeconfig`
+
+    - `config_file` - The raw kubeconfig file.
+
+    - `host` - The URL of the Kubernetes API server.
+
+    - `cluster_ca_certificate` - The CA certificate of the Kubernetes API server.
+
+    - `token` - The token to connect to the Kubernetes API server.
+
+- `status` - The status of the Kubernetes cluster.
+
+- `upgrade_available` - True if a newer Kubernetes version is available.
+
+- `description` - A description for the Kubernetes cluster.
+
+- `version` - The version of the Kubernetes cluster.
+
+- `cni` - The Container Network Interface (CNI) for the Kubernetes cluster.
+
+- `enable_dashboard` - True if the [Kubernetes dashboard](https://github.com/kubernetes/dashboard) is enabled for the Kubernetes cluster.
+
+- `ingress` - The [ingress controller](https://kubernetes.io/docs/concepts/services-networking/ingress-controllers/) deployed on the Kubernetes cluster.
+
+- `tags` - The tags associated with the Kubernetes cluster.
+
+- `autoscaler_config` - The configuration options for the [Kubernetes cluster autoscaler](https://github.com/kubernetes/autoscaler/tree/master/cluster-autoscaler).
+
+    - `disable_scale_down` - True if the scale down feature of the autoscaler is disabled.
+
+    - `scale_down_delay_after_add` - The duration after scale up that scale down evaluation resumes.
+
+    - `scale_down_unneeded_time` - The duration a node should be unneeded before it is eligible for scale down.
+
+    - `estimator` - The type of resource estimator used in scale up.
+
+    - `expander` - The type of node group expander be used in scale up.
+
+    - `ignore_daemonsets_utilization` - True if ignoring DaemonSet pods when calculating resource utilization for scaling down is enabled.
+
+    - `balance_similar_node_groups` - True if detecting similar node groups and balance the number of nodes between them is enabled.
+
+    - `expendable_pods_priority_cutoff` - Pods with priority below cutoff will be expendable. They can be killed without any consideration during scale down and they don't cause scale up. Pods with null priority (PodPriority disabled) are non expendable.
+
+- `auto_upgrade` - The auto upgrade configuration.
+
+    - `enable` - True if Kubernetes patch version auto upgrades is enabled.
+
+    - `maintenance_window_start_hour` - The start hour (UTC) of the 2-hour auto upgrade maintenance window (0 to 23).
+
+    - `maintenance_window_day` - The day of the auto upgrade maintenance window (`monday` to `sunday`, or `any`).
+
+- `feature_gates` - The list of [feature gates](https://kubernetes.io/docs/reference/command-line-tools-reference/feature-gates/) enabled on the cluster.
+
+- `admission_plugins` - The list of [admission plugins](https://kubernetes.io/docs/reference/access-authn-authz/admission-controllers/) enabled on the cluster.
+
+- `region` - The [region](../guides/regions_and_zones.md#regions) in which the cluster is.
+
+- `organization_id` - The ID of the organization the cluster is associated with.
+
+- `project_id` - The ID of the project the cluster is associated with.
+

docs/data-sources/k8s_pool.md

@@ -0,0 +1,78 @@
+---
+page_title: "Scaleway: scaleway_k8s_pool"
+description: |-
+  Gets information about a Kubernetes Cluster's Pool.
+---
+
+# scaleway_k8s_pool
+
+Gets information about a Kubernetes Cluster's Pool.
+
+## Example Usage
+
+```hcl
+# Get info by pokl name (need cluster_id)
+data "scaleway_k8s_pool" "my_key" {
+  name  = "my-pool-name"
+  cluster_id = "11111111-1111-1111-1111-111111111111"
+}
+
+# Get info by pool id
+data "scaleway_k8s_pool" "my_key" {
+  pool_id = "11111111-1111-1111-1111-111111111111"
+}
+```
+
+## Argument Reference
+
+- `name` - The pool name. Only one of `name` and `pool_id` should be specified. `cluster_id` should be specified with `name`.
+
+- `pool_id` - (Optional) The pool's ID. Only one of `name` and `pool_id` should be specified.
+
+- `cluster_id` - (Optional) The cluster ID. Required when `name` is set.
+
+- `region` - (Defaults to [provider](../index.md#region) `region`) The [region](../guides/regions_and_zones.md#regions) in which the pool exists.
+
+## Attributes Reference
+
+In addition to all above arguments, the following attributes are exported:
+
+- `id` - The ID of the pool.
+
+- `status` - The status of the pool.
+
+- `nodes` - (List of) The nodes in the default pool.
+
+    - `name` - The name of the node.
+
+    - `public_ip` - The public IPv4.
+
+    - `public_ip_v6` - The public IPv6.
+
+    - `status` - The status of the node.
+
+- `created_at` - The creation date of the pool.
+
+- `updated_at` - The last update date of the pool.
+
+- `version` - The version of the pool.
+
+- `current_size` - The size of the pool at the time the terraform state was updated.
+
+- `node_type` - The commercial type of the pool instances.
+
+- `size` - The size of the pool.
+
+- `min_size` - The minimum size of the pool, used by the autoscaling feature.
+
+- `max_size` - The maximum size of the pool, used by the autoscaling feature.
+
+- `tags` - The tags associated with the pool.
+
+- `placement_group_id` - [placement group](https://developers.scaleway.com/en/products/instance/api/#placement-groups-d8f653) the nodes of the pool are attached to.
+
+- `autoscaling` - True if the autoscaling feature is enabled for this pool.
+
+- `autohealing` - True if the autohealing feature is enabled for this pool.
+
+- `container_runtime` - The container runtime of the pool.

scaleway/data_source_k8s_cluster.go

@@ -0,0 +1,71 @@
+package scaleway
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	k8s "github.com/scaleway/scaleway-sdk-go/api/k8s/v1"
+	"github.com/scaleway/scaleway-sdk-go/scw"
+)
+
+func dataSourceScalewayK8SCluster() *schema.Resource {
+	// Generate datasource schema from resource
+	dsSchema := datasourceSchemaFromResourceSchema(resourceScalewayK8SCluster().Schema)
+
+	// Set 'Optional' schema elements
+	addOptionalFieldsToSchema(dsSchema, "name", "region")
+	delete(dsSchema, "delete_additional_resources")
+
+	dsSchema["name"].ConflictsWith = []string{"cluster_id"}
+	dsSchema["cluster_id"] = &schema.Schema{
+		Type:          schema.TypeString,
+		Optional:      true,
+		Description:   "The ID of the cluster",
+		ValidateFunc:  validationUUIDorUUIDWithLocality(),
+		ConflictsWith: []string{"name"},
+	}
+
+	return &schema.Resource{
+		ReadContext: dataSourceScalewayK8SClusterRead,
+
+		Schema: dsSchema,
+	}
+}
+
+func dataSourceScalewayK8SClusterRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics {
+	meta := m.(*Meta)
+	k8sAPI, region, err := k8sAPIWithRegion(d, meta)
+	if err != nil {
+		return diag.FromErr(err)
+	}
+
+	clusterID, ok := d.GetOk("cluster_id")
+	if !ok {
+		res, err := k8sAPI.ListClusters(&k8s.ListClustersRequest{
+			Region:    region,
+			Name:      expandStringPtr(d.Get("name")),
+			ProjectID: expandStringPtr(d.Get("project_id")),
+		}, scw.WithContext(ctx))
+		if err != nil {
+			return diag.FromErr(err)
+		}
+		for _, cluster := range res.Clusters {
+			if cluster.Name == d.Get("name").(string) {
+				if clusterID != "" {
+					return diag.FromErr(fmt.Errorf("more than 1 cluster found with the same name %s", d.Get("name")))
+				}
+				clusterID = cluster.ID
+			}
+		}
+		if clusterID == "" {
+			return diag.FromErr(fmt.Errorf("no cluster found with the name %s", d.Get("name")))
+		}
+	}
+
+	regionalizedID := datasourceNewRegionalizedID(clusterID, region)
+	d.SetId(regionalizedID)
+	_ = d.Set("cluster_id", regionalizedID)
+	return resourceScalewayK8SClusterRead(ctx, d, m)
+}

scaleway/data_source_k8s_cluster_test.go

@@ -0,0 +1,54 @@
+package scaleway
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+func TestAccScalewayDataSourceK8SCluster_Basic(t *testing.T) {
+	tt := NewTestTools(t)
+	defer tt.Cleanup()
+	clusterName := "tf-cluster"
+	version := testAccScalewayK8SClusterGetLatestK8SVersion(tt)
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck:          func() { testAccPreCheck(t) },
+		ProviderFactories: tt.ProviderFactories,
+		CheckDestroy:      testAccCheckScalewayK8SClusterDestroy(tt),
+		Steps: []resource.TestStep{
+			{
+				Config: fmt.Sprintf(`
+					resource "scaleway_k8s_cluster" "main" {
+					  	name 	= "%s"
+						version = "%s"
+						cni     = "cilium"
+					  	tags    = [ "terraform-test", "data_scaleway_k8s_cluster", "basic" ]
+					}`, clusterName, version),
+			},
+			{
+				Config: fmt.Sprintf(`
+					resource "scaleway_k8s_cluster" "main" {
+					  	name 	= "%s"
+						version = "%s"
+						cni     = "cilium"
+					  	tags    = [ "terraform-test", "data_scaleway_k8s_cluster", "basic" ]
+					}
+					
+					data "scaleway_k8s_cluster" "prod" {
+					  	name = "${scaleway_k8s_cluster.main.name}"
+					}
+					
+					data "scaleway_k8s_cluster" "stg" {
+					  	cluster_id = "${scaleway_k8s_cluster.main.id}"
+					}`, clusterName, version),
+				Check: resource.ComposeTestCheckFunc(
+					testAccCheckScalewayK8SClusterExists(tt, "data.scaleway_k8s_cluster.prod"),
+					resource.TestCheckResourceAttr("data.scaleway_k8s_cluster.prod", "name", clusterName),
+					testAccCheckScalewayK8SClusterExists(tt, "data.scaleway_k8s_cluster.stg"),
+					resource.TestCheckResourceAttr("data.scaleway_k8s_cluster.stg", "name", clusterName),
+				),
+			},
+		},
+	})
+}

scaleway/data_source_k8s_pool.go

@@ -0,0 +1,73 @@
+package scaleway
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	k8s "github.com/scaleway/scaleway-sdk-go/api/k8s/v1"
+	"github.com/scaleway/scaleway-sdk-go/scw"
+)
+
+func dataSourceScalewayK8SPool() *schema.Resource {
+	// Generate datasource schema from resource
+	dsSchema := datasourceSchemaFromResourceSchema(resourceScalewayK8SPool().Schema)
+
+	// Set 'Optional' schema elements
+	addOptionalFieldsToSchema(dsSchema, "name", "region", "cluster_id", "size")
+
+	dsSchema["name"].ConflictsWith = []string{"pool_id"}
+	dsSchema["cluster_id"].ConflictsWith = []string{"pool_id"}
+	dsSchema["cluster_id"].RequiredWith = []string{"name"}
+	dsSchema["pool_id"] = &schema.Schema{
+		Type:          schema.TypeString,
+		Optional:      true,
+		Description:   "The ID of the pool",
+		ValidateFunc:  validationUUIDorUUIDWithLocality(),
+		ConflictsWith: []string{"name", "cluster_id"},
+	}
+
+	return &schema.Resource{
+		ReadContext: dataSourceScalewayK8SPoolRead,
+
+		Schema: dsSchema,
+	}
+}
+
+func dataSourceScalewayK8SPoolRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics {
+	meta := m.(*Meta)
+	k8sAPI, region, err := k8sAPIWithRegion(d, meta)
+	if err != nil {
+		return diag.FromErr(err)
+	}
+
+	poolID, ok := d.GetOk("pool_id")
+	if !ok {
+		clusterID := expandRegionalID(d.Get("cluster_id"))
+		res, err := k8sAPI.ListPools(&k8s.ListPoolsRequest{
+			Region:    region,
+			Name:      expandStringPtr(d.Get("name")),
+			ClusterID: clusterID.ID,
+		}, scw.WithContext(ctx))
+		if err != nil {
+			return diag.FromErr(err)
+		}
+		for _, pool := range res.Pools {
+			if pool.Name == d.Get("name").(string) {
+				if poolID != "" {
+					return diag.FromErr(fmt.Errorf("more than 1 pool found with the same name %s", d.Get("name")))
+				}
+				poolID = pool.ID
+			}
+		}
+		if poolID == "" {
+			return diag.FromErr(fmt.Errorf("no pool found with the name %s", d.Get("name")))
+		}
+	}
+
+	regionalizedID := datasourceNewRegionalizedID(poolID, region)
+	d.SetId(regionalizedID)
+	_ = d.Set("pool_id", regionalizedID)
+	return resourceScalewayK8SPoolRead(ctx, d, m)
+}