feat(kubernetes): add cluster labels (#289)

Author: kangasta

CHANGELOG.md

@@ -7,6 +7,7 @@ See updating [Changelog example here](https://keepachangelog.com/en/1.0.0/)
 
 ### Added
 - Managed Load Balancer: `MaintenanceDOW` and `MaintenanceTime` fields for controlling maintenance window occurrence
+- Kubernetes: support for cluster labels.
 
 ### Changed
 - **Breaking**, Managed Database: `ManagedDatabaseUserOpernSearchAccessControl` fields changed to pointers
@@ -15,6 +16,7 @@ See updating [Changelog example here](https://keepachangelog.com/en/1.0.0/)
 - **Breaking**, Managed Load Balancer: `LoadBalancerFrontendProperties` field `InboundProxyProtocol` to pointer
 - **Breaking**, Managed Object Storage: `CreateManagedObjectStorageUserAccessKeyRequest` field `Enabled` to pointer
 - **Breaking**, Managed Object Storage: `ModifyManagedObjectStorageUserAccessKeyRequest` field `Enabled` to pointer
+- **Breaking** Kubernetes: the `ControlPlaneIPFilter` of `ModifyKubernetesCluster` is changed from `[]string` to `*[]string`.
 
 ### Removed
 - **Breaking**, Managed Database: connection related methods in favor of session

upcloud/kubernetes.go

@@ -37,6 +37,7 @@ type (
 
 type KubernetesCluster struct {
 	ControlPlaneIPFilter []string               `json:"control_plane_ip_filter"`
+	Labels               []Label                `json:"labels"`
 	Name                 string                 `json:"name"`
 	Network              string                 `json:"network"`
 	NetworkCIDR          string                 `json:"network_cidr"`

upcloud/request/kubernetes.go

@@ -48,6 +48,7 @@ func (r *GetKubernetesClusterRequest) RequestURL() string {
 // CreateKubernetesClusterRequest represents a request to create a Kubernetes cluster
 type CreateKubernetesClusterRequest struct {
 	ControlPlaneIPFilter []string              `json:"control_plane_ip_filter"`
+	Labels               []upcloud.Label       `json:"labels,omitempty"`
 	Name                 string                `json:"name"`
 	Network              string                `json:"network"`
 	NetworkCIDR          string                `json:"network_cidr"`
@@ -63,7 +64,8 @@ func (r *CreateKubernetesClusterRequest) RequestURL() string {
 }
 
 type ModifyKubernetesCluster struct {
-	ControlPlaneIPFilter []string `json:"control_plane_ip_filter"`
+	ControlPlaneIPFilter *[]string        `json:"control_plane_ip_filter,omitempty"`
+	Labels               *[]upcloud.Label `json:"labels,omitempty"`
 }
 
 type ModifyKubernetesClusterRequest struct {

upcloud/request/kubernetes_test.go

@@ -178,27 +178,52 @@ func TestKubernetes(t *testing.T) {
 	t.Run("ModifyKubernetesClusterRequestMarshal", func(t *testing.T) {
 		t.Parallel()
 
-		expected := `{ "control_plane_ip_filter": ["0.0.0.0/0"] }`
-
-		uuid := "this-is-the-uuid-you-are-looking-for"
-		r := ModifyKubernetesClusterRequest{
-			ClusterUUID: uuid,
-			Cluster: ModifyKubernetesCluster{
-				ControlPlaneIPFilter: []string{"0.0.0.0/0"},
+		tests := []struct {
+			request  ModifyKubernetesClusterRequest
+			expected string
+		}{
+			{
+				request: ModifyKubernetesClusterRequest{
+					ClusterUUID: "set-filter-omit-labels",
+					Cluster: ModifyKubernetesCluster{
+						ControlPlaneIPFilter: &[]string{"0.0.0.0/0"},
+					},
+				},
+				expected: `{ "control_plane_ip_filter": ["0.0.0.0/0"] }`,
+			},
+			{
+				request: ModifyKubernetesClusterRequest{
+					ClusterUUID: "omit-filter-set-labels",
+					Cluster: ModifyKubernetesCluster{
+						Labels: &[]upcloud.Label{{Key: "tool", Value: "Go SDK"}},
+					},
+				},
+				expected: `{ "labels": [{"key": "tool", "value": "Go SDK"}] }`,
+			},
+			{
+				request: ModifyKubernetesClusterRequest{
+					ClusterUUID: "clear-filter-clear-labels",
+					Cluster: ModifyKubernetesCluster{
+						ControlPlaneIPFilter: &[]string{},
+						Labels:               &[]upcloud.Label{},
+					},
+				},
+				expected: `{ "control_plane_ip_filter": [], "labels": [] }`,
 			},
 		}
-
-		assert.Equal(t, fmt.Sprintf("%s/%s", kubernetesClusterBasePath, uuid), r.RequestURL())
-
-		b, err := json.Marshal(&r)
-		actual := string(b)
-
-		assert.NoError(t, err)
-		assert.JSONEq(
-			t,
-			expected,
-			actual,
-		)
+		for _, test := range tests {
+			assert.Equal(t, fmt.Sprintf("%s/%s", kubernetesClusterBasePath, test.request.ClusterUUID), test.request.RequestURL())
+
+			b, err := json.Marshal(&test.request)
+			actual := string(b)
+
+			assert.NoError(t, err)
+			assert.JSONEq(
+				t,
+				test.expected,
+				actual,
+			)
+		}
 	})
 
 	t.Run("DeleteKubernetesClusterRequest", func(t *testing.T) {