diff --git a/test/e2e/soak_namespace.go b/test/e2e/soak_namespace.go deleted file mode 100644 index 5217e4c5730..00000000000 --- a/test/e2e/soak_namespace.go +++ /dev/null @@ -1,107 +0,0 @@ -/* -Copyright 2014 The Kubernetes Authors All rights reserved. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package e2e - -import ( - "fmt" - "github.com/GoogleCloudPlatform/kubernetes/pkg/api" - "github.com/GoogleCloudPlatform/kubernetes/pkg/client" - "github.com/GoogleCloudPlatform/kubernetes/pkg/fields" - "github.com/GoogleCloudPlatform/kubernetes/pkg/labels" - //"github.com/GoogleCloudPlatform/kubernetes/pkg/util" - "strings" - "time" - - . "github.com/onsi/ginkgo" - . "github.com/onsi/gomega" -) - -var _ = Describe("ns-soak", func() { - - //This namespace is modified throughout the course of the test. - var namespace *api.Namespace - var c *client.Client - var err error = nil - BeforeEach(func() { - By("Creating a kubernetes client") - c, err = loadClient() - Expect(err).NotTo(HaveOccurred()) - }) - - AfterEach(func() { - }) - - // First test because it has no dependencies on variables created later on. - totalNS := 100 - It("Namespaces should be deleted within 100 seconds", func() { - for n := 0; n < totalNS; n += 1 { - namespace, err = createTestingNS(fmt.Sprintf("nslifetest-%v", n), c) - } - - //100 seconds after the ns are created, they should all be gone ! - deletionCompleted := time.After(time.Duration(150) * time.Second) - deletionStart := time.After(time.Duration(10 * time.Second)) - tick := time.Tick(2 * time.Second) - T: - for { - select { - case <-deletionCompleted: - Logf("Timeout %v reached. Breaking!", deletionCompleted) - break T - case <-deletionStart: - print("STARTING DELETION") - nsList, err := c.Namespaces().List(labels.Everything(), fields.Everything()) - Expect(err).NotTo(HaveOccurred()) - for _, item := range nsList.Items { - if strings.Contains(item.Name, "nslifetest") { - print(item.Name) - if err := c.Namespaces().Delete(item.Name); err != nil { - Failf("Failed deleting error ::: --- %v ", err) - } - } - Logf("namespace : %v api call to delete is complete ", item) - } - - case <-tick: - nsList, err := c.Namespaces().List(labels.Everything(), fields.Everything()) - Expect(err).NotTo(HaveOccurred()) - var cnt = 0 - for _, item := range nsList.Items { - if strings.Contains(item.Name, "nslifetest") { - cnt++ - } - } - Logf("currently remaining NS == %v", cnt) - //if all the ns's are gone, we break early - if cnt == 0 { - break T - } - } - } - - nsList, err := c.Namespaces().List(labels.Everything(), fields.Everything()) - Expect(err).NotTo(HaveOccurred()) - for _, item := range nsList.Items { - if strings.Contains(item.Name, "nslifetest") { - Failf("FAILED. There is still a remaining ns %v", item.Name) - } - Logf("namespace : %v", item) - } - - }) - -})