We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6fb3f52 commit d7525b8Copy full SHA for d7525b8
tests/slo/native/query/main.go
@@ -4,6 +4,7 @@ import (
4
"context"
5
"fmt"
6
"os/signal"
7
+ "strconv"
8
"sync"
9
"syscall"
10
"time"
@@ -127,12 +128,14 @@ func main() {
127
128
for i := 0; i < cfg.ReadRPS; i++ {
129
go w.Read(ctx, &wg, readRL)
130
}
131
+ log.Println("started " + strconv.Itoa(cfg.ReadRPS) + " read workers")
132
133
writeRL := rate.NewLimiter(rate.Limit(cfg.WriteRPS), 1)
134
wg.Add(cfg.WriteRPS)
135
for i := 0; i < cfg.WriteRPS; i++ {
136
go w.Write(ctx, &wg, writeRL, gen)
137
138
+ log.Println("started " + strconv.Itoa(cfg.ReadRPS) + " write workers")
139
140
metricsRL := rate.NewLimiter(rate.Every(time.Duration(cfg.ReportPeriod)*time.Millisecond), 1)
141
wg.Add(1)
0 commit comments