htwkmooc/poseidon
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Enable logging for failed monitoring.

Browse Source
This commit is contained in:
Maximilian Paß
2022-07-01 14:41:03 +02:00
parent 3f0c781997
commit d9b7989a6c
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/monitoring/influxdb2_middleware.go
View File

@ -6,6 +6,7 @@ import (
"github.com/gorilla/mux" "github.com/gorilla/mux"
influxdb2 "github.com/influxdata/influxdb-client-go/v2" influxdb2 "github.com/influxdata/influxdb-client-go/v2"
influxdb2API "github.com/influxdata/influxdb-client-go/v2/api" influxdb2API "github.com/influxdata/influxdb-client-go/v2/api"
http2 "github.com/influxdata/influxdb-client-go/v2/api/http"
"github.com/influxdata/influxdb-client-go/v2/api/write" "github.com/influxdata/influxdb-client-go/v2/api/write"
"github.com/openHPI/poseidon/internal/config" "github.com/openHPI/poseidon/internal/config"
"github.com/openHPI/poseidon/pkg/dto" "github.com/openHPI/poseidon/pkg/dto"
@ -47,6 +48,12 @@ func InitializeInfluxDB(db *config.InfluxDB) (cancel func()) {
client := influxdb2.NewClient(db.URL, db.Token) client := influxdb2.NewClient(db.URL, db.Token)
influxClient = client.WriteAPI(db.Organization, db.Bucket) influxClient = client.WriteAPI(db.Organization, db.Bucket)
influxClient.SetWriteFailedCallback(func(_ string, error http2.Error, retryAttempts uint) bool {
if retryAttempts == 0 {
log.WithError(&error).Warn("Could not write influx data.")
}
return true // Enable retry (default)
})
cancel = func() { cancel = func() {
influxClient.Flush() influxClient.Flush()
client.Close() client.Close()