From bca3ce71211f3abee94f02078007fed89d56f2ff Mon Sep 17 00:00:00 2001 From: Michael Insel Date: Mon, 10 Aug 2020 17:51:19 +0200 Subject: [PATCH] Add Redis password authentication Adds the missing password authentication. refs #204 --- connection/redis.go | 3 ++- main.go | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/connection/redis.go b/connection/redis.go index 8ec7f158..8fbd9da1 100644 --- a/connection/redis.go +++ b/connection/redis.go @@ -112,11 +112,12 @@ func (rdbw *RDBWrapper) CompareAndSetConnected(connected bool) (swapped bool) { } } -func NewRDBWrapper(address string, poolSize int) *RDBWrapper { +func NewRDBWrapper(address string, password string, poolSize int) *RDBWrapper { log.Info("Connecting to Redis") rdb := redis.NewClient(&redis.Options{ Addr: address, + Password: password, DialTimeout: time.Minute / 2, ReadTimeout: time.Minute, WriteTimeout: time.Minute, diff --git a/main.go b/main.go index fbc3ecb8..40aea7e5 100644 --- a/main.go +++ b/main.go @@ -104,7 +104,7 @@ func main() { mysqlInfo := config.GetMysqlInfo() metricsInfo := config.GetMetricsInfo() - redisConn := connection.NewRDBWrapper(redisInfo.Host+":"+redisInfo.Port, redisInfo.PoolSize) + redisConn := connection.NewRDBWrapper(redisInfo.Host+":"+redisInfo.Port, redisInfo.Password,redisInfo.PoolSize) mysqlConn, err := connection.NewDBWrapper( mysqlInfo.User+":"+mysqlInfo.Password+"@tcp("+mysqlInfo.Host+":"+mysqlInfo.Port+")/"+mysqlInfo.Database,