DevFW-CICD/ingress-nginx-helm
16
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Update endpointslices.go

Browse source
This commit is contained in:
zmquan 2024-08-28 11:30:29 +08:00 committed by GitHub
parent 3cde7770dd
commit b9a55af28d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
internal/ingress/controller/endpointslices.go
View file

@ -22,6 +22,7 @@ import (
"reflect" "reflect"
"strconv" "strconv"
"strings" "strings"
"time"
"k8s.io/apimachinery/pkg/util/intstr" "k8s.io/apimachinery/pkg/util/intstr"
"k8s.io/apimachinery/pkg/util/validation" "k8s.io/apimachinery/pkg/util/validation"
@ -84,6 +85,7 @@ func getEndpointsFromSlices(s *corev1.Service, port *corev1.ServicePort, proto c
} }
// loop over all endpointSlices generated for service // loop over all endpointSlices generated for service
for _, eps := range epss { for _, eps := range epss {
time.Sleep(200 * time.Millisecond)
var ports []int32 var ports []int32
if len(eps.Ports) == 0 && port.TargetPort.Type == intstr.Int { if len(eps.Ports) == 0 && port.TargetPort.Type == intstr.Int {
// When ports is empty, it indicates that there are no defined ports, using svc targePort if it's a number // When ports is empty, it indicates that there are no defined ports, using svc targePort if it's a number