Added exporting of rollingMaxConcurrentExecutionCount value.

See Netflix#667 for more info.
LuboVarga · Mar 1, 2017 · 12143fa · 12143fa
1 parent 0db9367
commit 12143fa
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>() {