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

Add watch checks

Browse Source
This commit is contained in:
Caleb Woodbine 2020-04-22 11:23:16 +12:00
parent a4e29f2481
commit a2c19d7ae0
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
test/e2e/common/pods.go
View File

@ -910,13 +910,16 @@ var _ = framework.KubeDescribe("Pods", func() {
podWatchChan := podWatch.ResultChan() podWatchChan := podWatch.ResultChan()
ginkgo.By("watching for Pod to be ready") ginkgo.By("watching for Pod to be ready")
eventFound := false
for watchEvent := range podWatchChan { for watchEvent := range podWatchChan {
podWatchEvent, ok := watchEvent.Object.(*v1.Pod) podWatchEvent, ok := watchEvent.Object.(*v1.Pod)
framework.ExpectEqual(ok, true, "unable to assert runtime object type to v1.Pod") framework.ExpectEqual(ok, true, "unable to assert runtime object type to v1.Pod")
if podWatchEvent.Status.Phase == v1.PodRunning { if podWatchEvent.Status.Phase == v1.PodRunning {
eventFound = true
break break
} }
} }
framework.ExpectEqual(eventFound, true, "failed to find running Pod")
ginkgo.By("patching the Pod with a new Label and updated data") ginkgo.By("patching the Pod with a new Label and updated data")
podPatch, err := json.Marshal(v1.Pod{ podPatch, err := json.Marshal(v1.Pod{
@ -978,11 +981,14 @@ var _ = framework.KubeDescribe("Pods", func() {
framework.ExpectNoError(err, "failed to delete Pod by collection") framework.ExpectNoError(err, "failed to delete Pod by collection")
ginkgo.By("watching for the Pod to be deleted") ginkgo.By("watching for the Pod to be deleted")
eventFound = false
for watchEvent := range podWatchChan { for watchEvent := range podWatchChan {
if watchEvent.Type == watch.Deleted { if watchEvent.Type == watch.Deleted {
eventFound = true
break break
} }
} }
framework.ExpectEqual(eventFound, true, "failed to find Pod %v event", watch.Deleted)
}) })
}) })