wip

test/e2e/serial/tests/metrics.go

@@ -41,15 +41,15 @@ var _ = Describe("metrics exposed securely", Serial, func() {
 
 	Context("testing metrics e2e from rte worker pod", func() {
 		metricsPort := "2112"
-		labelSelector := "name=resource-topology"
-		pods, err := e2eclient.K8sClient.CoreV1().Pods(namespace).List(context.TODO(), metav1.ListOptions{
-			LabelSelector: labelSelector,
-		})
-		Expect(err).To(BeNil(), "Error listing worker pods: %v", err)
-		Expect(len(pods.Items)).To(BeNumerically(">=", 1), "There should be at least one worker pod")
-		workerPod := &pods.Items[0]
 
 		It("should be able to fetch metrics from the worker pod container using kube-rbac-proxy", func() {
+			labelSelector := "name=resource-topology"
+			pods, err := e2eclient.K8sClient.CoreV1().Pods(namespace).List(context.TODO(), metav1.ListOptions{
+				LabelSelector: labelSelector,
+			})
+			Expect(err).To(BeNil(), "Error listing worker pods: %v", err)
+			Expect(len(pods.Items)).To(BeNumerically(">=", 1), "There should be at least one worker pod")
+			workerPod := &pods.Items[0]
 			stdout := fetchMetricsFromPod(workerPod, metricsAddress, metricsPort)
 			Expect(strings.Contains(stdout, "rte_noderesourcetopology_writes_total")).To(BeTrue(), "rte_noderesourcetopology_writes_total metric not found")
 			Expect(strings.Contains(stdout, "rte_wakeup_delay_milliseconds")).To(BeTrue(), "rte_wakeup_delay_milliseconds metric not found")