github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-01-05 23:47:50 +00:00
Code Issues Projects Releases Wiki Activity

Add multiple init pods to perf test cases

Browse Source 
Add test case with several init pods with affinity or antiaffinity.

Signed-off-by: Aldo Culquicondor <acondor@google.com>
This commit is contained in:
Aldo Culquicondor
2020-03-23 14:55:12 -04:00
parent 0e66e56e70
commit 5adc4c41e3
6 changed files with 113 additions and 86 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
test/integration/scheduler_perf/scheduler_perf_test.go
View File

@@ -65,7 +65,7 @@ type testCase struct {
// configures nodes in the cluster
Nodes nodeCase
// configures pods in the cluster before running the tests
InitPods podCase
InitPods []podCase
// pods to be scheduled during the test.
PodsToSchedule podCase
// optional, feature gates to set before running the test
@@ -100,7 +100,7 @@ type simpleTestCases struct {
type testParams struct {
NumNodes int
NumInitPods int
NumInitPods []int
NumPodsToSchedule int
}
@@ -117,7 +117,11 @@ func BenchmarkPerfScheduling(b *testing.B) {
}
for _, test := range tests {
name := fmt.Sprintf("%v/%vNodes/%vInitPods/%vPodsToSchedule", test.Desc, test.Nodes.Num, test.InitPods.Num, test.PodsToSchedule.Num)
initPods := 0
for _, p := range test.InitPods {
initPods += p.Num
}
name := fmt.Sprintf("%v/%vNodes/%vInitPods/%vPodsToSchedule", test.Desc, test.Nodes.Num, initPods, test.PodsToSchedule.Num)
b.Run(name, func(b *testing.B) {
for feature, flag := range test.FeatureGates {
defer featuregatetesting.SetFeatureGateDuringTest(b, utilfeature.DefaultFeatureGate, feature, flag)()
@@ -143,10 +147,14 @@ func perfScheduling(test testCase, b *testing.B) []DataItem {
}
defer nodePreparer.CleanupNodes()
if err := createPods(setupNamespace, test.InitPods, clientset); err != nil {
b.Fatal(err)
total := 0
for _, p := range test.InitPods {
if err := createPods(setupNamespace, p, clientset); err != nil {
b.Fatal(err)
}
total += p.Num
}
if err := waitNumPodsScheduled(b, test.InitPods.Num, podInformer); err != nil {
if err := waitNumPodsScheduled(b, total, podInformer); err != nil {
b.Fatal(err)
}
@@ -164,7 +172,7 @@ func perfScheduling(test testCase, b *testing.B) []DataItem {
if err := createPods(testNamespace, test.PodsToSchedule, clientset); err != nil {
b.Fatal(err)
}
if err := waitNumPodsScheduled(b, test.InitPods.Num+test.PodsToSchedule.Num, podInformer); err != nil {
if err := waitNumPodsScheduled(b, total+test.PodsToSchedule.Num, podInformer); err != nil {
b.Fatal(err)
}
@@ -278,7 +286,10 @@ func parseTestCases(path string) ([]testCase, error) {
testCase := s.Template
for _, p := range s.Params {
testCase.Nodes.Num = p.NumNodes
testCase.InitPods.Num = p.NumInitPods
testCase.InitPods = append([]podCase(nil), testCase.InitPods...)
for i, v := range p.NumInitPods {
testCase.InitPods[i].Num = v
}
testCase.PodsToSchedule.Num = p.NumPodsToSchedule
testCases = append(testCases, testCase)
}