Start a random slot in the case of cluster benchmarks and commands without key (#89)

filipecosta90 · web-flow · commit c493fe4a4fee · 2023-03-31T18:49:47.000+01:00
diff --git a/cmd/ftsb_redisearch/cmd_processor.go b/cmd/ftsb_redisearch/cmd_processor.go
@@ -7,6 +7,7 @@ import (
 	radix "github.com/mediocregopher/radix/v3"
 	"golang.org/x/time/rate"
 	"log"
+	"math/rand"
 	"strconv"
 	"strings"
 	"sync"
@@ -85,6 +86,8 @@ func connectionProcessor(p *processor, rateLimiter *rate.Limiter, useRateLimiter
 			}
 		}
 		clusterAddrLen = len(clusterSlots)
+		// start at a random slot between 0 and clusterAddrLen
+		slotP = rand.Intn(clusterAddrLen)
 	}
 
 	for row := range p.rows {

Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import (`
`7`	`7`	`radix "github.com/mediocregopher/radix/v3"`
`8`	`8`	`"golang.org/x/time/rate"`
`9`	`9`	`"log"`
	`10`	`+ "math/rand"`
`10`	`11`	`"strconv"`
`11`	`12`	`"strings"`
`12`	`13`	`"sync"`
`@@ -85,6 +86,8 @@ func connectionProcessor(p processor, rateLimiter rate.Limiter, useRateLimiter`
`85`	`86`	`}`
`86`	`87`	`}`
`87`	`88`	`clusterAddrLen = len(clusterSlots)`
	`89`	`+ // start at a random slot between 0 and clusterAddrLen`
	`90`	`+ slotP = rand.Intn(clusterAddrLen)`
`88`	`91`	`}`
`89`	`92`
`90`	`93`	`for row := range p.rows {`