go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-04-20 07:40:19 +08:00
Code Issues Projects Releases Wiki Activity

Merge 0d79ae231ea580156cd9354e4939df8c3c4e4daa into 489e21920b92ae6acfc19c54de91166e56817620

Browse Source
This commit is contained in:
xu0o0 2025-01-01 20:23:22 -08:00 committed by GitHub
commit ee2e55527a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
asynq.go
View File

@ -489,6 +489,7 @@ func parseRedisURI(u *url.URL) (RedisConnOpt, error) {
} }
redisConnOpt.Addr = u.Host redisConnOpt.Addr = u.Host
redisConnOpt.Username = u.User.Username()
redisConnOpt.Password = password redisConnOpt.Password = password
redisConnOpt.DB = db redisConnOpt.DB = db
@ -513,7 +514,7 @@ func parseRedisSocketURI(u *url.URL) (RedisConnOpt, error) {
if v, ok := u.User.Password(); ok { if v, ok := u.User.Password(); ok {
password = v password = v
} }
return RedisClientOpt{Network: "unix", Addr: u.Path, DB: db, Password: password}, nil return RedisClientOpt{Network: "unix", Addr: u.Path, DB: db, Username: u.User.Username(), Password: password}, nil
} }
func parseRedisSentinelURI(u *url.URL) (RedisConnOpt, error) { func parseRedisSentinelURI(u *url.URL) (RedisConnOpt, error) {

28
asynq_test.go
View File

@ -109,22 +109,50 @@ func TestParseRedisURI(t *testing.T) {
"redis://localhost:6379/3", "redis://localhost:6379/3",
RedisClientOpt{Addr: "localhost:6379", DB: 3}, RedisClientOpt{Addr: "localhost:6379", DB: 3},
}, },
{
"redis://:@localhost:6379",
RedisClientOpt{Addr: "localhost:6379"},
},
{
"redis://myusername:@localhost:6379",
RedisClientOpt{Addr: "localhost:6379", Username: "myusername"},
},
{ {
"redis://:mypassword@localhost:6379", "redis://:mypassword@localhost:6379",
RedisClientOpt{Addr: "localhost:6379", Password: "mypassword"}, RedisClientOpt{Addr: "localhost:6379", Password: "mypassword"},
}, },
{
"redis://myusername:mypassword@localhost:6379",
RedisClientOpt{Addr: "localhost:6379", Username: "myusername", Password: "mypassword"},
},
{ {
"redis://:mypassword@127.0.0.1:6379/11", "redis://:mypassword@127.0.0.1:6379/11",
RedisClientOpt{Addr: "127.0.0.1:6379", Password: "mypassword", DB: 11}, RedisClientOpt{Addr: "127.0.0.1:6379", Password: "mypassword", DB: 11},
}, },
{
"redis://myusername:mypassword@localhost:6379/11",
RedisClientOpt{Addr: "localhost:6379", Username: "myusername", Password: "mypassword", DB: 11},
},
{ {
"redis-socket:///var/run/redis/redis.sock", "redis-socket:///var/run/redis/redis.sock",
RedisClientOpt{Network: "unix", Addr: "/var/run/redis/redis.sock"}, RedisClientOpt{Network: "unix", Addr: "/var/run/redis/redis.sock"},
}, },
{
"redis-socket://:@/var/run/redis/redis.sock",
RedisClientOpt{Network: "unix", Addr: "/var/run/redis/redis.sock"},
},
{
"redis-socket://myusername:@/var/run/redis/redis.sock",
RedisClientOpt{Network: "unix", Addr: "/var/run/redis/redis.sock", Username: "myusername"},
},
{ {
"redis-socket://:mypassword@/var/run/redis/redis.sock", "redis-socket://:mypassword@/var/run/redis/redis.sock",
RedisClientOpt{Network: "unix", Addr: "/var/run/redis/redis.sock", Password: "mypassword"}, RedisClientOpt{Network: "unix", Addr: "/var/run/redis/redis.sock", Password: "mypassword"},
}, },
{
"redis-socket://myusername:mypassword@/var/run/redis/redis.sock",
RedisClientOpt{Network: "unix", Addr: "/var/run/redis/redis.sock", Username: "myusername", Password: "mypassword"},
},
{ {
"redis-socket:///var/run/redis/redis.sock?db=7", "redis-socket:///var/run/redis/redis.sock?db=7",
RedisClientOpt{Network: "unix", Addr: "/var/run/redis/redis.sock", DB: 7}, RedisClientOpt{Network: "unix", Addr: "/var/run/redis/redis.sock", DB: 7},