Add SLI Read-Only Test Scenario 10 Nodes with 1000 Pods

contrib/cmd/runkperf/commands/bench/read_only_node10_job1_pod1k.go

@@ -0,0 +1,99 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+package bench
+
+import (
+	"context"
+	"fmt"
+	"sync"
+	"time"
+
+	internaltypes "github.com/Azure/kperf/contrib/internal/types"
+	"github.com/Azure/kperf/contrib/utils"
+
+	"github.com/urfave/cli"
+)
+
+var benchNode10Job1Pod1kCase = cli.Command{
+	Name: "node10_job1_pod1k",
+	Usage: `
+
+The test suite is to setup 10 virtual nodes and deploy one job with 100 pods on
+that nodes. It repeats to create and delete job. The load profile is fixed.
+	`,
+	Flags: append(
+		[]cli.Flag{
+			cli.IntFlag{
+				Name:  "total",
+				Usage: "Total requests per runner (There are 10 runners totally and runner's rate is 1)",
+				Value: 1000,
+			},
+		},
+		commonFlags...,
+	),
+	Action: func(cliCtx *cli.Context) error {
+		_, err := renderBenchmarkReportInterceptor(
+			addAPIServerCoresInfoInterceptor(benchNode10Job1Pod1kCaseRun),
+		)(cliCtx)
+		return err
+	},
+}
+
+func benchNode10Job1Pod1kCaseRun(cliCtx *cli.Context) (*internaltypes.BenchmarkReport, error) {
+	ctx := context.Background()
+	kubeCfgPath := cliCtx.GlobalString("kubeconfig")
+
+	rgCfgFile, rgSpec, rgCfgFileDone, err := newLoadProfileFromEmbed(cliCtx,
+		"loadprofile/read_only_node10_job1_pod1k.yaml")
+	if err != nil {
+		return nil, err
+	}
+	defer func() { _ = rgCfgFileDone() }()
+
+	vcDone, err := deployVirtualNodepool(ctx, cliCtx, "node10job1pod1k",
+		10,
+		cliCtx.Int("cpu"),
+		cliCtx.Int("memory"),
+		cliCtx.Int("max-pods"),
+	)
+	if err != nil {
+		return nil, fmt.Errorf("failed to deploy virtual node: %w", err)
+	}
+	defer func() { _ = vcDone() }()
+
+	var wg sync.WaitGroup
+	wg.Add(1)
+
+	jobInterval := 5 * time.Second
+	jobCtx, jobCancel := context.WithCancel(ctx)
+	go func() {
+		defer wg.Done()
+
+		utils.RepeatJobWithPod(jobCtx, kubeCfgPath, "job1pod1k", "workload/1kpod.job.yaml", jobInterval)
+	}()
+
+	rgResult, derr := utils.DeployRunnerGroup(ctx,
+		cliCtx.GlobalString("kubeconfig"),
+		cliCtx.GlobalString("runner-image"),
+		rgCfgFile,
+		cliCtx.GlobalString("runner-flowcontrol"),
+		cliCtx.GlobalString("rg-affinity"),
+	)
+
+	wg.Wait()
+	jobCancel()
+
+	if derr != nil {
+		return nil, derr
+	}
+
+	return &internaltypes.BenchmarkReport{
+		Description: fmt.Sprintf(`
+		Environment: 10 virtual nodes managed by kwok-controller,
+		Workload: Deploy 1 job with 1,000 pods repeatedly. The parallelism is 100. The interval is %v`, jobInterval),
+		LoadSpec: *rgSpec,
+		Result:   *rgResult,
+		Info:     make(map[string]interface{}),
+	}, nil
+}

contrib/cmd/runkperf/commands/bench/root.go

@@ -60,6 +60,7 @@ var Command = cli.Command{
 		benchNode100DeploymentNPod10KCase,
 		benchCiliumCustomResourceListCase,
 		benchListConfigmapsCase,
+		benchNode10Job1Pod1kCase,
 	},
 }
 

contrib/internal/manifests/loadprofile/read_only_node10_job1_pod1k.yaml

@@ -0,0 +1,30 @@
+count: 10
+
+loadProfile:
+  version: 1
+  description: 10nodes_1000pods
+  spec:
+  rate: 10
+  total: 10000
+  conns: 10
+  client: 10
+  contentType: json
+  disableHTTP2: false
+  maxRetries: 0
+  requests:
+    - staleList:
+        version: v1
+        resource: pods
+      shares: 1000
+    - quorumList:
+        version: v1
+        resource: pods
+      shares: 1000
+    - staleGet:
+        version: v1
+        resource: pods
+      shares: 100
+    - quorumGet:
+        version: v1
+        resource: pods
+      shares: 100

contrib/internal/manifests/workload/1kpod.job.yaml

@@ -0,0 +1,31 @@
+apiVersion: batch/v1
+kind: Job
+metadata:
+  name: batchjobs
+spec:
+  completions: 1000
+  parallelism: 100
+  template:
+    metadata:
+      labels:
+        app: fake-pod
+    spec:
+      restartPolicy: Never
+      affinity:
+        nodeAffinity:
+          requiredDuringSchedulingIgnoredDuringExecution:
+            nodeSelectorTerms:
+            - matchExpressions:
+              - key: type
+                operator: In
+                values:
+                - kperf-virtualnodes
+      # A taints was added to an automatically created Node.
+      # You can remove taints of Node or add this tolerations.
+      tolerations:
+      - key: "kperf.io/nodepool"
+        operator: "Exists"
+        effect: "NoSchedule"
+      containers:
+      - name: fake-container
+        image: fake-image