add staleread casew

Signed-off-by: yisaer <disxiaofei@163.com>

Author: Yisaer

pkg/test-infra/tidb/recommend.go

@@ -162,6 +162,9 @@ func RecommendedTiDBCluster(ns, name string, clusterConfig fixture.TiDBClusterCo
 							MountPath:   "/var/log/pdlog",
 						},
 					},
+					Service: &v1alpha1.ServiceSpec{
+						Type: corev1.ServiceTypeNodePort,
+					},
 				},
 				TiKV: &v1alpha1.TiKVSpec{
 					Replicas: int32(clusterConfig.TiKVReplicas),
@@ -260,6 +263,9 @@ func RecommendedTiDBCluster(ns, name string, clusterConfig fixture.TiDBClusterCo
 						Version:   "v2.11.1",
 					},
 					LogLevel: "info",
+					Service: v1alpha1.ServiceSpec{
+						Type: corev1.ServiceTypeNodePort,
+					},
 				},
 				Grafana: &v1alpha1.GrafanaSpec{
 					Service: v1alpha1.ServiceSpec{

run/lib/case.libsonnet

@@ -58,6 +58,10 @@
       '/bin/cross-region',
        '-tso-request-count=%s' % args.tso_request_count,
     ],
+  staleread(args={})::
+    [
+      '/bin/stale-read',
+    ],
   'example'(args={})::
     [
       '/bin/example',

run/workflow/stale-read.jsonnet

@@ -0,0 +1,15 @@
+{
+  _config+:: {
+    case_name: 'staleread',
+    image_name: 'hub.pingcap.net/qa/tipocket',
+    args+: {
+      // k8s configurations
+      // 'storage-class': 'local-storage',
+      // tidbcluster configurations
+      // 'pd-storage-class': 'shared-local-storage',
+      // 'tikv-storage-class': 'local-storage',
+      // 'log-storage-class': 'shared-sas',
+    },
+    command: {},
+  },
+}

testcase/stale-read/cmd/main.go

@@ -3,23 +3,27 @@ package main
 import (
 	"context"
 	"flag"
-	staleread "github.com/pingcap/tipocket/testcase/stale-read"
-
-	// use mysql
-	_ "github.com/go-sql-driver/mysql"
+	"time"
 
 	"github.com/pingcap/tipocket/cmd/util"
 	logs "github.com/pingcap/tipocket/logsearch/pkg/logs"
 	"github.com/pingcap/tipocket/pkg/cluster"
 	"github.com/pingcap/tipocket/pkg/control"
 	test_infra "github.com/pingcap/tipocket/pkg/test-infra"
 	"github.com/pingcap/tipocket/pkg/test-infra/fixture"
+	staleread "github.com/pingcap/tipocket/testcase/stale-read"
+)
+
+var (
+	workerCount    = flag.Int("sysbench-worker-count", 1, "the worker count of the sysbench")
+	runDuration    = flag.Duration("sysbench-duration", 1*time.Minute, "the duration of the sysbench running")
+	rowsEachInsert = flag.Int("rows-each-insert", 50, "rows each time insert")
+	insertCount    = flag.Int("insert-count", 20, "count of the inserting")
 )
 
 func main() {
 	flag.Parse()
 	fixture.Context.ClusterName = "stale-read"
-	fixture.Context.Namespace = "gaosong"
 	cfg := control.Config{
 		Mode:        control.ModeStandard,
 		ClientCount: 1,
@@ -36,12 +40,19 @@ func main() {
 	c.TiDBClusterConfig.TiDBImage = "hub.pingcap.net/gaosong/tidb:newly-master"
 	c.TiDBClusterConfig.TiKVImage = "hub.pingcap.net/gaosong/tikv:newly-master"
 	suit := util.Suit{
-		Config:        &cfg,
-		Provider:      cluster.NewDefaultClusterProvider(),
-		ClientCreator: staleread.ClientCreator{},
-		NemesisGens:   util.ParseNemesisGenerators(fixture.Context.Nemesis),
-		ClusterDefs:   test_infra.NewDefaultCluster(c.Namespace, c.ClusterName, c.TiDBClusterConfig),
-		LogsClient:    logs.NewDiagnosticLogClient(),
+		Config:   &cfg,
+		Provider: cluster.NewDefaultClusterProvider(),
+		ClientCreator: staleread.ClientCreator{
+			Config: staleread.Config{
+				SysBenchWorkerCount: *workerCount,
+				SysBenchDuration:    *runDuration,
+				RowsEachInsert:      *rowsEachInsert,
+				InsertCount:         *insertCount,
+			},
+		},
+		NemesisGens: util.ParseNemesisGenerators(fixture.Context.Nemesis),
+		ClusterDefs: test_infra.NewDefaultCluster(c.Namespace, c.ClusterName, c.TiDBClusterConfig),
+		LogsClient:  logs.NewDiagnosticLogClient(),
 	}
 	suit.Run(context.Background())
 }

testcase/stale-read/stale-read.go

@@ -116,6 +116,8 @@ func (c *staleReadClient) Start(ctx context.Context, cfg interface{}, cnodes []c
 	default:
 		log.Warn("mode value transform error")
 	}
+	// assert metrics here
+	handleStoreMetricsValue(smvms, c.duration)
 	return nil
 }