github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-12 13:31:52 +00:00
Code Issues Projects Releases Wiki Activity

Confirm list quantity after pod template collection deleted

Browse Source
This commit is contained in:
Stephen Heywood 2020-06-02 03:20:58 +00:00
parent d373bef4e4
commit aaa0734259
1 changed files with 15 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -141,38 +141,37 @@ var _ = ginkgo.Describe("[sig-node] PodTemplates", func() {
framework.ExpectEqual(len(podTemplateList.Items), len(podTemplateNames), "looking for expected number of pod templates") framework.ExpectEqual(len(podTemplateList.Items), len(podTemplateNames), "looking for expected number of pod templates")
ginkgo.By("delete collection of pod templates") ginkgo.By("delete collection of pod templates")
// confirm that delete collection does remove all pod templates // delete collection
err = wait.PollImmediate(podTemplateRetryPeriod, podTemplateRetryTimeout, deletePodTemplateCollection(f, "podtemplate-set=true")) framework.Logf("requesting DeleteCollection of pod templates")
framework.ExpectNoError(err, "failed to delete collection") 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")
ginkgo.By("get a list of pod templates with a label in the current namespace") ginkgo.By("check that the list of pod templates matches the requested quantity")
// get list of pod templates
podTemplateList, err = f.ClientSet.CoreV1().PodTemplates(f.Namespace.Name).List(context.TODO(), metav1.ListOptions{
LabelSelector: "podtemplate-set=true",
})
framework.ExpectNoError(err, "failed to get a list of pod templates")
framework.ExpectEqual(len(podTemplateList.Items), 0, "pod templates should all be deleted")
err = wait.PollImmediate(podTemplateRetryPeriod, podTemplateRetryTimeout, checkPodTemplateListQuantity(f, "podtemplate-set=true", 0))
framework.ExpectNoError(err, "failed to count required pod templates")
}) })
}) })
func deletePodTemplateCollection(f *framework.Framework, label string) func() (bool, error) { func checkPodTemplateListQuantity(f *framework.Framework, label string, quantity int) func() (bool, error) {
return func() (bool, error) { return func() (bool, error) {
var err error var err error
framework.Logf("requesting DeleteCollection of pod templates") framework.Logf("requesting list of pod templates to confirm quantity")
err = f.ClientSet.CoreV1().PodTemplates(f.Namespace.Name).DeleteCollection(context.TODO(), metav1.DeleteOptions{}, metav1.ListOptions{ list, err := f.ClientSet.CoreV1().PodTemplates(f.Namespace.Name).List(context.TODO(), metav1.ListOptions{
LabelSelector: label}) LabelSelector: label})
if err != nil { if err != nil {
return false, err return false, err
} else {
return true, nil
} }
if len(list.Items) != quantity {
return false, err
}
return true, nil
} }
} }