go-pkg/asynqmon
2
0
Fork 0
mirror of https://github.com/hibiken/asynqmon.git synced 2025-07-01 23:03:39 +08:00
Code Issues Projects Releases Wiki Activity

Merge pull request #3 from platacard/add-default-port

Browse Source 
Add default port if not present in redis-cluster-nodes
This commit is contained in:
Igor Zibarev 2023-12-01 15:50:53 +02:00 committed by GitHub
commit f6370dc32d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cmd/asynqmon/main.go
View File

@ -111,8 +111,18 @@ func makeRedisConnOpt(cfg *Config) (asynq.RedisConnOpt, error) {
// Connecting to redis-cluster // Connecting to redis-cluster
if len(cfg.RedisClusterNodes) > 0 { if len(cfg.RedisClusterNodes) > 0 {
cfg.RedisClusterNodes = cleanUpClusterNodes(cfg.RedisClusterNodes) cfg.RedisClusterNodes = cleanUpClusterNodes(cfg.RedisClusterNodes)
addrs := strings.Split(cfg.RedisClusterNodes, ",")
// Add default port if not present.
for i := range addrs {
if !strings.Contains(addrs[i], ":") {
addrs[i] = addrs[i] + ":6379"
}
}
return asynq.RedisClusterClientOpt{ return asynq.RedisClusterClientOpt{
Addrs: strings.Split(cfg.RedisClusterNodes, ","), Addrs: addrs,
Password: cfg.RedisPassword, Password: cfg.RedisPassword,
Username: cfg.RedisUsername, Username: cfg.RedisUsername,
TLSConfig: makeTLSConfig(cfg), TLSConfig: makeTLSConfig(cfg),