From 0ac66040f2c6e46b4306cf3820bc9a92bf2e80af Mon Sep 17 00:00:00 2001 From: David Eads Date: Thu, 3 Nov 2022 17:25:32 -0400 Subject: [PATCH] demonstrate the watch is working fast --- .../e2e/common/storage/projected_configmap.go | 20 +++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/vendor/k8s.io/kubernetes/test/e2e/common/storage/projected_configmap.go b/vendor/k8s.io/kubernetes/test/e2e/common/storage/projected_configmap.go index 4c006f844257..fe1fbe5362c2 100644 --- a/vendor/k8s.io/kubernetes/test/e2e/common/storage/projected_configmap.go +++ b/vendor/k8s.io/kubernetes/test/e2e/common/storage/projected_configmap.go @@ -149,6 +149,25 @@ var _ = SIGDescribe("Projected configMap", func() { ginkgo.By("Creating the pod") f.PodClient().CreateSync(pod) + + watcher, err := f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Watch(context.TODO(), metav1.ListOptions{}) + defer watcher.Stop() + go func() { + framework.Logf("STARTING!") + for { + watchEvent, ok := <-watcher.ResultChan() + if !ok { + break + } + name := "unknown" + if configmap, ok := watchEvent.Object.(*v1.ConfigMap); ok { + name = configmap.Name + } + framework.Logf("WATCH type=%v, name=%v", watchEvent.Type, name) + } + framework.Logf("EXIT!") + }() + pollLogs := func() (string, error) { return e2epod.GetPodLogs(f.ClientSet, f.Namespace.Name, pod.Name, pod.Spec.Containers[0].Name) } @@ -163,6 +182,7 @@ var _ = SIGDescribe("Projected configMap", func() { ginkgo.By("waiting to observe update in volume") gomega.Eventually(pollLogs, podLogTimeout, framework.Poll).Should(gomega.ContainSubstring("value-2")) + framework.Logf("SUCCESS!") }) /*