modify eps syncer labels

Author: ApsTomar

pkg/controllers/resources/endpointslices/syncer.go

@@ -115,10 +115,23 @@ func (s *endpointSliceSyncer) ReconcileStart(ctx *synccontext.SyncContext, req c
 		}
 	}
 
-	svc := &corev1.Service{}
+	eps := &discoveryv1.EndpointSlice{}
 	err := ctx.VirtualClient.Get(ctx, types.NamespacedName{
 		Namespace: req.Namespace,
 		Name:      req.Name,
+	}, eps)
+
+	epsLabels := eps.GetLabels()
+	svcName, ok := epsLabels[translate.K8sServiceNameAnnotation]
+	if !ok {
+		klog.Infof("Error retrieving service name: %v", err)
+		return true, nil
+	}
+
+	svc := &corev1.Service{}
+	err = ctx.VirtualClient.Get(ctx, types.NamespacedName{
+		Namespace: req.Namespace,
+		Name:      svcName,
 	}, svc)
 	if err != nil {
 		if kerrors.IsNotFound(err) {

pkg/controllers/resources/endpointslices/translate.go

@@ -13,6 +13,14 @@ func (s *endpointSliceSyncer) translate(ctx *synccontext.SyncContext, vObj clien
 	endpointSlice := translate.HostMetadata(vObj.(*discoveryv1.EndpointSlice),
 		s.VirtualToHost(ctx, types.NamespacedName{Name: vObj.GetName(), Namespace: vObj.GetNamespace()}, vObj),
 		s.excludedAnnotations...)
+
+	virtualSvcName := endpointSlice.GetLabels()[translate.K8sServiceNameAnnotation]
+	vcName := endpointSlice.GetLabels()[translate.MarkerLabel]
+	namespace := endpointSlice.GetLabels()[translate.NamespaceLabel]
+	hostSvcName := translateSvcName(virtualSvcName, namespace, vcName)
+
+	// in case of selector-less service, we need to add "kubernetes.io/service-name" label manually
+	endpointSlice.Labels[translate.K8sServiceNameAnnotation] = hostSvcName
 	s.translateSpec(ctx, endpointSlice)
 	return endpointSlice
 }
@@ -35,3 +43,7 @@ func (s *endpointSliceSyncer) translateUpdate(ctx *synccontext.SyncContext, pObj
 	pObj.Endpoints = translated.Endpoints
 	return nil
 }
+
+func translateSvcName(virtualSvcName, namespace, vcName string) string {
+	return virtualSvcName + "-x-" + namespace + "-x-" + vcName
+}

pkg/util/translate/types.go

@@ -30,6 +30,8 @@ var (
 
 	ManagedAnnotationsAnnotation = "vcluster.loft.sh/managed-annotations"
 	ManagedLabelsAnnotation      = "vcluster.loft.sh/managed-labels"
+
+	K8sServiceNameAnnotation = "kubernetes.io/service-name"
 )
 
 var Default Translator = &singleNamespace{}