github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-02 09:47:06 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #32063 from gmarek/load

Browse Source 
Automatic merge from submit-queue

Add few more logs to the Load test

Useful to debug enormous-cluster failures.
This commit is contained in:
Kubernetes Submit Queue
2016-09-05 02:22:56 -07:00
committed by GitHub
parent a95dea4147 41e8f10d78
commit 2352464853
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
test/e2e/load.go
View File

@@ -149,6 +149,7 @@ var _ = framework.KubeDescribe("Load capacity", func() {
_, err := c.Services(service.Namespace).Create(service) _, err := c.Services(service.Namespace).Create(service)
framework.ExpectNoError(err) framework.ExpectNoError(err)
} }
framework.Logf("%v Services created.", len(services))
} else { } else {
framework.Logf("Skipping service creation") framework.Logf("Skipping service creation")
} }
@@ -168,6 +169,7 @@ var _ = framework.KubeDescribe("Load capacity", func() {
// to make it possible to create/schedule them in the meantime. // to make it possible to create/schedule them in the meantime.
// Currently we assume <throughput> pods/second average throughput. // Currently we assume <throughput> pods/second average throughput.
// We may want to revisit it in the future. // We may want to revisit it in the future.
framework.Logf("Starting to create ReplicationControllers...")
creatingTime := time.Duration(totalPods/throughput) * time.Second creatingTime := time.Duration(totalPods/throughput) * time.Second
createAllRC(configs, creatingTime) createAllRC(configs, creatingTime)
By("============================================================================") By("============================================================================")
@@ -177,9 +179,11 @@ var _ = framework.KubeDescribe("Load capacity", func() {
// Currently we assume that <throughput> pods/second average throughput. // Currently we assume that <throughput> pods/second average throughput.
// The expected number of created/deleted pods is less than totalPods/3. // The expected number of created/deleted pods is less than totalPods/3.
scalingTime := time.Duration(totalPods/(3*throughput)) * time.Second scalingTime := time.Duration(totalPods/(3*throughput)) * time.Second
framework.Logf("Starting to scale ReplicationControllers first time...")
scaleAllRC(configs, scalingTime) scaleAllRC(configs, scalingTime)
By("============================================================================") By("============================================================================")
framework.Logf("Starting to scale ReplicationControllers second time...")
scaleAllRC(configs, scalingTime) scaleAllRC(configs, scalingTime)
By("============================================================================") By("============================================================================")
@@ -187,13 +191,15 @@ var _ = framework.KubeDescribe("Load capacity", func() {
// Currently we assume <throughput> pods/second average deletion throughput. // Currently we assume <throughput> pods/second average deletion throughput.
// We may want to revisit it in the future. // We may want to revisit it in the future.
deletingTime := time.Duration(totalPods/throughput) * time.Second deletingTime := time.Duration(totalPods/throughput) * time.Second
framework.Logf("Starting to delete ReplicationControllers...")
deleteAllRC(configs, deletingTime) deleteAllRC(configs, deletingTime)
if createServices == "true" { if createServices == "true" {
framework.Logf("Starting to delete services...")
for _, service := range services { for _, service := range services {
err := c.Services(ns).Delete(service.Name) err := c.Services(ns).Delete(service.Name)
framework.ExpectNoError(err) framework.ExpectNoError(err)
} }
framework.Logf("%v Services created.", len(services)) framework.Logf("Services deleted")
} }
}) })
} }