github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-06 18:54:06 +00:00
Code Issues Projects Releases Wiki Activity

Use polling while deleting the collection of events

Browse Source
This commit is contained in:
Stephen Heywood 2020-05-26 02:51:44 +00:00
parent cd2ad2b986
commit 7622a794da
1 changed files with 27 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
test/e2e/framework/events/events.go
View File

@ -33,6 +33,12 @@ import (
"k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/types"
) )
const (
eventRetryPeriod = 1 * time.Second
eventRetryTimeout = 1 * time.Minute
)
// Action is a function to be performed by the system. // Action is a function to be performed by the system.
type Action func() error type Action func() error
@ -159,12 +165,10 @@ var _ = ginkgo.Describe("[sig-api-machinery] Events", func() {
framework.ExpectEqual(len(eventList.Items), len(eventTestNames), "looking for expected number of pod templates events") framework.ExpectEqual(len(eventList.Items), len(eventTestNames), "looking for expected number of pod templates events")
ginkgo.By("delete collection of events") ginkgo.By("delete collection of events")
// delete collection // confirm that delete collection does remove all events
framework.Logf("requesting DeleteCollection of events") err = wait.PollImmediate(eventRetryPeriod, eventRetryTimeout, deleteEventCollection(f, "testevent-set=true"))
err = f.ClientSet.CoreV1().Events(f.Namespace.Name).DeleteCollection(context.TODO(), metav1.DeleteOptions{}, metav1.ListOptions{ framework.ExpectNoError(err, "failed to delete collection")
LabelSelector: "testevent-set=true"})
framework.ExpectNoError(err, "failed to delete the test event")
ginkgo.By("get a list of Events with a label in the current namespace") ginkgo.By("get a list of Events with a label in the current namespace")
// get list of events // get list of events
@ -199,3 +203,21 @@ func eventOccurred(c clientset.Interface, namespace, eventSelector, msg string)
return false, nil return false, nil
} }
} }
func deleteEventCollection(f *framework.Framework, label string) func() (bool, error) {
return func() (bool, error) {
var err error
framework.Logf("requesting DeleteCollection of events")
err = f.ClientSet.CoreV1().Events(f.Namespace.Name).DeleteCollection(context.TODO(), metav1.DeleteOptions{}, metav1.ListOptions{
LabelSelector: label})
if err != nil {
return false, err
} else {
return true, nil
}
}
}