count time spent filtering bad messages

Signed-off-by: John Seekins <[email protected]>
datto · Nov 24, 2021 · 73973c1 · 73973c1
1 parent da61363
commit 73973c1
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/filters.go b/filters.go
@@ -54,12 +54,14 @@ func filterMsg(thread int, msg InfluxMetric, normalize bool) (InfluxMetric, erro
 	if !allowedFirstChar.MatchString(msg.Name) {
 		DroppedMsgs.Inc()
 		log.WithFields(log.Fields{"threadNum": thread, "name": msg.Name, "metric": msg, "section": "filter"}).Warning("Dropped! Bad first character in name")
+		FilterTime.Add(float64(time.Now().Sub(FilterTimeStart)) / TimeSegmentDivisor)
 		return InfluxMetric{}, fmt.Errorf("Dropped metric with bad name")
 	}
 	// Also check for metrics with no fields (this occasionally happens with histograms from prometheus data sources)
 	if len(msg.Fields) < 1 {
 		DroppedMsgs.Inc()
 		log.WithFields(log.Fields{"threadNum": thread, "name": msg.Name, "metric": msg, "section": "filter"}).Warning("Dropped! No fields in incoming metric")
+		FilterTime.Add(float64(time.Now().Sub(FilterTimeStart)) / TimeSegmentDivisor)
 		return InfluxMetric{}, fmt.Errorf("Dropped metric with bad name")
 	}
 	if normalize {