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

Merge pull request #117830 from aojea/deflake_term

Browse Source 
e2e services: retry if healthcheck nodeport is not available
This commit is contained in:
Kubernetes Prow Robot 2023-05-06 04:41:16 -07:00 committed by GitHub
commit a382ae92dd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
test/e2e/network/service.go
View File

@ -2757,11 +2757,13 @@ var _ = common.SIGDescribe("Services", func() {
cmd := fmt.Sprintf(`curl -s -o /dev/null -w "%%{http_code}" --connect-timeout 5 http://%s/healthz`, healthCheckNodePortAddr)
out, err := e2eoutput.RunHostCmd(pausePod0.Namespace, pausePod0.Name, cmd)
if err != nil {
return false, err
framework.Logf("unexpected error trying to connect to nodeport %d : %v", healthCheckNodePortAddr, err)
return false, nil
}
expectedOut := "200"
if out != expectedOut {
framework.Logf("expected output: %s , got %s", expectedOut, out)
return false, nil
}
return true, nil
@ -2778,11 +2780,13 @@ var _ = common.SIGDescribe("Services", func() {
cmd := fmt.Sprintf(`curl -s -o /dev/null -w "%%{http_code}" --connect-timeout 5 http://%s/healthz`, healthCheckNodePortAddr)
out, err := e2eoutput.RunHostCmd(pausePod0.Namespace, pausePod0.Name, cmd)
if err != nil {
return false, err
framework.Logf("unexpected error trying to connect to nodeport %d : %v", healthCheckNodePortAddr, err)
return false, nil
}
expectedOut := "503"
if out != expectedOut {
framework.Logf("expected output: %s , got %s", expectedOut, out)
return false, nil
}
return true, nil