github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-28 22:17:14 +00:00
Code Issues Projects Releases Wiki Activity

Re-enabled load e2e test for Jenkins scalability suite

Browse Source 
Also increased next pod startup waiting time from 100s to 200s
to eliminate flakiness by incresing failCount param.
This commit is contained in:
Piotr Szczesniak 2015-05-25 10:38:22 +02:00
parent 5520386b18
commit a2116f2bc1
2 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
test/e2e/load.go
View File

@ -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

2
test/e2e/util.go
View File

@ -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 {