e2e networking: wait for endpoints to be published

Antonio Ojea · aojea · commit ec295c0f2a65 · 2020-06-29T15:04:28.000+02:00
e2e test wait for the endpoints objects to be created
diff --git a/test/e2e/framework/network/utils.go b/test/e2e/framework/network/utils.go
@@ -673,6 +673,13 @@ func (config *NetworkingTestConfig) setup(selector map[string]string) {
 	} else {
 		config.NodeIP = e2enode.FirstAddress(nodeList, v1.NodeInternalIP)
 	}
+
+	ginkgo.By("Waiting for NodePort service to expose endpoint")
+	err = framework.WaitForServiceEndpointsNum(config.f.ClientSet, config.Namespace, nodePortServiceName, len(config.EndpointPods), time.Second, wait.ForeverTestTimeout)
+	framework.ExpectNoError(err, "failed to validate endpoints for service %s in namespace: %s", nodePortServiceName, config.Namespace)
+	ginkgo.By("Waiting for Session Affinity service to expose endpoint")
+	err = framework.WaitForServiceEndpointsNum(config.f.ClientSet, config.Namespace, sessionAffinityServiceName, len(config.EndpointPods), time.Second, wait.ForeverTestTimeout)
+	framework.ExpectNoError(err, "failed to validate endpoints for service %s in namespace: %s", sessionAffinityServiceName, config.Namespace)
 }
 
 func (config *NetworkingTestConfig) createNetProxyPods(podName string, selector map[string]string) []*v1.Pod {

Original file line number	Diff line number	Diff line change
`@@ -673,6 +673,13 @@ func (config *NetworkingTestConfig) setup(selector map[string]string) {`
`673`	`673`	`} else {`
`674`	`674`	`config.NodeIP = e2enode.FirstAddress(nodeList, v1.NodeInternalIP)`
`675`	`675`	`}`
	`676`	`+`
	`677`	`+ ginkgo.By("Waiting for NodePort service to expose endpoint")`
	`678`	`+ err = framework.WaitForServiceEndpointsNum(config.f.ClientSet, config.Namespace, nodePortServiceName, len(config.EndpointPods), time.Second, wait.ForeverTestTimeout)`
	`679`	`+ framework.ExpectNoError(err, "failed to validate endpoints for service %s in namespace: %s", nodePortServiceName, config.Namespace)`
	`680`	`+ ginkgo.By("Waiting for Session Affinity service to expose endpoint")`
	`681`	`+ err = framework.WaitForServiceEndpointsNum(config.f.ClientSet, config.Namespace, sessionAffinityServiceName, len(config.EndpointPods), time.Second, wait.ForeverTestTimeout)`
	`682`	`+ framework.ExpectNoError(err, "failed to validate endpoints for service %s in namespace: %s", sessionAffinityServiceName, config.Namespace)`
`676`	`683`	`}`
`677`	`684`
`678`	`685`	`func (config NetworkingTestConfig) createNetProxyPods(podName string, selector map[string]string) []v1.Pod {`