add generic metric increment report method

extensions/datadog_statsd.go

@@ -117,6 +117,20 @@ func (s *StatsD) ReportGoStats(
 	s.Client.Gauge("next_gc_bytes", float64(nextGCBytes), tags, 1)
 }
 
+// ReportMetricIncrement reports a custom metric increment in statsd
+func (s *StatsD) ReportMetricIncrement(
+	metric string,
+	game, platform string,
+) {
+	hostname, _ := os.Hostname()
+	tags := []string{
+		fmt.Sprintf("hostname:%s", hostname),
+		fmt.Sprintf("game:%s", game),
+		fmt.Sprintf("platform:%s", platform),
+	}
+	s.Client.Incr(metric, tags, 1)
+}
+
 //Cleanup closes statsd connection
 func (s *StatsD) Cleanup() error {
 	s.Client.Close()

extensions/datadog_statsd_test.go

@@ -99,6 +99,27 @@ var _ = Describe("StatsD Extension", func() {
 				Expect(mockClient.Count["failed"]).To(Equal(2))
 			})
 		})
+
+		Describe("Reporting metric increment", func() {
+			It("should report metric increment in statsd", func() {
+				statsd, err := NewStatsD(config, logger, mockClient)
+				Expect(err).NotTo(HaveOccurred())
+				defer statsd.Cleanup()
+
+				statsd.ReportMetricIncrement("tokens_to_delete", "game", "apns")
+				statsd.ReportMetricIncrement("tokens_to_delete", "game", "apns")
+				statsd.ReportMetricIncrement("tokens_to_delete", "game", "apns")
+
+				statsd.ReportMetricIncrement("tokens_deleted", "game", "apns")
+				statsd.ReportMetricIncrement("tokens_deleted", "game", "apns")
+
+				statsd.ReportMetricIncrement("tokens_deletion_failed", "game", "apns")
+
+				Expect(mockClient.Count["tokens_to_delete"]).To(Equal(3))
+				Expect(mockClient.Count["tokens_deleted"]).To(Equal(2))
+				Expect(mockClient.Count["tokens_deletion_failed"]).To(Equal(1))
+			})
+		})
 	})
 
 	Describe("[Integration]", func() {

interfaces/stats_reporter.go

@@ -30,4 +30,5 @@ type StatsReporter interface {
 	HandleNotificationSuccess(game string, platform string)
 	HandleNotificationFailure(game string, platform string, err *errors.PushError)
 	ReportGoStats(numGoRoutines int, allocatedAndNotFreed, heapObjects, nextGCBytes, pauseGCNano uint64)
+	ReportMetricIncrement(metric string, game, platform string)
 }