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

Degrade InfluxDB Retry Write log.

Browse Source
This commit is contained in:
Maximilian Paß
2023-07-14 14:18:09 +02:00
parent 9d13613f37
commit 0bfef5e105
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/monitoring/influxdb2_middleware.go
View File

@ -74,7 +74,7 @@ func InitializeInfluxDB(db *config.InfluxDB) (cancel func()) {
client := influxdb2.NewClientWithOptions(db.URL, db.Token, options) client := influxdb2.NewClientWithOptions(db.URL, db.Token, options)
influxClient = client.WriteAPI(db.Organization, db.Bucket) influxClient = client.WriteAPI(db.Organization, db.Bucket)
influxClient.SetWriteFailedCallback(func(_ string, error http2.Error, retryAttempts uint) bool { influxClient.SetWriteFailedCallback(func(_ string, error http2.Error, retryAttempts uint) bool {
log.WithError(&error).WithField("retryAttempts", retryAttempts).Debug("Retrying to write influx data...") log.WithError(&error).WithField("retryAttempts", retryAttempts).Trace("Retrying to write influx data...")
// retryAttempts means number of retries, 0 if it failed during first write. // retryAttempts means number of retries, 0 if it failed during first write.
if retryAttempts == options.MaxRetries() { if retryAttempts == options.MaxRetries() {