Merge pull request Netflix#1489 from LuboVarga/master

Added exporting of rollingMaxConcurrentExecutionCount value.
sheeeng · Mar 1, 2017 · 4cf7e88 · 4cf7e88
2 parents 8b2de49 + 12143fa
commit 4cf7e88
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/...flix/hystrix/contrib/codahalemetricspublisher/HystrixCodaHaleMetricsPublisherCommand.java b/...flix/hystrix/contrib/codahalemetricspublisher/HystrixCodaHaleMetricsPublisherCommand.java
@@ -272,6 +272,13 @@ public HystrixRollingNumberEvent call() {
                 return HystrixRollingNumberEvent.TIMEOUT;
             }
         });
+        // the rolling number of MaxConcurrentExecutionCount. Can be used to determine saturation
+        safelyCreateRollingCountForEvent("rollingMaxConcurentExecutionCount", new Func0<HystrixRollingNumberEvent>() {
+            @Override
+            public HystrixRollingNumberEvent call() {
+                return HystrixRollingNumberEvent.COMMAND_MAX_ACTIVE;
+            }
+        });
 
         // the number of executionSemaphorePermits in use right now
         metricRegistry.register(createMetricName("executionSemaphorePermitsInUse"), new Gauge<Integer>() {