Add metric for total number of conflicting events

prometheus · Jul 18, 2017 · bbd5227 · bbd5227
1 parent c1791d7
commit bbd5227
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/exporter.go b/exporter.go
@@ -250,6 +250,7 @@ func (b *Exporter) Listen(e <-chan Events) {
 					eventStats.WithLabelValues("counter").Inc()
 				} else {
 					log.Errorf(regErrF, metricName, err)
+					conflictingEventStats.WithLabelValues("counter").Inc()
 				}
 
 			case *GaugeEvent:
@@ -268,6 +269,7 @@ func (b *Exporter) Listen(e <-chan Events) {
 					eventStats.WithLabelValues("gauge").Inc()
 				} else {
 					log.Errorf(regErrF, metricName, err)
+					conflictingEventStats.WithLabelValues("gauge").Inc()
 				}
 
 			case *TimerEvent:
@@ -281,6 +283,7 @@ func (b *Exporter) Listen(e <-chan Events) {
 					eventStats.WithLabelValues("timer").Inc()
 				} else {
 					log.Errorf(regErrF, metricName, err)
+					conflictingEventStats.WithLabelValues("timer").Inc()
 				}
 
 			default:

diff --git a/telemetry.go b/telemetry.go
@@ -47,11 +47,19 @@ var (
 		Name: "statsd_exporter_loaded_mappings",
 		Help: "The current number of configured metric mappings.",
 	})
+	conflictingEventStats = prometheus.NewCounterVec(
+		prometheus.CounterOpts{
+			Name: "statsd_exporter_events_conflict_total",
+			Help: "The total number of StatsD events with conflicting names.",
+		},
+		[]string{"type"},
+	)
 )
 
 func init() {
 	prometheus.MustRegister(eventStats)
 	prometheus.MustRegister(networkStats)
 	prometheus.MustRegister(configLoads)
 	prometheus.MustRegister(mappingsCount)
+	prometheus.MustRegister(conflictingEventStats)
 }