Switch deprecated corev1.Endpoints with discoveryv1.EndpointSlices

Had to rewrite logServiceEndpoints function:
 - Changed from using corev1.Endpoints to discoveryv1.EndpointSliceList
 - Now lists all EndpointSlices for a service using the kubernetes.io/service-name label
 - Updated logic to work with the new EndpointSlice structure where:
 - Each endpoint has a Conditions.Ready field instead of separate ready/not-ready address lists
 - Ports are at the slice level with optional pointer fields

Signed-off-by: Anik Bhattacharjee <anbhatta@redhat.com>

Author: anik120

tests/e2e/test_utils.go

@@ -13,6 +13,7 @@ import (
 	"github.com/stretchr/testify/require"
 	appsv1 "k8s.io/api/apps/v1"
 	corev1 "k8s.io/api/core/v1"
+	discoveryv1 "k8s.io/api/discovery/v1"
 	apiextv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
 	"k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
@@ -313,33 +314,56 @@ func logPodDetails(t *testing.T, testenv *TestEnvironment, namespace string) {
 func logServiceEndpoints(t *testing.T, testenv *TestEnvironment, namespace, serviceName string) {
 	t.Helper()
 
-	endpoints := &corev1.Endpoints{}
-	err := testenv.Client.Get(testenv.Ctx, types.NamespacedName{
-		Name:      serviceName,
-		Namespace: namespace,
-	}, endpoints)
+	// List all EndpointSlices for the service
+	endpointSliceList := &discoveryv1.EndpointSliceList{}
+	err := testenv.Client.List(testenv.Ctx, endpointSliceList,
+		client.InNamespace(namespace),
+		client.MatchingLabels{"kubernetes.io/service-name": serviceName})
 
 	if err != nil {
-		t.Logf("Failed to get endpoints for service %s: %v", serviceName, err)
+		t.Logf("Failed to get endpoint slices for service %s: %v", serviceName, err)
+		return
+	}
+
+	if len(endpointSliceList.Items) == 0 {
+		t.Logf("🔗 Service %s has no endpoint slices", serviceName)
 		return
 	}
 
 	t.Logf("🔗 Service %s endpoints:", serviceName)
-	for i, subset := range endpoints.Subsets {
-		t.Logf("  Subset %d:", i)
-		// Ready addresses indicate pods that passed health checks and can receive traffic
-		t.Logf("    Ready addresses: %d", len(subset.Addresses))
-		for _, addr := range subset.Addresses {
-			t.Logf("      - %s", addr.IP)
-		}
-		// Not ready addresses show pods that exist but failed health checks
-		t.Logf("    Not ready addresses: %d", len(subset.NotReadyAddresses))
-		for _, addr := range subset.NotReadyAddresses {
-			t.Logf("      - %s", addr.IP)
+	for i, slice := range endpointSliceList.Items {
+		t.Logf("  EndpointSlice %d (%s):", i, slice.Name)
+
+		readyCount := 0
+		notReadyCount := 0
+
+		for _, endpoint := range slice.Endpoints {
+			isReady := endpoint.Conditions.Ready != nil && *endpoint.Conditions.Ready
+			if isReady {
+				readyCount++
+				for _, addr := range endpoint.Addresses {
+					t.Logf("    Ready: %s", addr)
+				}
+			} else {
+				notReadyCount++
+				for _, addr := range endpoint.Addresses {
+					t.Logf("    Not ready: %s", addr)
+				}
+			}
 		}
+
+		t.Logf("    Summary: %d ready, %d not ready", readyCount, notReadyCount)
 		t.Logf("    Ports:")
-		for _, port := range subset.Ports {
-			t.Logf("      - %s: %d", port.Name, port.Port)
+		for _, port := range slice.Ports {
+			portNum := int32(0)
+			if port.Port != nil {
+				portNum = *port.Port
+			}
+			portName := ""
+			if port.Name != nil {
+				portName = *port.Name
+			}
+			t.Logf("      - %s: %d", portName, portNum)
 		}
 	}
 }