feat(kuma-cp): add service-name and service-port tags

Signed-off-by: Jakub Dyszkiewicz <jakub.dyszkiewicz@gmail.com>
kumahq · Dec 8, 2021 · aeed20c · aeed20c
1 parent 8f1a8df
commit aeed20c
Show file tree

Hide file tree

Showing 16 changed files with 80 additions and 3 deletions.
diff --git a/pkg/plugins/runtime/k8s/controllers/inbound_converter.go b/pkg/plugins/runtime/k8s/controllers/inbound_converter.go
@@ -2,6 +2,7 @@ package controllers
 
 import (
 	"fmt"
+	"strconv"
 	"strings"
 
 	"github.com/pkg/errors"
@@ -12,7 +13,11 @@ import (
 	util_k8s "github.com/kumahq/kuma/pkg/plugins/runtime/k8s/util"
 )
 
-const NamespaceTag = "k8s.kuma.io/namespace"
+const (
+	KubeNamespaceTag = "k8s.kuma.io/namespace"
+	KubeServiceTag   = "k8s.kuma.io/service-name"
+	KubePortTag      = "k8s.kuma.io/service-port"
+)
 
 func inboundForService(zone string, pod *kube_core.Pod, service *kube_core.Service) (ifaces []*mesh_proto.Dataplane_Networking_Inbound) {
 	for _, svcPort := range service.Spec.Ports {
@@ -133,7 +138,9 @@ func InboundTagsForService(zone string, pod *kube_core.Pod, svc *kube_core.Servi
 	if tags == nil {
 		tags = make(map[string]string)
 	}
-	tags[NamespaceTag] = pod.Namespace
+	tags[KubeNamespaceTag] = pod.Namespace
+	tags[KubeServiceTag] = svc.Name
+	tags[KubePortTag] = strconv.Itoa(int(svcPort.Port))
 	tags[mesh_proto.ServiceTag] = util_k8s.ServiceTagFor(svc, svcPort)
 	if zone != "" {
 		tags[mesh_proto.ZoneTag] = zone
@@ -177,7 +184,7 @@ func InboundTagsForPod(zone string, pod *kube_core.Pod) map[string]string {
 	if tags == nil {
 		tags = make(map[string]string)
 	}
-	tags[NamespaceTag] = pod.Namespace
+	tags[KubeNamespaceTag] = pod.Namespace
 	tags[mesh_proto.ServiceTag] = fmt.Sprintf("%s_%s_svc", nameFromPod(pod), pod.Namespace)
 	if zone != "" {
 		tags[mesh_proto.ZoneTag] = zone

diff --git a/pkg/plugins/runtime/k8s/controllers/pod_controller_test.go b/pkg/plugins/runtime/k8s/controllers/pod_controller_test.go
@@ -389,13 +389,17 @@ var _ = Describe("PodReconciler", func() {
                 app: sample
                 kuma.io/protocol: http
                 kuma.io/service: example_demo_svc_80
+                k8s.kuma.io/service-name: example
+                k8s.kuma.io/service-port: "80"
                 k8s.kuma.io/namespace: demo
             - health: {} 
               port: 6060
               tags:
                 app: sample
                 kuma.io/service: example_demo_svc_6061
                 kuma.io/protocol: tcp
+                k8s.kuma.io/service-name: example
+                k8s.kuma.io/service-port: "6061"
                 k8s.kuma.io/namespace: demo
 `))
 	})
@@ -465,13 +469,17 @@ var _ = Describe("PodReconciler", func() {
                 app: sample
                 kuma.io/protocol: http
                 kuma.io/service: example_demo_svc_80
+                k8s.kuma.io/service-name: example
+                k8s.kuma.io/service-port: "80"
                 k8s.kuma.io/namespace: demo
             - health: {} 
               port: 6060
               tags:
                 app: sample
                 kuma.io/service: example_demo_svc_6061
                 kuma.io/protocol: tcp
+                k8s.kuma.io/service-name: example
+                k8s.kuma.io/service-port: "6061"
                 k8s.kuma.io/namespace: demo
 `))
 	})

diff --git a/pkg/plugins/runtime/k8s/controllers/pod_converter_test.go b/pkg/plugins/runtime/k8s/controllers/pod_converter_test.go
@@ -413,6 +413,8 @@ var _ = Describe("InboundTagsForService(..)", func() {
 			expected: map[string]string{
 				"kuma.io/service":       "example_demo_svc_80",
 				"kuma.io/protocol":      "tcp", // we want Kuma's default behavior to be explicit to a user
+				"k8s.kuma.io/service-name": "example",
+				"k8s.kuma.io/service-port": "80",
 				"k8s.kuma.io/namespace": "test",
 			},
 		}),
@@ -427,6 +429,8 @@ var _ = Describe("InboundTagsForService(..)", func() {
 				"version":               "0.1",
 				"kuma.io/service":       "example_demo_svc_80",
 				"kuma.io/protocol":      "tcp", // we want Kuma's default behavior to be explicit to a user
+				"k8s.kuma.io/service-name": "example",
+				"k8s.kuma.io/service-port": "80",
 				"k8s.kuma.io/namespace": "test",
 			},
 		}),
@@ -442,6 +446,8 @@ var _ = Describe("InboundTagsForService(..)", func() {
 				"version":               "0.1",
 				"kuma.io/service":       "example_demo_svc_80",
 				"kuma.io/protocol":      "tcp", // we want Kuma's default behavior to be explicit to a user
+				"k8s.kuma.io/service-name": "example",
+				"k8s.kuma.io/service-port": "80",
 				"k8s.kuma.io/namespace": "test",
 			},
 		}),
@@ -459,6 +465,8 @@ var _ = Describe("InboundTagsForService(..)", func() {
 				"version":               "0.1",
 				"kuma.io/service":       "example_demo_svc_80",
 				"kuma.io/protocol":      "not-yet-supported-protocol", // we want Kuma's behavior to be straightforward to a user (just copy annotation value "as is")
+				"k8s.kuma.io/service-name": "example",
+				"k8s.kuma.io/service-port": "80",
 				"k8s.kuma.io/namespace": "test",
 			},
 		}),
@@ -476,6 +484,8 @@ var _ = Describe("InboundTagsForService(..)", func() {
 				"version":               "0.1",
 				"kuma.io/service":       "example_demo_svc_80",
 				"kuma.io/protocol":      "http",
+				"k8s.kuma.io/service-name": "example",
+				"k8s.kuma.io/service-port": "80",
 				"k8s.kuma.io/namespace": "test",
 			},
 		}),
@@ -491,6 +501,8 @@ var _ = Describe("InboundTagsForService(..)", func() {
 				"version":               "0.1",
 				"kuma.io/service":       "example_demo_svc_80",
 				"kuma.io/protocol":      "http",
+				"k8s.kuma.io/service-name": "example",
+				"k8s.kuma.io/service-port": "80",
 				"k8s.kuma.io/namespace": "test",
 			},
 		}),
@@ -507,6 +519,8 @@ var _ = Describe("InboundTagsForService(..)", func() {
 				mesh_proto.ServiceTag:   "example_demo_svc_80",
 				mesh_proto.ZoneTag:      "zone-1",
 				mesh_proto.ProtocolTag:  "tcp",
+				"k8s.kuma.io/service-name": "example",
+				"k8s.kuma.io/service-port": "80",
 				"k8s.kuma.io/namespace": "test",
 			},
 		}),
@@ -520,6 +534,8 @@ var _ = Describe("InboundTagsForService(..)", func() {
 				"app":                   "example",
 				"kuma.io/service":       "example_demo_svc_80",
 				"kuma.io/protocol":      "tcp",
+				"k8s.kuma.io/service-name": "example",
+				"k8s.kuma.io/service-port": "80",
 				"k8s.kuma.io/namespace": "test",
 			},
 		}),

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/01.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/01.dataplane.yaml
@@ -9,6 +9,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "80"
         kuma.io/protocol: http
         kuma.io/service: example_demo_svc_80
         kuma.io/zone: zone-1
@@ -17,6 +19,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "443"
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_443
         kuma.io/zone: zone-1
@@ -27,6 +31,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: sample
+        k8s.kuma.io/service-port: "7071"
         kuma.io/protocol: MONGO
         kuma.io/service: sample_playground_svc_7071
         kuma.io/zone: zone-1
@@ -37,6 +43,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: sample
+        k8s.kuma.io/service-port: "6061"
         kuma.io/protocol: tcp
         kuma.io/service: sample_playground_svc_6061
         kuma.io/zone: zone-1

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/02.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/02.dataplane.yaml
@@ -9,6 +9,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "80"
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_80
         kuma.io/zone: zone-1

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/03.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/03.dataplane.yaml
@@ -8,6 +8,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "80"
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_80
         kuma.io/zone: zone-1

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/04.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/04.dataplane.yaml
@@ -9,6 +9,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "80"
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_80
         kuma.io/zone: zone-1

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/05.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/05.dataplane.yaml
@@ -9,6 +9,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "80"
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_80
         kuma.io/zone: zone-1

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/06.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/06.dataplane.yaml
@@ -9,6 +9,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "80"
         kuma.io/instance: example
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_80
@@ -18,6 +20,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "443"
         kuma.io/instance: example
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_443

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/07.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/07.dataplane.yaml
@@ -14,6 +14,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: sample
+        k8s.kuma.io/service-port: "7071"
         kuma.io/protocol: tcp
         kuma.io/service: sample_playground_svc_7071
         kuma.io/zone: zone-1

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/08.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/08.dataplane.yaml
@@ -9,6 +9,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "80"
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_80
         kuma.io/zone: zone-1

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/09.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/09.dataplane.yaml
@@ -9,6 +9,8 @@ spec:
       tags:
         app: kuma-ingress
         k8s.kuma.io/namespace: kuma-system
+        k8s.kuma.io/service-name: kuma-ingress
+        k8s.kuma.io/service-port: "10001"
         kuma.io/protocol: tcp
         kuma.io/service: kuma-ingress_kuma-system_svc_10001
         kuma.io/zone: zone-1

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/10.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/10.dataplane.yaml
@@ -9,6 +9,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "80"
         kuma.io/protocol: http
         kuma.io/service: example_demo_svc_80
         kuma.io/zone: zone-1
@@ -17,6 +19,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "443"
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_443
         kuma.io/zone: zone-1
@@ -25,6 +29,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: sample
+        k8s.kuma.io/service-port: "7071"
         kuma.io/protocol: MONGO
         kuma.io/service: sample_playground_svc_7071
         kuma.io/zone: zone-1

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/11.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/11.dataplane.yaml
@@ -11,6 +11,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "80"
         kuma.io/protocol: http
         kuma.io/service: example_demo_svc_80
         kuma.io/zone: zone-1
@@ -19,6 +21,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "443"
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_443
         kuma.io/zone: zone-1
@@ -28,6 +32,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: sample
+        k8s.kuma.io/service-port: "7071"
         kuma.io/protocol: MONGO
         kuma.io/service: sample_playground_svc_7071
         kuma.io/zone: zone-1

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/12.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/12.dataplane.yaml
@@ -10,6 +10,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "80"
         kuma.io/protocol: http
         kuma.io/service: example_demo_svc_80
         kuma.io/zone: zone-1
@@ -19,6 +21,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "443"
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_443
         kuma.io/zone: zone-1
@@ -28,6 +32,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: sample
+        k8s.kuma.io/service-port: "7071"
         kuma.io/protocol: MONGO
         kuma.io/service: sample_playground_svc_7071
         kuma.io/zone: zone-1

diff --git a/pkg/plugins/runtime/k8s/controllers/testdata/15.dataplane.yaml b/pkg/plugins/runtime/k8s/controllers/testdata/15.dataplane.yaml
@@ -9,6 +9,8 @@ spec:
       tags:
         app: example
         k8s.kuma.io/namespace: demo
+        k8s.kuma.io/service-name: example
+        k8s.kuma.io/service-port: "80"
         kuma.io/protocol: tcp
         kuma.io/service: example_demo_svc_80
         kuma.io/zone: zone-1