Commit ed06d9e9 authored by Michelle Au's avatar Michelle Au

Tag e2e/pd.go tests with [Volume]

parent c822e3e1
...@@ -78,7 +78,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() { ...@@ -78,7 +78,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() {
mathrand.Seed(time.Now().UTC().UnixNano()) mathrand.Seed(time.Now().UTC().UnixNano())
}) })
It("should schedule a pod w/ a RW PD, ungracefully remove it, then schedule it on another host [Slow]", func() { It("should schedule a pod w/ a RW PD, ungracefully remove it, then schedule it on another host [Slow] [Volume]", func() {
framework.SkipUnlessProviderIs("gce", "gke", "aws") framework.SkipUnlessProviderIs("gce", "gke", "aws")
By("creating PD") By("creating PD")
...@@ -142,7 +142,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() { ...@@ -142,7 +142,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() {
return return
}) })
It("Should schedule a pod w/ a RW PD, gracefully remove it, then schedule it on another host [Slow]", func() { It("Should schedule a pod w/ a RW PD, gracefully remove it, then schedule it on another host [Slow] [Volume]", func() {
framework.SkipUnlessProviderIs("gce", "gke", "aws") framework.SkipUnlessProviderIs("gce", "gke", "aws")
By("creating PD") By("creating PD")
...@@ -206,7 +206,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() { ...@@ -206,7 +206,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() {
return return
}) })
It("should schedule a pod w/ a readonly PD on two hosts, then remove both ungracefully. [Slow]", func() { It("should schedule a pod w/ a readonly PD on two hosts, then remove both ungracefully. [Slow] [Volume]", func() {
framework.SkipUnlessProviderIs("gce", "gke") framework.SkipUnlessProviderIs("gce", "gke")
By("creating PD") By("creating PD")
...@@ -258,7 +258,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() { ...@@ -258,7 +258,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() {
waitForPDDetach(diskName, host1Name) waitForPDDetach(diskName, host1Name)
}) })
It("Should schedule a pod w/ a readonly PD on two hosts, then remove both gracefully. [Slow]", func() { It("Should schedule a pod w/ a readonly PD on two hosts, then remove both gracefully. [Slow] [Volume]", func() {
framework.SkipUnlessProviderIs("gce", "gke") framework.SkipUnlessProviderIs("gce", "gke")
By("creating PD") By("creating PD")
...@@ -310,7 +310,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() { ...@@ -310,7 +310,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() {
waitForPDDetach(diskName, host1Name) waitForPDDetach(diskName, host1Name)
}) })
It("should schedule a pod w/ a RW PD shared between multiple containers, write to PD, delete pod, verify contents, and repeat in rapid succession [Slow]", func() { It("should schedule a pod w/ a RW PD shared between multiple containers, write to PD, delete pod, verify contents, and repeat in rapid succession [Slow] [Volume]", func() {
framework.SkipUnlessProviderIs("gce", "gke", "aws") framework.SkipUnlessProviderIs("gce", "gke", "aws")
By("creating PD") By("creating PD")
...@@ -363,7 +363,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() { ...@@ -363,7 +363,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() {
waitForPDDetach(diskName, host0Name) waitForPDDetach(diskName, host0Name)
}) })
It("should schedule a pod w/two RW PDs both mounted to one container, write to PD, verify contents, delete pod, recreate pod, verify contents, and repeat in rapid succession [Slow]", func() { It("should schedule a pod w/two RW PDs both mounted to one container, write to PD, verify contents, delete pod, recreate pod, verify contents, and repeat in rapid succession [Slow] [Volume]", func() {
framework.SkipUnlessProviderIs("gce", "gke", "aws") framework.SkipUnlessProviderIs("gce", "gke", "aws")
By("creating PD1") By("creating PD1")
...@@ -423,7 +423,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() { ...@@ -423,7 +423,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() {
waitForPDDetach(disk2Name, host0Name) waitForPDDetach(disk2Name, host0Name)
}) })
It("should be able to detach from a node which was deleted [Slow] [Disruptive]", func() { It("should be able to detach from a node which was deleted [Slow] [Disruptive] [Volume]", func() {
framework.SkipUnlessProviderIs("gce") framework.SkipUnlessProviderIs("gce")
initialGroupSize, err := GroupSize(framework.TestContext.CloudConfig.NodeInstanceGroup) initialGroupSize, err := GroupSize(framework.TestContext.CloudConfig.NodeInstanceGroup)
...@@ -478,7 +478,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() { ...@@ -478,7 +478,7 @@ var _ = framework.KubeDescribe("Pod Disks", func() {
return return
}) })
It("should be able to detach from a node whose api object was deleted [Slow] [Disruptive]", func() { It("should be able to detach from a node whose api object was deleted [Slow] [Disruptive] [Volume]", func() {
framework.SkipUnlessProviderIs("gce") framework.SkipUnlessProviderIs("gce")
initialGroupSize, err := GroupSize(framework.TestContext.CloudConfig.NodeInstanceGroup) initialGroupSize, err := GroupSize(framework.TestContext.CloudConfig.NodeInstanceGroup)
framework.ExpectNoError(err, "Error getting group size") framework.ExpectNoError(err, "Error getting group size")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment