upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-05-28 04:35:54 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Add Redis password authentication

Browse source 
Adds the missing password authentication.

refs #204
This commit is contained in:
Michael Insel 2020-08-10 17:51:19 +02:00
parent c0b6e8d202
commit bca3ce7121
2 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
connection/redis.go
View file

@ -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,

2
main.go
View file

@ -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,