Add more metadata about the target if possible

control-plane/catalog/to-consul/resource.go

@@ -28,7 +28,10 @@ const (
 
 	// ConsulK8SNS is the key used in the meta to record the namespace
 	// of the service/node registration.
-	ConsulK8SNS = "external-k8s-ns"
+	ConsulK8SNS       = "external-k8s-ns"
+	ConsulK8SRefKind  = "external-k8s-ref-kind"
+	ConsulK8SRefValue = "external-k8s-ref-name"
+	ConsulK8SNodeName = "external-k8s-node-name"
 )
 
 type NodePortSyncType string
@@ -656,6 +659,19 @@ func (t *ServiceResource) registerServiceInstance(
 			r.Service.ID = serviceID(r.Service.Service, addr)
 			r.Service.Address = addr
 			r.Service.Port = epPort
+			r.Service.Meta = make(map[string]string)
+			// Deepcopy baseService.Meta into r.Service.Meta as baseService is shared
+			// between all nodes of a service
+			for k, v := range baseService.Meta {
+				r.Service.Meta[k] = v
+			}
+			if subsetAddr.TargetRef != nil {
+				r.Service.Meta[ConsulK8SRefValue] = subsetAddr.TargetRef.Name
+				r.Service.Meta[ConsulK8SRefKind] = subsetAddr.TargetRef.Kind
+			}
+			if subsetAddr.NodeName != nil {
+				r.Service.Meta[ConsulK8SNodeName] = *subsetAddr.NodeName
+			}
 
 			t.consulMap[key] = append(t.consulMap[key], &r)
 		}

control-plane/catalog/to-consul/resource_test.go

@@ -1266,6 +1266,39 @@ func TestServiceResource_clusterIPTargetPortNamed(t *testing.T) {
 	})
 }
 
+// Test target information are set in service meta.
+func TestServiceResource_targetRefInMeta(t *testing.T) {
+	t.Parallel()
+	client := fake.NewSimpleClientset()
+	syncer := newTestSyncer()
+	serviceResource := defaultServiceResource(client, syncer)
+	serviceResource.ClusterIPSync = true
+
+	// Start the controller
+	closer := controller.TestControllerRun(&serviceResource)
+	defer closer()
+
+	// Insert the service
+	svc := clusterIPService("foo", metav1.NamespaceDefault)
+	_, err := client.CoreV1().Services(metav1.NamespaceDefault).Create(context.Background(), svc, metav1.CreateOptions{})
+	require.NoError(t, err)
+
+	// Insert the endpoints
+	createEndpoints(t, client, "foo", metav1.NamespaceDefault)
+
+	// Verify what we got
+	retry.Run(t, func(r *retry.R) {
+		syncer.Lock()
+		defer syncer.Unlock()
+		actual := syncer.Registrations
+		require.Len(r, actual, 2)
+		require.Equal(r, "foobar", actual[0].Service.Meta[ConsulK8SRefValue])
+		require.Equal(r, "pod", actual[0].Service.Meta[ConsulK8SRefKind])
+		require.NotContains(r, ConsulK8SRefValue, actual[0].Service.Meta)
+		require.NotContains(r, ConsulK8SRefKind, actual[0].Service.Meta)
+	})
+}
+
 // Test allow/deny namespace lists.
 func TestServiceResource_AllowDenyNamespaces(t *testing.T) {
 	t.Parallel()
@@ -1601,6 +1634,7 @@ func createNodes(t *testing.T, client *fake.Clientset) (*apiv1.Node, *apiv1.Node
 func createEndpoints(t *testing.T, client *fake.Clientset, serviceName string, namespace string) {
 	node1 := nodeName1
 	node2 := nodeName2
+	target_ref := apiv1.ObjectReference{Kind: "pod", Name: "foobar"}
 	_, err := client.CoreV1().Endpoints(namespace).Create(
 		context.Background(),
 		&apiv1.Endpoints{
@@ -1612,7 +1646,7 @@ func createEndpoints(t *testing.T, client *fake.Clientset, serviceName string, n
 			Subsets: []apiv1.EndpointSubset{
 				{
 					Addresses: []apiv1.EndpointAddress{
-						{NodeName: &node1, IP: "1.1.1.1"},
+						{NodeName: &node1, IP: "1.1.1.1", TargetRef: &target_ref},
 					},
 					Ports: []apiv1.EndpointPort{
 						{Name: "http", Port: 8080},