fix lint

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

fix lint

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

Author: Yisaer

testcase/stale-read/bench.go

@@ -21,11 +21,13 @@ pad char(255) not null default '')`
 
 const splitTableTemplate = `SPLIT TABLE sbtest%d BETWEEN (0) AND (1000000000) REGIONS 100;`
 
+// SysbenchCase indicates a sysbench case
 type SysbenchCase struct {
 	insertCount    int
 	rowsEachInsert int
 }
 
+// CreateTable ...
 func (c *SysbenchCase) CreateTable(db *sql.DB) error {
 	if err := c.DropTable(db); err != nil {
 		log.Error("fail to drop table", zap.Error(err))
@@ -42,6 +44,7 @@ func (c *SysbenchCase) CreateTable(db *sql.DB) error {
 	return nil
 }
 
+// InsertData ...
 func (c *SysbenchCase) InsertData(worker *sysbench.Worker, db *sql.DB) error {
 	var buf bytes.Buffer
 	pkID := worker.ID
@@ -67,6 +70,7 @@ func (c *SysbenchCase) InsertData(worker *sysbench.Worker, db *sql.DB) error {
 	return nil
 }
 
+// Execute ...
 // TODO: fulfill workload in future
 func (c *SysbenchCase) Execute(worker *sysbench.Worker, db *sql.DB) error {
 	log.Info("worker start execute")
@@ -142,6 +146,7 @@ func (c *SysbenchCase) executeSelect(db *sql.DB) error {
 	return nil
 }
 
+// DropTable ...
 func (c *SysbenchCase) DropTable(db *sql.DB) error {
 	_, err := db.Exec("drop table if exists sbtest0")
 	return err

testcase/stale-read/cmd/main.go

@@ -5,6 +5,9 @@ import (
 	"flag"
 	"time"
 
+	// use mysql
+	_ "github.com/go-sql-driver/mysql"
+
 	"github.com/pingcap/tipocket/cmd/util"
 	logs "github.com/pingcap/tipocket/logsearch/pkg/logs"
 	"github.com/pingcap/tipocket/pkg/cluster"

testcase/stale-read/stale-read.go

@@ -15,13 +15,15 @@ import (
 	"go.uber.org/zap"
 )
 
+// Config ...
 type Config struct {
 	SysBenchWorkerCount int
 	SysBenchDuration    time.Duration
 	RowsEachInsert      int
 	InsertCount         int
 }
 
+// ClientCreator ...
 type ClientCreator struct {
 	Config
 }
@@ -87,7 +89,7 @@ func (c *staleReadClient) SetUp(ctx context.Context, _ []cluster.Node, cnodes []
 	return nil
 }
 
-// SetUp...
+// Start ...
 func (c *staleReadClient) Start(ctx context.Context, cfg interface{}, cnodes []cluster.ClientNode) error {
 	log.Info("Run sysbench test")
 	sysbench.RunTest(c.sysBenchConf)
@@ -134,6 +136,7 @@ func buildPrometheusSvcName(name, namespace string) string {
 	return fmt.Sprintf("%s-prometheus.%s.svc:9090", name, namespace)
 }
 
+// StoreMetricsValue indicates the metrics value for a store from prometheus
 type StoreMetricsValue struct {
 	Timestamp int64
 	Value     float64