From eb5d340851354d9de8f1df97f673ab36f6d26519 Mon Sep 17 00:00:00 2001
From: Robert Rati <rrati@redhat.com>
Date: Fri, 30 Jan 2015 16:00:03 -0500
Subject: [PATCH] Added a submit/remove test to pods #3941

---
 test/e2e/pods.go | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)

diff --git a/test/e2e/pods.go b/test/e2e/pods.go
index c7d2b28937b..cc84d22df1e 100644
--- a/test/e2e/pods.go
+++ b/test/e2e/pods.go
@@ -39,6 +39,42 @@ var _ = Describe("Pods", func() {
 		c = loadClientOrDie()
 	})
 
+	It("should be submitted and removed", func() {
+		podClient := c.Pods(api.NamespaceDefault)
+
+		By("loading the pod json")
+		pod := loadPodOrDie(assetPath("api", "examples", "pod.json"))
+		value := strconv.Itoa(time.Now().Nanosecond())
+		pod.Name = pod.Name + "-" + randomSuffix()
+		pod.Labels["time"] = value
+		pod.Spec.Containers[0].Ports[0].HostPort = 0
+
+		By("submitting the pod to kubernetes")
+		_, err := podClient.Create(pod)
+		if err != nil {
+			Fail(fmt.Sprintf("Failed to create pod: %v", err))
+		}
+		defer func() {
+			// We call defer here in case there is a problem with
+			// the test so we can ensure that we clean up after
+			// ourselves
+			defer GinkgoRecover()
+			podClient.Delete(pod.Name)
+		}()
+
+		By("verifying the pod is in kubernetes")
+		pods, err := podClient.List(labels.SelectorFromSet(labels.Set(map[string]string{"time": value})))
+		if err != nil {
+			Fail(fmt.Sprintf("Failed to query for pods: %v", err))
+		}
+		Expect(len(pods.Items)).To(Equal(1))
+
+		By("deleting the pod")
+		podClient.Delete(pod.Name)
+		pods, err = podClient.List(labels.SelectorFromSet(labels.Set(map[string]string{"time": value})))
+		Expect(len(pods.Items)).To(Equal(0))
+	})
+
 	It("should be updated", func() {
 		podClient := c.Pods(api.NamespaceDefault)