github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-03 09:22:44 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #15568 from a-robinson/e2e

Browse Source 
Auto commit by PR queue bot
This commit is contained in:
k8s-merge-robot 2015-10-19 19:43:18 -07:00
commit 1f758d8ca6
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
test/e2e/service.go
View File

@ -548,6 +548,16 @@ var _ = Describe("Services", func() {
i++ i++
} }
By("updating service's port " + serviceName + " and reaching it at the same IP")
service, err = updateService(f.Client, f.Namespace.Name, serviceName, func(s *api.Service) {
s.Spec.Ports[0].Port = 19482 // chosen arbitrarily to not conflict with port 80
})
Expect(err).NotTo(HaveOccurred())
port = service.Spec.Ports[0]
if !testLoadBalancerReachable(service.Status.LoadBalancer.Ingress[0], port.Port) {
Failf("Failed to reach load balancer at original ingress after updating its port: %+v", service)
}
By("changing service " + serviceName + " back to type=ClusterIP") By("changing service " + serviceName + " back to type=ClusterIP")
service, err = updateService(f.Client, f.Namespace.Name, serviceName, func(s *api.Service) { service, err = updateService(f.Client, f.Namespace.Name, serviceName, func(s *api.Service) {
s.Spec.Type = api.ServiceTypeClusterIP s.Spec.Type = api.ServiceTypeClusterIP
@ -580,7 +590,7 @@ var _ = Describe("Services", func() {
ip = pickNodeIP(f.Client) ip = pickNodeIP(f.Client)
testNotReachable(ip, nodePort2) testNotReachable(ip, nodePort2)
By("checking the LoadBalancer is closed") By("checking the LoadBalancer is closed")
testLoadBalancerNotReachable(ingress1, 80) testLoadBalancerNotReachable(ingress1, port.Port)
}) })
It("should prevent NodePort collisions", func() { It("should prevent NodePort collisions", func() {