makes the writer payload smaller

Author: bseto

cmd/reader/main.go

@@ -195,12 +195,12 @@ func hGetAll(
 	timeoutCtx, cancel := context.WithTimeout(ctx, timeout)
 	defer cancel()
 	start := time.Now()
-	hGetAllSeconds := metrics.GetOrCreateHistogram(fmt.Sprintf(`kvrocks_command_seconds{command="hgetall",client="%s"}`, client.Name()))
+	hGetAllSeconds := metrics.GetOrCreateHistogram(fmt.Sprintf(`kvrocks_command_seconds{command="hgetall",conn_client="%s"}`, client.Name()))
 	defer hGetAllSeconds.UpdateDuration(start)
 
 	data, err := client.HGetAll(timeoutCtx, key)
 	if err != nil {
-		metrics.GetOrCreateCounter(fmt.Sprintf(`kvrocks_command_errors_total{command="hgetall",client="%s"}`, client.Name())).Inc()
+		metrics.GetOrCreateCounter(fmt.Sprintf(`kvrocks_command_errors_total{command="hgetall",conn_client="%s"}`, client.Name())).Inc()
 		return nil, err
 	}
 

cmd/reader/reader

@@ -67,11 +67,11 @@ func main() {
 	}
 
 	logger.Get().Info("creating payload")
-	payload := []byte("11123123456789123456712312345678912123123456789123456712312345678912345671231234567891234567123123456789123456734567123123456789123456712312345678912345672312345678912345671231234567891212312345678912345671231234567891234567123123456789123456712312345678912345673456712312345678912345671231234567891234567123123456789123456712312345678912123123456789123456712312345678912345671231234567891234567123123456789123456734567123123456789123456712312345678912345672312345678912345671231234567891212312345678912345671231234567891234567123123456789123456712312345678912345673456712312345678912345671231234567891234567")
+	payload := []byte("123452312345678912345671223456712312345678912345673456712312345678912345671231234567891234567")
 	payloadSize := len(payload)
 	data := make(map[string][]byte)
 	cols := []string{}
-	for i := 0; i < 8; i++ {
+	for i := 0; i < 12; i++ {
 		data[fmt.Sprintf("%d", i)] = payload
 		cols = append(cols, fmt.Sprintf("%d", i))
 	}