Add Dogstatsd metrics for both duplicate and blank events.

commands/dogstatsd.go

@@ -31,3 +31,29 @@ func StatsdRunTime(start time.Time, exec string, watchType string, watchId strin
 		statsd.Gauge(metricName, float64(milliseconds), tags)
 	}
 }
+
+func StatsdDuplicate(watchType string, watchId string) {
+	if DogStatsd {
+		statsd, _ := godspeed.NewDefault()
+		defer statsd.Conn.Close()
+		tags := make([]string, 2)
+		watchTypeTag := fmt.Sprintf("watchtype:%s", watchType)
+		watchIdTag := fmt.Sprintf("watchid:%s", watchId)
+		tags = append(tags, watchTypeTag)
+		tags = append(tags, watchIdTag)
+		metricName := fmt.Sprintf("%s.duplicate", MetricPrefix)
+		statsd.Incr(metricName, tags)
+	}
+}
+
+func StatsdBlank(watchType string) {
+	if DogStatsd {
+		statsd, _ := godspeed.NewDefault()
+		defer statsd.Conn.Close()
+		tags := make([]string, 1)
+		watchTypeTag := fmt.Sprintf("watchtype:%s", watchType)
+		tags = append(tags, watchTypeTag)
+		metricName := fmt.Sprintf("%s.blank", MetricPrefix)
+		statsd.Incr(metricName, tags)
+	}
+}

commands/event.go

@@ -44,12 +44,12 @@ func startEvent(cmd *cobra.Command, args []string) {
 			StatsdRunTime(start, Exec, "event", EventName, strconv.FormatInt(lTime, 10))
 		} else {
 			RunTime(start, "duplicate", fmt.Sprintf("watch='event' exec='%s' ltime='%d'", Exec, lTime))
+			StatsdDuplicate("event", EventName)
 		}
-
 	} else {
 		RunTime(start, "blank", fmt.Sprintf("watch='event' exec='%s'", Exec))
+		StatsdBlank("event")
 	}
-
 }
 
 func checkEventFlags() {

commands/key.go

@@ -40,9 +40,11 @@ func startKey(cmd *cobra.Command, args []string) {
 			StatsdRunTime(start, Exec, "key", d.getKey(), shaValue)
 		} else {
 			RunTime(start, "duplicate", fmt.Sprintf("watch='key' exec='%s' sha='%s'", Exec, shaValue))
+			StatsdDuplicate("key", d.getKey())
 		}
 	} else {
 		RunTime(start, "blank", fmt.Sprintf("watch='key' exec='%s'", Exec))
+		StatsdBlank("key")
 	}
 }