github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 11:50:44 +00:00
Code Issues Projects Releases Wiki Activity

Update name of watchEvent and comment on timeout for watch

Browse Source
This commit is contained in:
Caleb Woodbine 2020-03-25 11:05:40 +13:00
parent bf4f46b9fa
commit 58c532b968
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
test/e2e/network/service.go
View File

@ -2708,14 +2708,15 @@ var _ = SIGDescribe("Services", func() {
}, metav1.CreateOptions{})
framework.ExpectNoError(err, "failed to create Endpoint")
// setup a watch for the Endpoint
// set up a watch for the Endpoint
// this timeout was chosen as there was timeout failure from the CI
endpointWatchTimeoutSeconds := int64(180)
endpointWatch, err := f.ClientSet.CoreV1().Endpoints(ns).Watch(context.TODO(), metav1.ListOptions{LabelSelector: "testendpoint-static=true", TimeoutSeconds: &endpointWatchTimeoutSeconds})
framework.ExpectNoError(err, "failed to setup watch on newly created Endpoint")
endpointWatchChan := endpointWatch.ResultChan()
ginkgo.By("waiting for available Endpoint")
for event := range endpointWatchChan {
if event.Type == "ADDED" {
for watchEvent := range endpointWatchChan {
if watchEvent.Type == "ADDED" {
break
}
}
@ -2766,7 +2767,7 @@ var _ = SIGDescribe("Services", func() {
},
},
})
framework.ExpectNoError(err, "failed to marshal JSON for Event patch")
framework.ExpectNoError(err, "failed to marshal JSON for WatchEvent patch")
ginkgo.By("patching the Endpoint")
_, err = f.ClientSet.CoreV1().Endpoints(ns).Patch(context.TODO(), testEndpointName, types.StrategicMergePatchType, []byte(endpointPatch), metav1.PatchOptions{})
framework.ExpectNoError(err, "failed to patch Endpoint")
@ -2787,8 +2788,8 @@ var _ = SIGDescribe("Services", func() {
framework.ExpectNoError(err, "failed to delete Endpoint by Collection")
ginkgo.By("waiting for Endpoint deletion")
for event := range endpointWatchChan {
if event.Type == "DELETED" {
for watchEvent := range endpointWatchChan {
if watchEvent.Type == "DELETED" {
break
}
}