github
/
k3s
mirror of https://github.com/k3s-io/k3s
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Revert "Modify load test to not create too may services/endpoints"

pull/6/head
Wojciech Tyczynski 2017-02-16 11:30:22 +01:00 committed by GitHub
parent 8c1313913f
commit e5277864e8
1 changed files with 3 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
test/e2e/load.go
View File

@ -168,11 +168,7 @@ var _ = framework.KubeDescribe("Load capacity", func() {
configs, secretConfigs = generateConfigs(totalPods, itArg.image, itArg.command, namespaces, itArg.kind, itArg.secretsPerPod) configs, secretConfigs = generateConfigs(totalPods, itArg.image, itArg.command, namespaces, itArg.kind, itArg.secretsPerPod)
if itArg.services { if itArg.services {
framework.Logf("Creating services") framework.Logf("Creating services")
// If <totalPods> is large, we generate services only for every second services := generateServicesForConfigs(configs)
// config. Since those are sorted by the size, we will have both small,
// medium and large services, but only for half of pods.
onlyHalfServices := totalPods > 60000
services := generateServicesForConfigs(configs, onlyHalfServices)
for _, service := range services { for _, service := range services {
_, err := clientset.Core().Services(service.Namespace).Create(service) _, err := clientset.Core().Services(service.Namespace).Create(service)
framework.ExpectNoError(err) framework.ExpectNoError(err)
@ -422,12 +418,9 @@ func generateConfigsForGroup(
return configs, secretConfigs return configs, secretConfigs
} }
func generateServicesForConfigs(configs []testutils.RunObjectConfig, onlyHalfServices bool) []*v1.Service { func generateServicesForConfigs(configs []testutils.RunObjectConfig) []*v1.Service {
services := make([]*v1.Service, 0, len(configs)) services := make([]*v1.Service, 0, len(configs))
for i, config := range configs { for _, config := range configs {
if onlyHalfServices && i%2 == 1 {
continue
}
serviceName := config.GetName() + "-svc" serviceName := config.GetName() + "-svc"
labels := map[string]string{"name": config.GetName()} labels := map[string]string{"name": config.GetName()}
service := &v1.Service{ service := &v1.Service{