From 1cbc5a9b27dccfc1bb4b9fc533760e8781e34572 Mon Sep 17 00:00:00 2001
From: Brian Akins <brian@akins.org>
Date: Mon, 25 Mar 2019 18:16:38 -0400
Subject: [PATCH] Add metric for count of events by action

Signed-off-by: Brian Akins <brian@akins.org>
---
 exporter.go  | 2 ++
 telemetry.go | 8 ++++++++
 2 files changed, 10 insertions(+)

diff --git a/exporter.go b/exporter.go
index 15c01b7..0339da5 100644
--- a/exporter.go
+++ b/exporter.go
@@ -322,6 +322,7 @@ func (b *Exporter) handleEvent(event Event) {
 	}
 
 	if mapping.Action == mapper.ActionTypeDrop {
+		eventsActions.WithLabelValues("drop").Inc()
 		return
 	}
 
@@ -342,6 +343,7 @@ func (b *Exporter) handleEvent(event Event) {
 		for label, value := range labels {
 			prometheusLabels[label] = value
 		}
+		eventsActions.WithLabelValues(string(mapping.Action)).Inc()
 	} else {
 		eventsUnmapped.Inc()
 		metricName = escapeMetricName(event.MetricName())
diff --git a/telemetry.go b/telemetry.go
index 541140c..be38b96 100644
--- a/telemetry.go
+++ b/telemetry.go
@@ -109,6 +109,13 @@ var (
 		},
 		[]string{"reason"},
 	)
+	eventsActions = prometheus.NewCounterVec(
+		prometheus.CounterOpts{
+			Name: "statsd_exporter_events_actions_total",
+			Help: "The total number of StatsD events by action.",
+		},
+		[]string{"action"},
+	)
 )
 
 func init() {
@@ -127,4 +134,5 @@ func init() {
 	prometheus.MustRegister(mappingsCount)
 	prometheus.MustRegister(conflictingEventStats)
 	prometheus.MustRegister(errorEventStats)
+	prometheus.MustRegister(eventsActions)
 }