fix: r

Signed-off-by: ashing <[email protected]>

Author: ronething

internal/controller/ingress_controller.go

@@ -359,6 +359,11 @@ func (r *IngressReconciler) processBackendService(ctx context.Context, tctx *pro
 		Name:      backendService.Name,
 	}] = endpointSliceList.Items
 
+	tctx.Services[client.ObjectKey{
+		Namespace: namespace,
+		Name:      backendService.Name,
+	}] = &service
+
 	return nil
 }
 

internal/provider/adc/translator/ingress.go

@@ -117,11 +117,31 @@ func (t *Translator) TranslateIngress(tctx *provider.TranslateContext, obj *netw
 			} else if backendService.Port.Name != "" {
 				servicePortName = backendService.Port.Name
 			}
-			_ = servicePort
+
+			getService := tctx.Services[types.NamespacedName{
+				Namespace: obj.Namespace,
+				Name:      backendService.Name,
+			}]
+			if getService == nil {
+				continue
+			}
+
+			var getServicePort *corev1.ServicePort
+			for _, port := range getService.Spec.Ports {
+				port := port
+				if servicePort > 0 && port.Port == servicePort {
+					getServicePort = &port
+					break
+				}
+				if servicePortName != "" && port.Name == servicePortName {
+					getServicePort = &port
+					break
+				}
+			}
 
 			// convert the EndpointSlice to upstream nodes
 			if len(endpointSlices) > 0 {
-				upstream.Nodes = t.translateEndpointSliceForIngress(1, endpointSlices, servicePortName)
+				upstream.Nodes = t.translateEndpointSliceForIngress(1, endpointSlices, getServicePort)
 			}
 
 			// if there is no upstream node, create a placeholder node
@@ -171,16 +191,16 @@ func (t *Translator) TranslateIngress(tctx *provider.TranslateContext, obj *netw
 }
 
 // translateEndpointSliceForIngress create upstream nodes from EndpointSlice
-func (t *Translator) translateEndpointSliceForIngress(weight int, endpointSlices []discoveryv1.EndpointSlice, portName string) adctypes.UpstreamNodes {
+func (t *Translator) translateEndpointSliceForIngress(weight int, endpointSlices []discoveryv1.EndpointSlice, servciePort *corev1.ServicePort) adctypes.UpstreamNodes {
 	var nodes adctypes.UpstreamNodes
 	if len(endpointSlices) == 0 {
 		return nodes
 	}
 
 	for _, endpointSlice := range endpointSlices {
 		for _, port := range endpointSlice.Ports {
-			// if the port name is specified, only use the matching port
-			if portName != "" && *port.Name != portName {
+			// if the port number is specified, only use the matching port
+			if servciePort != nil && *port.Name != servciePort.Name {
 				continue
 			}
 			for _, endpoint := range endpointSlice.Endpoints {

internal/provider/provider.go

@@ -24,6 +24,7 @@ type TranslateContext struct {
 	EndpointSlices   map[types.NamespacedName][]discoveryv1.EndpointSlice
 	Secrets          map[types.NamespacedName]*corev1.Secret
 	PluginConfigs    map[types.NamespacedName]*v1alpha1.PluginConfig
+	Services         map[types.NamespacedName]*corev1.Service
 }
 
 func NewDefaultTranslateContext() *TranslateContext {