From c035ee52330c9450c3812d58ce884548f0244dea Mon Sep 17 00:00:00 2001 From: zmquan <952473625@qq.com> Date: Wed, 28 Aug 2024 14:10:11 +0800 Subject: [PATCH] Add delay in endpointslices.go --- internal/ingress/controller/endpointslices.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/ingress/controller/endpointslices.go b/internal/ingress/controller/endpointslices.go index 4f98e3ce7..5c4118e9e 100644 --- a/internal/ingress/controller/endpointslices.go +++ b/internal/ingress/controller/endpointslices.go @@ -22,6 +22,7 @@ import ( "reflect" "strconv" "strings" + "time" "k8s.io/apimachinery/pkg/util/intstr" "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 for _, eps := range epss { + time.Sleep(200 * time.Millisecond) var ports []int32 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