github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 11:50:44 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #95333 from jayunit100/node_port_udp_fast_test

Browse Source 
Node port udp fast test
This commit is contained in:
Kubernetes Prow Robot 2020-10-13 18:19:54 -07:00 committed by GitHub
commit 9891ac4d4d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
test/e2e/framework/network/utils.go
View File

@ -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)
}

10
test/e2e/network/networking.go
View File

@ -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)