github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 01:40:07 +00:00
Code Issues Projects Releases Wiki Activity

Add watch event checks

Browse Source
This commit is contained in:
Caleb Woodbine 2020-05-06 11:04:04 +12:00
parent f0757ecd77
commit b52740c44f
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -188,11 +188,14 @@ var _ = ginkgo.Describe("[sig-node] ConfigMap", func() {
resourceWatchChan := resourceWatch.ResultChan() resourceWatchChan := resourceWatch.ResultChan()
ginkgo.By("waiting for the ConfigMap to be added") ginkgo.By("waiting for the ConfigMap to be added")
foundWatchEvent := false
for watchEvent := range resourceWatchChan { for watchEvent := range resourceWatchChan {
if watchEvent.Type == watch.Added { if watchEvent.Type == watch.Added {
foundWatchEvent = true
break break
} }
} }
framework.ExpectEqual(true, foundWatchEvent, "expected to find a watch.Delete event configmap %s", testConfigMapName)
configMapPatchPayload, err := json.Marshal(v1.ConfigMap{ configMapPatchPayload, err := json.Marshal(v1.ConfigMap{
ObjectMeta: metav1.ObjectMeta{ ObjectMeta: metav1.ObjectMeta{
@ -210,11 +213,14 @@ var _ = ginkgo.Describe("[sig-node] ConfigMap", func() {
_, err = f.ClientSet.CoreV1().ConfigMaps(testNamespaceName).Patch(context.TODO(), testConfigMapName, types.StrategicMergePatchType, []byte(configMapPatchPayload), metav1.PatchOptions{}) _, err = f.ClientSet.CoreV1().ConfigMaps(testNamespaceName).Patch(context.TODO(), testConfigMapName, types.StrategicMergePatchType, []byte(configMapPatchPayload), metav1.PatchOptions{})
framework.ExpectNoError(err, "failed to patch ConfigMap") framework.ExpectNoError(err, "failed to patch ConfigMap")
ginkgo.By("waiting for the ConfigMap to be modified") ginkgo.By("waiting for the ConfigMap to be modified")
foundWatchEvent = false
for watchEvent := range resourceWatchChan { for watchEvent := range resourceWatchChan {
if watchEvent.Type == watch.Modified { if watchEvent.Type == watch.Modified {
foundWatchEvent = true
break break
} }
} }
framework.ExpectEqual(true, foundWatchEvent, "expected to find a watch.Modified event configmap %s", testConfigMapName)
ginkgo.By("fetching the ConfigMap") ginkgo.By("fetching the ConfigMap")
configMap, err := f.ClientSet.CoreV1().ConfigMaps(testNamespaceName).Get(context.TODO(), testConfigMapName, metav1.GetOptions{}) configMap, err := f.ClientSet.CoreV1().ConfigMaps(testNamespaceName).Get(context.TODO(), testConfigMapName, metav1.GetOptions{})
@ -246,12 +252,14 @@ var _ = ginkgo.Describe("[sig-node] ConfigMap", func() {
}) })
framework.ExpectNoError(err, "failed to delete ConfigMap collection with LabelSelector") framework.ExpectNoError(err, "failed to delete ConfigMap collection with LabelSelector")
ginkgo.By("waiting for the ConfigMap to be deleted") ginkgo.By("waiting for the ConfigMap to be deleted")
foundWatchEvent = false
for watchEvent := range resourceWatchChan { for watchEvent := range resourceWatchChan {
if watchEvent.Type == watch.Deleted { if watchEvent.Type == watch.Deleted {
foundWatchEvent = true
break break
} }
fmt.Println("failed to find Deleted watchEvent")
} }
framework.ExpectEqual(true, foundWatchEvent, "expected to find a watch.Deleted event configmap %s", testConfigMapName)
}) })
}) })