github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-24 20:24:09 +00:00
Code Issues Projects Releases Wiki Activity

Don't check nodeport for nginx ingress

Browse Source
This commit is contained in:
bprashanth 2016-12-12 12:04:51 -08:00
parent 12147a3cd6
commit ee6e4bd832
2 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
test/e2e/ingress.go
View File

@ -114,7 +114,7 @@ var _ = framework.KubeDescribe("Loadbalancing: L7", func() {
By(t.entryLog)
t.execute()
By(t.exitLog)
jig.waitForIngress()
jig.waitForIngress(true)
}
})
@ -196,7 +196,7 @@ var _ = framework.KubeDescribe("Loadbalancing: L7", func() {
By(t.entryLog)
t.execute()
By(t.exitLog)
jig.waitForIngress()
jig.waitForIngress(false)
}
})
})

11
test/e2e/ingress_utils.go
View File

@ -811,7 +811,12 @@ func (j *testJig) deleteIngress() {
framework.ExpectNoError(j.client.Extensions().Ingresses(j.ing.Namespace).Delete(j.ing.Name, nil))
}
func (j *testJig) waitForIngress() {
// waitForIngress waits till the ingress acquires an IP, then waits for its
// hosts/urls to respond to a protocol check (either http or https). If
// waitForNodePort is true, the NodePort of the Service is verified before
// verifying the Ingress. NodePort is currently a requirement for cloudprovider
// Ingress.
func (j *testJig) waitForIngress(waitForNodePort bool) {
// Wait for the loadbalancer IP.
address, err := framework.WaitForIngressAddress(j.client, j.ing.Namespace, j.ing.Name, lbPollTimeout)
if err != nil {
@ -833,7 +838,9 @@ func (j *testJig) waitForIngress() {
}
}
for _, p := range rules.IngressRuleValue.HTTP.Paths {
j.curlServiceNodePort(j.ing.Namespace, p.Backend.ServiceName, int(p.Backend.ServicePort.IntVal))
if waitForNodePort {
j.curlServiceNodePort(j.ing.Namespace, p.Backend.ServiceName, int(p.Backend.ServicePort.IntVal))
}
route := fmt.Sprintf("%v://%v%v", proto, address, p.Path)
framework.Logf("Testing route %v host %v with simple GET", route, rules.Host)
framework.ExpectNoError(pollURL(route, rules.Host, lbPollTimeout, j.pollInterval, timeoutClient, false))