From c08f142b5666b5983db9bd84764b7917b953d3a2 Mon Sep 17 00:00:00 2001 From: Zhidong Chen Date: Fri, 9 Sep 2022 10:27:02 +0800 Subject: [PATCH] fix redis sentinel url parse --- asynq.go | 2 +- asynq_test.go | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/asynq.go b/asynq.go index da4160d..86ddb9d 100644 --- a/asynq.go +++ b/asynq.go @@ -519,7 +519,7 @@ func parseRedisSentinelURI(u *url.URL) (RedisConnOpt, error) { if v, ok := u.User.Password(); ok { password = v } - return RedisFailoverClientOpt{MasterName: master, SentinelAddrs: addrs, Password: password}, nil + return RedisFailoverClientOpt{MasterName: master, SentinelAddrs: addrs, SentinelPassword: password}, nil } // ResultWriter is a client interface to write result data for a task. diff --git a/asynq_test.go b/asynq_test.go index ad6bc7f..1147682 100644 --- a/asynq_test.go +++ b/asynq_test.go @@ -143,9 +143,9 @@ func TestParseRedisURI(t *testing.T) { { "redis-sentinel://:mypassword@localhost:5000,localhost:5001,localhost:5002?master=mymaster", RedisFailoverClientOpt{ - MasterName: "mymaster", - SentinelAddrs: []string{"localhost:5000", "localhost:5001", "localhost:5002"}, - Password: "mypassword", + MasterName: "mymaster", + SentinelAddrs: []string{"localhost:5000", "localhost:5001", "localhost:5002"}, + SentinelPassword: "mypassword", }, }, }