From 41e8f10d78177651576c28d945c69d9d65e6c2b8 Mon Sep 17 00:00:00 2001 From: gmarek Date: Mon, 5 Sep 2016 10:34:30 +0200 Subject: [PATCH] Add few more logs to the Load test --- test/e2e/load.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/test/e2e/load.go b/test/e2e/load.go index 22b1ac3595d..7d68021390e 100644 --- a/test/e2e/load.go +++ b/test/e2e/load.go @@ -149,6 +149,7 @@ var _ = framework.KubeDescribe("Load capacity", func() { _, err := c.Services(service.Namespace).Create(service) framework.ExpectNoError(err) } + framework.Logf("%v Services created.", len(services)) } else { 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. // Currently we assume pods/second average throughput. // We may want to revisit it in the future. + framework.Logf("Starting to create ReplicationControllers...") creatingTime := time.Duration(totalPods/throughput) * time.Second createAllRC(configs, creatingTime) By("============================================================================") @@ -177,9 +179,11 @@ var _ = framework.KubeDescribe("Load capacity", func() { // Currently we assume that pods/second average throughput. // The expected number of created/deleted pods is less than totalPods/3. scalingTime := time.Duration(totalPods/(3*throughput)) * time.Second + framework.Logf("Starting to scale ReplicationControllers first time...") scaleAllRC(configs, scalingTime) By("============================================================================") + framework.Logf("Starting to scale ReplicationControllers second time...") scaleAllRC(configs, scalingTime) By("============================================================================") @@ -187,13 +191,15 @@ var _ = framework.KubeDescribe("Load capacity", func() { // Currently we assume pods/second average deletion throughput. // We may want to revisit it in the future. deletingTime := time.Duration(totalPods/throughput) * time.Second + framework.Logf("Starting to delete ReplicationControllers...") deleteAllRC(configs, deletingTime) if createServices == "true" { + framework.Logf("Starting to delete services...") for _, service := range services { err := c.Services(ns).Delete(service.Name) framework.ExpectNoError(err) } - framework.Logf("%v Services created.", len(services)) + framework.Logf("Services deleted") } }) }