luzifer/continuous-spark
1
0
Fork 0
mirror of https://github.com/Luzifer/continuous-spark.git synced 2024-12-20 09:41:19 +00:00
Code Issues Releases Wiki Activity

Fix: Metrics sender blocked on errors

Browse source 
Signed-off-by: Knut Ahlers <knut@ahlers.me>
This commit is contained in:
Knut Ahlers 2021-01-10 15:56:58 +01:00
parent 7b4bd40773
commit d744b91fb0
Signed by: luzifer
GPG key ID: 0066F03ED215AD7D
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
main.go
View file

@ -56,6 +56,12 @@ func main() {
if metrics, err = newMetricsSender(cfg.InfluxHost, cfg.InfluxUser, cfg.InfluxPass, cfg.InfluxDB); err != nil { if metrics, err = newMetricsSender(cfg.InfluxHost, cfg.InfluxUser, cfg.InfluxPass, cfg.InfluxDB); err != nil {
log.WithError(err).Fatalf("Unable to initialize InfluxDB sender") log.WithError(err).Fatalf("Unable to initialize InfluxDB sender")
} }
go func() {
for err := range metrics.Errors() {
log.WithError(err).Error("Unable to transmit metrics")
}
}()
} }
if err := updateStats(execTest()); err != nil { if err := updateStats(execTest()); err != nil {