rename batch to count

tair-opensource · Mar 20, 2024 · 55b41f5 · 55b41f5
1 parent f286da4
commit 55b41f5
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/internal/client/redis.go b/internal/client/redis.go
@@ -148,8 +148,8 @@ func (r *Redis) Close() {
 
 /* Commands */
 
-func (r *Redis) Scan(cursor uint64, batch string) (newCursor uint64, keys []string) {
-	r.Send("scan", strconv.FormatUint(cursor, 10), "count", batch)
+func (r *Redis) Scan(cursor uint64, count string) (newCursor uint64, keys []string) {
+	r.Send("scan", strconv.FormatUint(cursor, 10), "count", count)
 	reply, err := r.Receive()
 	if err != nil {
 		log.Panicf(err.Error())

diff --git a/internal/reader/scan_standalone_reader.go b/internal/reader/scan_standalone_reader.go
@@ -26,7 +26,7 @@ type ScanReaderOptions struct {
 	KSN           bool   `mapstructure:"ksn" default:"false"`
 	DBS           []int  `mapstructure:"dbs"`
 	PreferReplica bool   `mapstructure:"prefer_replica" default:"false"`
-	Batch         int    `mapstructure:"batch" default:"2048"`
+	Count         int    `mapstructure:"count" default:"2048"`
 }
 
 type dbKey struct {
@@ -132,10 +132,10 @@ func (r *scanStandaloneReader) scan() {
 		}
 
 		var cursor uint64 = 0
-		batch := strconv.Itoa(r.opts.Batch)
+		count := strconv.Itoa(r.opts.Count)
 		for {
 			var keys []string
-			cursor, keys = c.Scan(cursor, batch)
+			cursor, keys = c.Scan(cursor, count)
 			for _, key := range keys {
 				r.keyQueue.Put(dbKey{dbId, key}) // pass value not pointer
 			}