Parcourir la source

fixed duplicate metric problem at influxDB, on client.WriteSeries

niko il y a 11 ans
Parent
commit
f6dbbac614
1 fichiers modifiés avec 3 ajouts et 3 suppressions
  1. 3 3
      influxdb/influxdb.go

+ 3 - 3
influxdb/influxdb.go

@@ -102,10 +102,10 @@ func send(r metrics.Registry, client *influxClient.Client) error {
 				},
 			})
 		}
-		if err := client.WriteSeries(series); err != nil {
-			log.Println(err)
-		}
 	})
+	if err := client.WriteSeries(series); err != nil {
+		log.Println(err)
+	}
 	return nil
 }