feat(cluster): Add labels to cluster config (#9553)

* feat(cluster): Add labels to cluster config

Signed-off-by: Suleiman Dibirov <idsulik@gmail.com>

* Updated schema v4beta12.json

Signed-off-by: Suleiman Dibirov <idsulik@gmail.com>

* fix code style

Signed-off-by: Suleiman Dibirov <idsulik@gmail.com>

---------

Signed-off-by: Suleiman Dibirov <idsulik@gmail.com>

Author: idsulik

docs-v2/content/en/schemas/v4beta12.json

@@ -1228,6 +1228,15 @@
           "description": "describes how to mount the local Docker configuration into a pod.",
           "x-intellij-html-description": "describes how to mount the local Docker configuration into a pod."
         },
+        "labels": {
+          "additionalProperties": {
+            "type": "string"
+          },
+          "type": "object",
+          "description": "describes the Kubernetes labels for the pod.",
+          "x-intellij-html-description": "describes the Kubernetes labels for the pod.",
+          "default": "{}"
+        },
         "namespace": {
           "type": "string",
           "description": "Kubernetes namespace. Defaults to current namespace in Kubernetes configuration.",
@@ -1318,6 +1327,7 @@
         "tolerations",
         "nodeSelector",
         "annotations",
+        "labels",
         "runAsUser",
         "resources",
         "concurrency",

pkg/skaffold/build/cluster/pod.go

@@ -49,11 +49,16 @@ func (b *Builder) kanikoPodSpec(artifact *latest.KanikoArtifact, tag string, pla
 		MountPath: kaniko.DefaultEmptyDirMountPath,
 	}
 
+	labels := map[string]string{"skaffold-kaniko": "skaffold-kaniko"}
+	for k, v := range b.ClusterDetails.Labels {
+		labels[k] = v
+	}
+
 	pod := &v1.Pod{
 		ObjectMeta: metav1.ObjectMeta{
 			Annotations:  b.ClusterDetails.Annotations,
 			GenerateName: "kaniko-",
-			Labels:       map[string]string{"skaffold-kaniko": "skaffold-kaniko"},
+			Labels:       labels,
 			Namespace:    b.ClusterDetails.Namespace,
 		},
 		Spec: v1.PodSpec{

pkg/skaffold/build/cluster/pod_test.go

@@ -220,6 +220,8 @@ func TestKanikoPodSpec(t *testing.T) {
 			HTTPProxy:           "http://proxy",
 			HTTPSProxy:          "https://proxy",
 			ServiceAccountName:  "aVerySpecialSA",
+			Annotations:         map[string]string{"test": "test"},
+			Labels:              map[string]string{"test-key": "test-value"},
 			RunAsUser:           &runAsUser,
 			Resources: &latest.ResourceRequirements{
 				Requests: &latest.ResourceRequirement{
@@ -268,7 +270,7 @@ func TestKanikoPodSpec(t *testing.T) {
 		ObjectMeta: metav1.ObjectMeta{
 			Annotations:  map[string]string{"test": "test"},
 			GenerateName: "kaniko-",
-			Labels:       map[string]string{"skaffold-kaniko": "skaffold-kaniko"},
+			Labels:       map[string]string{"skaffold-kaniko": "skaffold-kaniko", "test-key": "test-value"},
 			Namespace:    "ns",
 		},
 		Spec: v1.PodSpec{
@@ -405,6 +407,7 @@ func TestKanikoPodSpec(t *testing.T) {
 
 	testutil.CheckDeepEqual(t, expectedPod.Spec.Containers[0].Env, pod.Spec.Containers[0].Env)
 	testutil.CheckDeepEqual(t, expectedPod.Spec.Containers[0].Args, pod.Spec.Containers[0].Args)
+	testutil.CheckDeepEqual(t, expectedPod.ObjectMeta, pod.ObjectMeta)
 }
 
 func TestResourceRequirements(t *testing.T) {

pkg/skaffold/schema/latest/config.go

@@ -544,6 +544,9 @@ type ClusterDetails struct {
 	// Annotations describes the Kubernetes annotations for the pod.
 	Annotations map[string]string `yaml:"annotations,omitempty"`
 
+	// Labels describes the Kubernetes labels for the pod.
+	Labels map[string]string `yaml:"labels,omitempty"`
+
 	// RunAsUser defines the UID to request for running the container.
 	// If omitted, no SecurityContext will be specified for the pod and will therefore be inherited
 	// from the service account.