From d7525b88f637831360538ef6671dc259cff5034f Mon Sep 17 00:00:00 2001 From: Aleksey Myasnikov Date: Wed, 2 Oct 2024 19:40:31 +0300 Subject: [PATCH] added log messages about read and write RPS --- tests/slo/native/query/main.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/tests/slo/native/query/main.go b/tests/slo/native/query/main.go index 052106153..a631a4079 100644 --- a/tests/slo/native/query/main.go +++ b/tests/slo/native/query/main.go @@ -4,6 +4,7 @@ import ( "context" "fmt" "os/signal" + "strconv" "sync" "syscall" "time" @@ -127,12 +128,14 @@ func main() { for i := 0; i < cfg.ReadRPS; i++ { go w.Read(ctx, &wg, readRL) } + log.Println("started " + strconv.Itoa(cfg.ReadRPS) + " read workers") writeRL := rate.NewLimiter(rate.Limit(cfg.WriteRPS), 1) wg.Add(cfg.WriteRPS) for i := 0; i < cfg.WriteRPS; i++ { go w.Write(ctx, &wg, writeRL, gen) } + log.Println("started " + strconv.Itoa(cfg.ReadRPS) + " write workers") metricsRL := rate.NewLimiter(rate.Every(time.Duration(cfg.ReportPeriod)*time.Millisecond), 1) wg.Add(1)