go-pkg/asynq
1
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-09-16 11:58:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'hibiken:master' into master

Browse Source
This commit is contained in:
mindon
2022-12-29 15:15:42 +08:00
committed by GitHub
parent a247371366 0b8cfad703
commit d121033c37
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
tools/asynq/cmd/root.go
View File

@@ -351,7 +351,7 @@ func initConfig() {
// createRDB creates a RDB instance using flag values and returns it.
func createRDB() *rdb.RDB {
var c redis.UniversalClient
if useRedisCluster {
if viper.GetBool("cluster") {
addrs := strings.Split(viper.GetString("cluster_addrs"), ",")
c = redis.NewClusterClient(&redis.ClusterOptions{
Addrs: addrs,
@@ -375,7 +375,7 @@ func createInspector() *asynq.Inspector {
}
func getRedisConnOpt() asynq.RedisConnOpt {
if useRedisCluster {
if viper.GetBool("cluster") {
addrs := strings.Split(viper.GetString("cluster_addrs"), ",")
return asynq.RedisClusterClientOpt{
Addrs: addrs,