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

Merge pull request #10823 from piosz/real_test

Browse Source 
Added load test with pods doing real works
This commit is contained in:
Wojciech Tyczynski 2015-07-09 11:26:47 +02:00
commit 977b1d9579
3 changed files with 24 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hack/jenkins/e2e.sh
View File

@ -164,7 +164,7 @@ case ${JOB_NAME} in
kubernetes-e2e-gce-scalability)
: ${E2E_CLUSTER_NAME:="jenkins-gce-e2e-scalability"}
: ${E2E_NETWORK:="e2e-scalability"}
: ${GINKGO_TEST_ARGS:="--ginkgo.focus=Performance\ssuite|should\sbe\sable\sto\shandle"}
: ${GINKGO_TEST_ARGS:="--ginkgo.focus=Performance\ssuite"}
: ${KUBE_GCE_INSTANCE_PREFIX:="e2e-scalability"}
: ${PROJECT:="kubernetes-jenkins"}
# Override GCE defaults.

29
test/e2e/load.go
View File

@ -33,7 +33,6 @@ import (
)
const (
image = "gcr.io/google_containers/serve_hostname:1.1"
smallRCSize = 5
mediumRCSize = 30
bigRCSize = 250
@ -94,17 +93,22 @@ var _ = Describe("Load capacity", func() {
type Load struct {
podsPerNode int
image string
command []string
}
loadTests := []Load{
{podsPerNode: 30},
// The container will consume 1 cpu and 512mb of memory.
{podsPerNode: 3, image: "jess/stress", command: []string{"stress", "-c", "1", "-m", "2"}},
{podsPerNode: 30, image: "gcr.io/google_containers/serve_hostname:1.1"},
}
for _, testArg := range loadTests {
name := fmt.Sprintf("[Skipped] should be able to handle %v pods per node", testArg.podsPerNode)
name := fmt.Sprintf("[Skipped] [Performance suite] should be able to handle %v pods per node", testArg.podsPerNode)
itArg := testArg
It(name, func() {
configs = generateRCConfigs(testArg.podsPerNode*nodeCount, c, ns)
configs = generateRCConfigs(itArg.podsPerNode*nodeCount, itArg.image, itArg.command, c, ns)
// Simulate lifetime of RC:
// * create with initial size
@ -134,23 +138,25 @@ func computeRCCounts(total int) (int, int, int) {
// - 25 medium RCs each 30 pods
// - 3 big RCs each 250 pods
bigRCCount := total / 4 / bigRCSize
mediumRCCount := total / 4 / mediumRCSize
smallRCCount := total / 2 / smallRCSize
total -= bigRCCount * bigRCSize
mediumRCCount := total / 3 / mediumRCSize
total -= mediumRCCount * mediumRCSize
smallRCCount := total / smallRCSize
return smallRCCount, mediumRCCount, bigRCCount
}
func generateRCConfigs(totalPods int, c *client.Client, ns string) []*RCConfig {
func generateRCConfigs(totalPods int, image string, command []string, c *client.Client, ns string) []*RCConfig {
configs := make([]*RCConfig, 0)
smallRCCount, mediumRCCount, bigRCCount := computeRCCounts(totalPods)
configs = append(configs, generateRCConfigsForGroup(c, ns, smallRCGroupName, smallRCSize, smallRCCount)...)
configs = append(configs, generateRCConfigsForGroup(c, ns, mediumRCGroupName, mediumRCSize, mediumRCCount)...)
configs = append(configs, generateRCConfigsForGroup(c, ns, bigRCGroupName, bigRCSize, bigRCCount)...)
configs = append(configs, generateRCConfigsForGroup(c, ns, smallRCGroupName, smallRCSize, smallRCCount, image, command)...)
configs = append(configs, generateRCConfigsForGroup(c, ns, mediumRCGroupName, mediumRCSize, mediumRCCount, image, command)...)
configs = append(configs, generateRCConfigsForGroup(c, ns, bigRCGroupName, bigRCSize, bigRCCount, image, command)...)
return configs
}
func generateRCConfigsForGroup(c *client.Client, ns, groupName string, size, count int) []*RCConfig {
func generateRCConfigsForGroup(c *client.Client, ns, groupName string, size, count int, image string, command []string) []*RCConfig {
configs := make([]*RCConfig, 0, count)
for i := 1; i <= count; i++ {
config := &RCConfig{
@ -159,6 +165,7 @@ func generateRCConfigsForGroup(c *client.Client, ns, groupName string, size, cou
Namespace: ns,
Timeout: 10 * time.Minute,
Image: image,
Command: command,
Replicas: size,
}
configs = append(configs, config)

8
test/e2e/util.go
View File

@ -159,6 +159,7 @@ func (s *podStore) Stop() {
type RCConfig struct {
Client *client.Client
Image string
Command []string
Name string
Namespace string
PollInterval time.Duration
@ -1020,9 +1021,10 @@ func RunRC(config RCConfig) error {
Spec: api.PodSpec{
Containers: []api.Container{
{
Name: config.Name,
Image: config.Image,
Ports: []api.ContainerPort{{ContainerPort: 80}},
Name: config.Name,
Image: config.Image,
Command: config.Command,
Ports: []api.ContainerPort{{ContainerPort: 80}},
},
},
},