github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-31 23:37:01 +00:00
Code Issues Projects Releases Wiki Activity

Reduce service creation/deletion parallelism in the load test

Browse Source
This commit is contained in:
gmarek 2017-05-25 11:37:02 +02:00
parent 4def5add11
commit ded8e03fc3
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
test/e2e/framework/kubelet_stats.go
View File

@ -39,7 +39,6 @@ import (
"k8s.io/kubernetes/pkg/master/ports" "k8s.io/kubernetes/pkg/master/ports"
"k8s.io/kubernetes/pkg/metrics" "k8s.io/kubernetes/pkg/metrics"
"github.com/golang/glog"
"github.com/prometheus/common/model" "github.com/prometheus/common/model"
) )

6
test/e2e/perf/load.go
View File

@ -59,6 +59,8 @@ const (
// nodeCountPerNamespace determines how many namespaces we will be using // nodeCountPerNamespace determines how many namespaces we will be using
// depending on the number of nodes in the underlying cluster. // depending on the number of nodes in the underlying cluster.
nodeCountPerNamespace = 100 nodeCountPerNamespace = 100
// How many threads will be used to create/delete services during this test.
serviceOperationsParallelism = 5
) )
var randomKind = schema.GroupKind{Kind: "Random"} var randomKind = schema.GroupKind{Kind: "Random"}
@ -190,7 +192,7 @@ var _ = framework.KubeDescribe("Load capacity", func() {
_, err := clientset.Core().Services(services[i].Namespace).Create(services[i]) _, err := clientset.Core().Services(services[i].Namespace).Create(services[i])
framework.ExpectNoError(err) framework.ExpectNoError(err)
} }
workqueue.Parallelize(25, len(services), createService) workqueue.Parallelize(serviceOperationsParallelism, len(services), createService)
framework.Logf("%v Services created.", len(services)) framework.Logf("%v Services created.", len(services))
defer func(services []*v1.Service) { defer func(services []*v1.Service) {
framework.Logf("Starting to delete services...") framework.Logf("Starting to delete services...")
@ -198,7 +200,7 @@ var _ = framework.KubeDescribe("Load capacity", func() {
err := clientset.Core().Services(services[i].Namespace).Delete(services[i].Name, nil) err := clientset.Core().Services(services[i].Namespace).Delete(services[i].Name, nil)
framework.ExpectNoError(err) framework.ExpectNoError(err)
} }
workqueue.Parallelize(25, len(services), deleteService) workqueue.Parallelize(serviceOperationsParallelism, len(services), deleteService)
framework.Logf("Services deleted") framework.Logf("Services deleted")
}(services) }(services)
} else { } else {