From b35b559d400c9a6ab92c3df9a8864a2ff0e187db Mon Sep 17 00:00:00 2001 From: camcui Date: Fri, 12 Apr 2024 13:54:08 +0800 Subject: [PATCH] chore: fix function names in comment Signed-off-by: camcui --- internal/rdb/rdb.go | 2 +- tools/asynq/cmd/root.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/rdb/rdb.go b/internal/rdb/rdb.go index 7bb10c8f5..68de3864c 100644 --- a/internal/rdb/rdb.go +++ b/internal/rdb/rdb.go @@ -1217,7 +1217,7 @@ redis.call("ZREMRANGEBYSCORE", KEYS[1], "-inf", ARGV[1]) return redis.status_reply("OK") `) -// ReclaimStateAggregationSets checks for any stale aggregation sets in the given queue, and +// ReclaimStaleAggregationSets checks for any stale aggregation sets in the given queue, and // reclaim tasks in the stale aggregation set by putting them back in the group. func (r *RDB) ReclaimStaleAggregationSets(qname string) error { var op errors.Op = "RDB.ReclaimStaleAggregationSets" diff --git a/tools/asynq/cmd/root.go b/tools/asynq/cmd/root.go index 02037b804..c314de7e8 100644 --- a/tools/asynq/cmd/root.go +++ b/tools/asynq/cmd/root.go @@ -369,7 +369,7 @@ func createRDB() *rdb.RDB { return rdb.NewRDB(c) } -// createRDB creates a Inspector instance using flag values and returns it. +// createInspector creates a Inspector instance using flag values and returns it. func createInspector() *asynq.Inspector { return asynq.NewInspector(getRedisConnOpt()) }