feat(MeshService): handle headless Services

deployments/charts/kuma/crds/kuma.io_meshservices.yaml

@@ -65,6 +65,11 @@ spec:
                 x-kubernetes-list-type: map
               selector:
                 properties:
+                  dataplaneRef:
+                    properties:
+                      name:
+                        type: string
+                    type: object
                   dataplaneTags:
                     additionalProperties:
                       type: string

deployments/charts/kuma/templates/cp-rbac.yaml

@@ -43,6 +43,14 @@ rules:
     verbs:
     - list
     - watch
+  - apiGroups:
+    - "discovery.k8s.io"
+    resources:
+      - endpointslices
+    verbs:
+    - get
+    - list
+    - watch
   - apiGroups:
       - "apps"
     resources:

docs/generated/raw/crds/kuma.io_meshservices.yaml

@@ -65,6 +65,11 @@ spec:
                 x-kubernetes-list-type: map
               selector:
                 properties:
+                  dataplaneRef:
+                    properties:
+                      name:
+                        type: string
+                    type: object
                   dataplaneTags:
                     additionalProperties:
                       type: string

pkg/core/resources/apis/meshservice/api/v1alpha1/meshservice.go

@@ -11,6 +11,19 @@ type DataplaneTags map[string]string
 
 type Selector struct {
 	DataplaneTags DataplaneTags `json:"dataplaneTags,omitempty"`
+	DataplaneRef  *DataplaneRef `json:"dataplaneRef,omitempty"`
+}
+
+type DataplaneRef struct {
+	Name string `json:"name,omitempty"`
+}
+
+func (r *DataplaneRef) Matches() bool {
+	if r == nil {
+		return false
+	}
+
+	return false
 }
 
 type Port struct {

pkg/core/resources/apis/meshservice/api/v1alpha1/schema.yaml

@@ -40,6 +40,11 @@ properties:
         x-kubernetes-list-type: map
       selector:
         properties:
+          dataplaneRef:
+            properties:
+              name:
+                type: string
+            type: object
           dataplaneTags:
             additionalProperties:
               type: string

pkg/core/resources/apis/meshservice/k8s/crd/kuma.io_meshservices.yaml

@@ -65,6 +65,11 @@ spec:
                 x-kubernetes-list-type: map
               selector:
                 properties:
+                  dataplaneRef:
+                    properties:
+                      name:
+                        type: string
+                    type: object
                   dataplaneTags:
                     additionalProperties:
                       type: string

pkg/plugins/policies/core/xds/meshroute/listeners.go

@@ -71,6 +71,9 @@ func CollectServices(
 	for _, outbound := range proxy.Dataplane.Spec.GetNetworking().GetOutbounds() {
 		oface := proxy.Dataplane.Spec.Networking.ToOutboundInterface(outbound)
 		if outbound.BackendRef != nil {
+			if outbound.GetAddress() == proxy.Dataplane.Spec.GetNetworking().GetAddress() {
+				continue
+			}
 			ms, ok := meshCtx.MeshServiceByName[outbound.BackendRef.Name]
 			if !ok {
 				// we want to ignore service which is not found. Logging might be excessive here.