fix 503 error caused by outdated endpooints

Signed-off-by: Huabing Zhao <[email protected]>
envoyproxy · Nov 21, 2024 · cf820b9 · cf820b9
1 parent 2def6a4
commit cf820b9
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/internal/provider/kubernetes/controller.go b/internal/provider/kubernetes/controller.go
@@ -454,12 +454,19 @@ func (r *gatewayAPIReconciler) processBackendRefs(ctx context.Context, gwcResour
 			} else {
 				for _, endpointSlice := range endpointSliceList.Items {
 					key := utils.NamespacedName(&endpointSlice).String()
+					r.log.Info("added EndpointSlice to resource tree",
+						"namespace", endpointSlice.Namespace,
+						"name", endpointSlice.Name)
 					if !resourceMappings.allAssociatedEndpointSlices.Has(key) {
 						resourceMappings.allAssociatedEndpointSlices.Insert(key)
-						r.log.Info("added EndpointSlice to resource tree",
-							"namespace", endpointSlice.Namespace,
-							"name", endpointSlice.Name)
 						gwcResource.EndpointSlices = append(gwcResource.EndpointSlices, &endpointSlice)
+					} else {
+						for i, es := range gwcResource.EndpointSlices {
+							if es.Name == endpointSlice.Name && es.Namespace == endpointSlice.Namespace {
+								gwcResource.EndpointSlices = append(gwcResource.EndpointSlices[:i], gwcResource.EndpointSlices[i+1:]...)
+								gwcResource.EndpointSlices = append(gwcResource.EndpointSlices, &endpointSlice)
+							}
+						}
 					}
 				}
 			}