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

Move watchTimeout value to the top and add comments

Browse Source
This commit is contained in:
Caleb Woodbine 2020-04-01 16:19:34 +13:00
parent 0c8ae2abf3
commit f0757ecd77
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
test/e2e/common/configmap.go
View File

@ -32,6 +32,11 @@ import (
"github.com/onsi/ginkgo"
)
var (
// tests which use this appear to all pass within the given time
generalWatchTimeout = int64(60)
)
var _ = ginkgo.Describe("[sig-node] ConfigMap", func() {
f := framework.NewDefaultFramework("configmap")
@ -178,8 +183,7 @@ var _ = ginkgo.Describe("[sig-node] ConfigMap", func() {
ginkgo.By("setting a watch for the ConfigMap")
// setup a watch for the ConfigMap
resourceWatchTimeoutSeconds := int64(60)
resourceWatch, err := f.ClientSet.CoreV1().ConfigMaps(testNamespaceName).Watch(context.TODO(), metav1.ListOptions{LabelSelector: "test-configmap-static=true", TimeoutSeconds: &resourceWatchTimeoutSeconds})
resourceWatch, err := f.ClientSet.CoreV1().ConfigMaps(testNamespaceName).Watch(context.TODO(), metav1.ListOptions{LabelSelector: "test-configmap-static=true", TimeoutSeconds: &generalWatchTimeout})
framework.ExpectNoError(err, "Failed to setup watch on newly created ConfigMap")
resourceWatchChan := resourceWatch.ResultChan()
@ -246,6 +250,7 @@ var _ = ginkgo.Describe("[sig-node] ConfigMap", func() {
if watchEvent.Type == watch.Deleted {
break
}
fmt.Println("failed to find Deleted watchEvent")
}
})
})