introduce new type for monotonic counts

DataDog · Dec 12, 2018 · 273aedd · 273aedd
1 parent b5365bd
commit 273aedd
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/main/java/org/datadog/jmxfetch/reporter/Reporter.java b/src/main/java/org/datadog/jmxfetch/reporter/Reporter.java
@@ -84,7 +84,7 @@ public void sendMetrics(LinkedList<HashMap<String, Object>> metrics, String inst
             // StatsD doesn't support rate metrics so we need to have our own aggregator to compute rates
             if ("gauge".equals(metricType) || "histogram".equals(metricType)) {
                 sendMetricPoint(metricType, metricName, currentValue, tags);
-            } else if ("count".equals(metricType)) {
+            } else if ("count".equals(metricType) || "monotonic_count".equals(metricName)) {
                 String key = generateId(metric);
                 if (!instanceCountersAggregator.containsKey(key)) {
                     instanceCountersAggregator.put(key,  currentValue.longValue());
@@ -100,10 +100,12 @@ public void sendMetrics(LinkedList<HashMap<String, Object>> metrics, String inst
 
                 instanceCountersAggregator.put(key, currentValue.longValue());
 
-                if (delta < 0 && canonicalRate) {
+                boolean monotonic = "monotonic_count".equals(metricType);
+                if (delta < 0 && monotonic) {
                     LOGGER.info("Counter " + metricName + " has been reset and canonical rate is enabled - not submitting.");
                     continue;
                 }
+
                 sendMetricPoint(metricType, metricName, delta, tags);
 
             } else { // The metric should be 'counter'

diff --git a/src/main/java/org/datadog/jmxfetch/reporter/StatsdReporter.java b/src/main/java/org/datadog/jmxfetch/reporter/StatsdReporter.java
@@ -31,7 +31,7 @@ protected void sendMetricPoint(String metricType, String metricName, double valu
             this.statsDClient.stop();
             init();
         }
-        if (metricType.equals("count")) {
+        if (metricType.equals("count") || metricType.equals("monotonic_count")) {
             statsDClient.count(metricName, (long) value, tags);
         } else if (metricType.equals("histogram")) {
             statsDClient.histogram(metricName, value, tags);