Skip to content

Commit aa824da

Browse files
committed
parse URL before creating redis connection
1 parent a2cc197 commit aa824da

1 file changed

Lines changed: 7 additions & 5 deletions

File tree

scheduler/cmd/scheduler/main.go

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -49,11 +49,13 @@ func main() {
4949
}
5050
defer conn.Close()
5151

52-
redisConn := redis.NewClient(&redis.Options{
53-
Addr: config.CacheUrl,
54-
Password: "",
55-
DB: 0,
56-
})
52+
options, err := redis.ParseURL(config.CacheUrl)
53+
if err != nil {
54+
logger.Error("error parsing redis url", "err", err)
55+
return
56+
}
57+
58+
redisConn := redis.NewClient(options)
5759

5860
messageBusConn, err := amqp.Dial(config.MessageBusUrl)
5961
if err != nil {

0 commit comments

Comments
 (0)