DevFW-CICD/ingress-nginx-helm
14
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix influxdb test flake

Browse source
This commit is contained in:
Manuel de Brito Fontes 2018-05-26 17:11:15 -04:00
parent 564f2a9fe4
commit 2c226ef0fb
1 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
test/e2e/annotations/influxdb.go
View file

@ -31,6 +31,7 @@ import (
corev1 "k8s.io/api/core/v1" corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/util/intstr" "k8s.io/apimachinery/pkg/util/intstr"
"k8s.io/apimachinery/pkg/util/wait"
"k8s.io/ingress-nginx/test/e2e/framework" "k8s.io/ingress-nginx/test/e2e/framework"
) )
@ -77,12 +78,20 @@ var _ = framework.IngressNginxDescribe("Annotations - influxdb", func() {
Expect(res.StatusCode).Should(Equal(http.StatusOK)) Expect(res.StatusCode).Should(Equal(http.StatusOK))
time.Sleep(5 * time.Second) time.Sleep(5 * time.Second)
measurements, err := extractInfluxDBMeasurements(f)
var measurements string
err = wait.PollImmediate(time.Second, time.Minute, func() (bool, error) {
measurements, err = extractInfluxDBMeasurements(f)
if err != nil {
return false, nil
}
return true, nil
})
Expect(err).NotTo(HaveOccurred())
var results map[string][]map[string]interface{} var results map[string][]map[string]interface{}
json.Unmarshal([]byte(measurements), &results) json.Unmarshal([]byte(measurements), &results)
Expect(err).NotTo(HaveOccurred())
Expect(len(measurements)).ShouldNot(Equal(0)) Expect(len(measurements)).ShouldNot(Equal(0))
for _, elem := range results["results"] { for _, elem := range results["results"] {
Expect(len(elem)).ShouldNot(Equal(0)) Expect(len(elem)).ShouldNot(Equal(0))