diff --git a/test/e2e/load.go b/test/e2e/load.go index 5d55320ce24..1a15d261756 100644 --- a/test/e2e/load.go +++ b/test/e2e/load.go @@ -26,6 +26,7 @@ import ( "github.com/GoogleCloudPlatform/kubernetes/pkg/client" "github.com/GoogleCloudPlatform/kubernetes/pkg/fields" "github.com/GoogleCloudPlatform/kubernetes/pkg/labels" + "github.com/GoogleCloudPlatform/kubernetes/pkg/util" . "github.com/onsi/ginkgo" . "github.com/onsi/gomega" @@ -67,6 +68,14 @@ var _ = Describe("Load", func() { if err := c.Namespaces().Delete(ns); err != nil { Failf("Couldn't delete ns %s", err) } + + // Verify latency metrics + // TODO: Update threshold to 1s once we reach this goal + // TODO: We should reset metrics before the test. Currently previous tests influence latency metrics. + _, err := HighLatencyRequests(c, 5*time.Second, util.NewStringSet("events")) + expectNoError(err) + // TODO: uncomment the following line once the test is stable + // Expect(highLatencyRequests).NotTo(BeNumerically(">", 0)) }) type Load struct { @@ -78,7 +87,7 @@ var _ = Describe("Load", func() { } for _, testArg := range loadTests { - name := fmt.Sprintf("[Skipped] should be able to handle %v pods per node", testArg.podsPerNode) + name := fmt.Sprintf("[Performance suite] [Skipped] should be able to handle %v pods per node", testArg.podsPerNode) It(name, func() { totalPods := testArg.podsPerNode * nodeCount diff --git a/test/e2e/util.go b/test/e2e/util.go index 5250f59d57f..8e9139cb175 100644 --- a/test/e2e/util.go +++ b/test/e2e/util.go @@ -743,7 +743,7 @@ func RunRC(c *client.Client, name string, ns, image string, replicas int) error By(fmt.Sprintf("%v Waiting for all %d replicas to be running with a max container failures of %d", time.Now(), replicas, maxContainerFailures)) same = 0 last = 0 - failCount = 10 + failCount = 20 current = 0 oldPods := &api.PodList{} for same < failCount && current < replicas {