Merge pull request kubernetes#95333 from jayunit100/node_port_udp_fast_test

Node port udp fast test

Author: k8s-ci-robot

test/e2e/framework/network/utils.go

@@ -686,6 +686,9 @@ func (config *NetworkingTestConfig) setupCore(selector map[string]string) {
 	config.createTestPods()
 
 	epCount := len(config.EndpointPods)
+
+	// Note that this is not O(n^2) in practice, because epCount SHOULD be < 10.  In cases that epCount is > 10, this would be prohibitively large.
+	// Check maxNetProxyPodsCount for details.
 	config.MaxTries = epCount*epCount + testTries
 	framework.Logf("Setting MaxTries for pod polling to %v for networking test based on endpoint count %v", config.MaxTries, epCount)
 }

test/e2e/network/networking.go

@@ -363,6 +363,16 @@ var _ = SIGDescribe("Networking", func() {
 			}
 		})
 
+		// quick validation of udp, next test confirms that this services update as well after endpoints are removed, but is slower.
+		ginkgo.It("should support basic nodePort: udp functionality", func() {
+			config := e2enetwork.NewNetworkingTestConfig(f, true, false)
+			ginkgo.By(fmt.Sprintf("dialing(udp) %v (node) --> %v:%v (nodeIP) and getting ALL host endpoints", config.NodeIP, config.NodeIP, config.NodeUDPPort))
+			err := config.DialFromNode("udp", config.NodeIP, config.NodeUDPPort, config.MaxTries, 0, config.EndpointHostnames())
+			if err != nil {
+				framework.Failf("Failure validating that nodePort service WAS forwarding properly: %v", err)
+			}
+		})
+
 		// Slow because we confirm that the nodePort doesn't serve traffic, which requires a period of polling.
 		ginkgo.It("should update nodePort: udp [Slow]", func() {
 			config := e2enetwork.NewNetworkingTestConfig(f, true, false)