upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-06-06 15:22:08 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Log all recovered reconnects to backends

Browse source 
... to give the admin the all-clear.

refs #351
This commit is contained in:
Alexander A. Klimov 2021-09-22 16:17:25 +02:00
parent f554fa9dfe
commit b4bfee92d9
2 changed files with 12 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
pkg/config/redis.go
View file

@ -66,6 +66,12 @@ func dialWithLogging(logger *zap.SugaredLogger) func(context.Context, string, st
logger.Warnw("Can't connect to Redis. Retrying", zap.Error(err))
}
},
OnSuccess: func(elapsed time.Duration, attempt uint64, _ error) {
if attempt > 0 {
logger.Infow("Reconnected to Redis",
zap.Duration("after", elapsed), zap.Uint64("attempts", attempt+1))
}
},
},
)

6
pkg/driver/driver.go
View file

@ -39,6 +39,12 @@ func (c RetryConnector) Connect(ctx context.Context) (driver.Conn, error) {
c.driver.Logger.Warnw("Can't connect to database. Retrying", zap.Error(err))
}
},
OnSuccess: func(elapsed time.Duration, attempt uint64, _ error) {
if attempt > 0 {
c.driver.Logger.Infow("Reconnected to database",
zap.Duration("after", elapsed), zap.Uint64("attempts", attempt+1))
}
},
},
), "can't connect to database")
return conn, err