github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-17 15:50:10 +00:00
Code Issues Projects Releases Wiki Activity

Use polling while deleting the collection of pod templates

Browse Source
This commit is contained in:
Stephen Heywood 2020-05-22 01:33:20 +00:00
parent 758e3c76a4
commit d373bef4e4
1 changed files with 28 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
test/e2e/common/podtemplates.go
View File

@ -24,12 +24,19 @@ import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/types"
"k8s.io/apimachinery/pkg/util/uuid"
"k8s.io/apimachinery/pkg/util/wait"
"k8s.io/kubernetes/test/e2e/framework"
imageutils "k8s.io/kubernetes/test/utils/image"
"time"
"github.com/onsi/ginkgo"
)
const (
podTemplateRetryPeriod = 1 * time.Second
podTemplateRetryTimeout = 1 * time.Minute
)
var _ = ginkgo.Describe("[sig-node] PodTemplates", func() {
f := framework.NewDefaultFramework("podtemplate")
/*
@ -134,12 +141,10 @@ var _ = ginkgo.Describe("[sig-node] PodTemplates", func() {
framework.ExpectEqual(len(podTemplateList.Items), len(podTemplateNames), "looking for expected number of pod templates")
ginkgo.By("delete collection of pod templates")
// delete collection
// confirm that delete collection does remove all pod templates
framework.Logf("requesting DeleteCollection of pod templates")
err = f.ClientSet.CoreV1().PodTemplates(f.Namespace.Name).DeleteCollection(context.TODO(), metav1.DeleteOptions{}, metav1.ListOptions{
LabelSelector: "podtemplate-set=true"})
framework.ExpectNoError(err, "failed to delete all pod templates")
err = wait.PollImmediate(podTemplateRetryPeriod, podTemplateRetryTimeout, deletePodTemplateCollection(f, "podtemplate-set=true"))
framework.ExpectNoError(err, "failed to delete collection")
ginkgo.By("get a list of pod templates with a label in the current namespace")
// get list of pod templates
@ -153,3 +158,21 @@ var _ = ginkgo.Describe("[sig-node] PodTemplates", func() {
})
})
func deletePodTemplateCollection(f *framework.Framework, label string) func() (bool, error) {
return func() (bool, error) {
var err error
framework.Logf("requesting DeleteCollection of pod templates")
err = f.ClientSet.CoreV1().PodTemplates(f.Namespace.Name).DeleteCollection(context.TODO(), metav1.DeleteOptions{}, metav1.ListOptions{
LabelSelector: label})
if err != nil {
return false, err
} else {
return true, nil
}
}
}