From 4ce8bb32841823c90bd3aeb44711c4878bb5465f Mon Sep 17 00:00:00 2001 From: zmquan <952473625@qq.com> Date: Wed, 28 Aug 2024 14:38:57 +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..02e23570a 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(100 * 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