Add 'waitForLuaSync' sleep in external name TCP test

This commit is contained in:
Kevin Pullin 2019-02-17 20:32:27 -08:00
parent f6aded2c51
commit 3ac57097f6

View file

@ -22,6 +22,7 @@ import (
"github.com/parnurzeal/gorequest" "github.com/parnurzeal/gorequest"
"net" "net"
"strings" "strings"
"time"
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"
@ -33,6 +34,10 @@ import (
"k8s.io/ingress-nginx/test/e2e/framework" "k8s.io/ingress-nginx/test/e2e/framework"
) )
const (
waitForLuaSync = 5 * time.Second
)
var _ = framework.IngressNginxDescribe("TCP Feature", func() { var _ = framework.IngressNginxDescribe("TCP Feature", func() {
f := framework.NewDefaultFramework("tcp") f := framework.NewDefaultFramework("tcp")
@ -164,6 +169,8 @@ var _ = framework.IngressNginxDescribe("TCP Feature", func() {
Update(config) Update(config)
Expect(err).NotTo(HaveOccurred(), "unexpected error updating configmap") Expect(err).NotTo(HaveOccurred(), "unexpected error updating configmap")
time.Sleep(waitForLuaSync)
// Validate that the generated nginx config contains the expected `proxy_upstream_name` value // Validate that the generated nginx config contains the expected `proxy_upstream_name` value
f.WaitForNginxConfiguration( f.WaitForNginxConfiguration(
func(cfg string) bool { func(cfg string) bool {
@ -183,6 +190,7 @@ var _ = framework.IngressNginxDescribe("TCP Feature", func() {
}, },
} }
ips, err := resolver.LookupHost(context.Background(), "google-public-dns-b.google.com") ips, err := resolver.LookupHost(context.Background(), "google-public-dns-b.google.com")
Expect(err).NotTo(HaveOccurred(), "unexpected error from DNS resolver")
Expect(ips).Should(ContainElement("8.8.4.4")) Expect(ips).Should(ContainElement("8.8.4.4"))
}) })