feat: include semaphore rejects in hystrix stats

nodeshift · Jun 20, 2017 · 2c326cc · 2c326cc
1 parent 80decd2
commit 2c326cc
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/hystrix-formatter.js b/lib/hystrix-formatter.js
@@ -23,7 +23,7 @@ function hystrixFormatter (stats) {
   json.rollingCountFallbackRejection = 0;
   json.rollingCountFallbackSuccess = 0;
   json.rollingCountResponsesFromCache = stats.cacheHits;
-  json.rollingCountSemaphoreRejected = stats.rejects;
+  json.rollingCountSemaphoreRejected = stats.semaphoreRejections;
   json.rollingCountShortCircuited = stats.rejects;
   json.rollingCountSuccess = stats.successes;
   json.rollingCountThreadPoolRejected = 0;
@@ -67,8 +67,8 @@ function hystrixFormatter (stats) {
   json.propertyValue_executionTimeoutInMilliseconds = stats.options.timeout;
   json.propertyValue_executionIsolationThreadInterruptOnTimeout = true;
   json.propertyValue_executionIsolationThreadPoolKeyOverride = null;
-  json.propertyValue_executionIsolationSemaphoreMaxConcurrentRequests = 10;
-  json.propertyValue_fallbackIsolationSemaphoreMaxConcurrentRequests = 10;
+  json.propertyValue_executionIsolationSemaphoreMaxConcurrentRequests = stats.options.capacity;
+  json.propertyValue_fallbackIsolationSemaphoreMaxConcurrentRequests = stats.options.capacity;
   json.propertyValue_metricsRollingStatisticalWindowInMilliseconds = 10000;
   json.propertyValue_requestCacheEnabled = stats.options.cache || false;
   json.propertyValue_requestLogEnabled = true;