test_class.declarator: groupKey = HystrixCommandGroupKey.Factory.asKey("HystrixThreadPoolMetrics-UnitTest")
test_class.modifier: private static final
test_class.original_string: private static final HystrixCommandGroupKey groupKey = HystrixCommandGroupKey.Factory.asKey("HystrixThreadPoolMetrics-UnitTest");
test_class.type: HystrixCommandGroupKey
test_class.var_name: groupKey
test_class.declarator: tpKey = HystrixThreadPoolKey.Factory.asKey("HystrixThreadPoolMetrics-ThreadPool")
test_class.modifier: private static final
test_class.original_string: private static final HystrixThreadPoolKey tpKey = HystrixThreadPoolKey.Factory.asKey("HystrixThreadPoolMetrics-ThreadPool");
test_class.type: HystrixThreadPoolKey
test_class.var_name: tpKey
test_class.file: hystrix-core/src/test/java/com/netflix/hystrix/HystrixThreadPoolMetricsTest.java
test_class.identifier: HystrixThreadPoolMetricsTest
test_case.body: @Test
      public void shouldYieldNoExecutedTasksOnStartup() throws Exception {
          //given
          final Collection<HystrixThreadPoolMetrics> instances = HystrixThreadPoolMetrics.getInstances();
  
          //then
          assertEquals(0, instances.size());
  
      }
test_case.class_method_signature: HystrixThreadPoolMetricsTest.shouldYieldNoExecutedTasksOnStartup()
test_case.full_signature: @Test public void shouldYieldNoExecutedTasksOnStartup()
test_case.identifier: shouldYieldNoExecutedTasksOnStartup
test_case.invocations: getInstances assertEquals size
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void shouldYieldNoExecutedTasksOnStartup()
focal_class.declarator: ALL_COMMAND_EVENT_TYPES = HystrixEventType.values()
focal_class.modifier: private static final
focal_class.original_string: private static final HystrixEventType[] ALL_COMMAND_EVENT_TYPES = HystrixEventType.values();
focal_class.type: HystrixEventType[]
focal_class.var_name: ALL_COMMAND_EVENT_TYPES
focal_class.declarator: ALL_THREADPOOL_EVENT_TYPES = HystrixEventType.ThreadPool.values()
focal_class.modifier: private static final
focal_class.original_string: private static final HystrixEventType.ThreadPool[] ALL_THREADPOOL_EVENT_TYPES = HystrixEventType.ThreadPool.values();
focal_class.type: HystrixEventType.ThreadPool[]
focal_class.var_name: ALL_THREADPOOL_EVENT_TYPES
focal_class.declarator: NUMBER_THREADPOOL_EVENT_TYPES = ALL_THREADPOOL_EVENT_TYPES.length
focal_class.modifier: private static final
focal_class.original_string: private static final int NUMBER_THREADPOOL_EVENT_TYPES = ALL_THREADPOOL_EVENT_TYPES.length;
focal_class.type: int
focal_class.var_name: NUMBER_THREADPOOL_EVENT_TYPES
focal_class.declarator: metrics = new ConcurrentHashMap<String, HystrixThreadPoolMetrics>()
focal_class.modifier: private static final
focal_class.original_string: private static final ConcurrentHashMap<String, HystrixThreadPoolMetrics> metrics = new ConcurrentHashMap<String, HystrixThreadPoolMetrics>();
focal_class.type: ConcurrentHashMap<String, HystrixThreadPoolMetrics>
focal_class.var_name: metrics
focal_class.declarator: appendEventToBucket
              = new Func2<long[], HystrixCommandCompletion, long[]>() {
          @Override
          public long[] call(long[] initialCountArray, HystrixCommandCompletion execution) {
              ExecutionResult.EventCounts eventCounts = execution.getEventCounts();
              for (HystrixEventType eventType: ALL_COMMAND_EVENT_TYPES) {
                  long eventCount = eventCounts.getCount(eventType);
                  HystrixEventType.ThreadPool threadPoolEventType = HystrixEventType.ThreadPool.from(eventType);
                  if (threadPoolEventType != null) {
                      initialCountArray[threadPoolEventType.ordinal()] += eventCount;
                  }
              }
              return initialCountArray;
          }
      }
focal_class.modifier: public static final
focal_class.original_string: public static final Func2<long[], HystrixCommandCompletion, long[]> appendEventToBucket
              = new Func2<long[], HystrixCommandCompletion, long[]>() {
          @Override
          public long[] call(long[] initialCountArray, HystrixCommandCompletion execution) {
              ExecutionResult.EventCounts eventCounts = execution.getEventCounts();
              for (HystrixEventType eventType: ALL_COMMAND_EVENT_TYPES) {
                  long eventCount = eventCounts.getCount(eventType);
                  HystrixEventType.ThreadPool threadPoolEventType = HystrixEventType.ThreadPool.from(eventType);
                  if (threadPoolEventType != null) {
                      initialCountArray[threadPoolEventType.ordinal()] += eventCount;
                  }
              }
              return initialCountArray;
          }
      };
focal_class.type: Func2<long[], HystrixCommandCompletion, long[]>
focal_class.var_name: appendEventToBucket
focal_class.declarator: counterAggregator = new Func2<long[], long[], long[]>() {
          @Override
          public long[] call(long[] cumulativeEvents, long[] bucketEventCounts) {
              for (int i = 0; i < NUMBER_THREADPOOL_EVENT_TYPES; i++) {
                  cumulativeEvents[i] += bucketEventCounts[i];
              }
              return cumulativeEvents;
          }
      }
focal_class.modifier: public static final
focal_class.original_string: public static final Func2<long[], long[], long[]> counterAggregator = new Func2<long[], long[], long[]>() {
          @Override
          public long[] call(long[] cumulativeEvents, long[] bucketEventCounts) {
              for (int i = 0; i < NUMBER_THREADPOOL_EVENT_TYPES; i++) {
                  cumulativeEvents[i] += bucketEventCounts[i];
              }
              return cumulativeEvents;
          }
      };
focal_class.type: Func2<long[], long[], long[]>
focal_class.var_name: counterAggregator
focal_class.declarator: threadPoolKey
focal_class.modifier: private final
focal_class.original_string: private final HystrixThreadPoolKey threadPoolKey;
focal_class.type: HystrixThreadPoolKey
focal_class.var_name: threadPoolKey
focal_class.declarator: threadPool
focal_class.modifier: private final
focal_class.original_string: private final ThreadPoolExecutor threadPool;
focal_class.type: ThreadPoolExecutor
focal_class.var_name: threadPool
focal_class.declarator: properties
focal_class.modifier: private final
focal_class.original_string: private final HystrixThreadPoolProperties properties;
focal_class.type: HystrixThreadPoolProperties
focal_class.var_name: properties
focal_class.declarator: concurrentExecutionCount = new AtomicInteger()
focal_class.modifier: private final
focal_class.original_string: private final AtomicInteger concurrentExecutionCount = new AtomicInteger();
focal_class.type: AtomicInteger
focal_class.var_name: concurrentExecutionCount
focal_class.declarator: rollingCounterStream
focal_class.modifier: private final
focal_class.original_string: private final RollingThreadPoolEventCounterStream rollingCounterStream;
focal_class.type: RollingThreadPoolEventCounterStream
focal_class.var_name: rollingCounterStream
focal_class.declarator: cumulativeCounterStream
focal_class.modifier: private final
focal_class.original_string: private final CumulativeThreadPoolEventCounterStream cumulativeCounterStream;
focal_class.type: CumulativeThreadPoolEventCounterStream
focal_class.var_name: cumulativeCounterStream
focal_class.declarator: rollingThreadPoolMaxConcurrencyStream
focal_class.modifier: private final
focal_class.original_string: private final RollingThreadPoolMaxConcurrencyStream rollingThreadPoolMaxConcurrencyStream;
focal_class.type: RollingThreadPoolMaxConcurrencyStream
focal_class.var_name: rollingThreadPoolMaxConcurrencyStream
focal_class.file: hystrix-core/src/main/java/com/netflix/hystrix/HystrixThreadPoolMetrics.java
focal_class.identifier: HystrixThreadPoolMetrics
focal_class.class_method_signature: HystrixThreadPoolMetrics.getInstance(HystrixThreadPoolKey key, ThreadPoolExecutor threadPool, HystrixThreadPoolProperties properties)
focal_class.full_signature: public static HystrixThreadPoolMetrics getInstance(HystrixThreadPoolKey key, ThreadPoolExecutor threadPool, HystrixThreadPoolProperties properties)
focal_class.identifier: getInstance
focal_class.modifiers: public static
focal_class.parameters: (HystrixThreadPoolKey key, ThreadPoolExecutor threadPool, HystrixThreadPoolProperties properties)
focal_class.return: HystrixThreadPoolMetrics
focal_class.signature: HystrixThreadPoolMetrics getInstance(HystrixThreadPoolKey key, ThreadPoolExecutor threadPool, HystrixThreadPoolProperties properties)
focal_class.class_method_signature: HystrixThreadPoolMetrics.getInstance(HystrixThreadPoolKey key)
focal_class.full_signature: public static HystrixThreadPoolMetrics getInstance(HystrixThreadPoolKey key)
focal_class.identifier: getInstance
focal_class.modifiers: public static
focal_class.parameters: (HystrixThreadPoolKey key)
focal_class.return: HystrixThreadPoolMetrics
focal_class.signature: HystrixThreadPoolMetrics getInstance(HystrixThreadPoolKey key)
focal_class.class_method_signature: HystrixThreadPoolMetrics.getInstances()
focal_class.full_signature: public static Collection<HystrixThreadPoolMetrics> getInstances()
focal_class.identifier: getInstances
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: Collection<HystrixThreadPoolMetrics>
focal_class.signature: Collection<HystrixThreadPoolMetrics> getInstances()
focal_class.class_method_signature: HystrixThreadPoolMetrics.hasExecutedCommandsOnThread(HystrixThreadPoolMetrics threadPoolMetrics)
focal_class.full_signature: private static boolean hasExecutedCommandsOnThread(HystrixThreadPoolMetrics threadPoolMetrics)
focal_class.identifier: hasExecutedCommandsOnThread
focal_class.modifiers: private static
focal_class.parameters: (HystrixThreadPoolMetrics threadPoolMetrics)
focal_class.return: boolean
focal_class.signature: boolean hasExecutedCommandsOnThread(HystrixThreadPoolMetrics threadPoolMetrics)
focal_class.class_method_signature: HystrixThreadPoolMetrics.reset()
focal_class.full_signature: static void reset()
focal_class.identifier: reset
focal_class.modifiers: static
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void reset()
focal_class.class_method_signature: HystrixThreadPoolMetrics.HystrixThreadPoolMetrics(HystrixThreadPoolKey threadPoolKey, ThreadPoolExecutor threadPool, HystrixThreadPoolProperties properties)
focal_class.full_signature: private  HystrixThreadPoolMetrics(HystrixThreadPoolKey threadPoolKey, ThreadPoolExecutor threadPool, HystrixThreadPoolProperties properties)
focal_class.identifier: HystrixThreadPoolMetrics
focal_class.modifiers: private
focal_class.parameters: (HystrixThreadPoolKey threadPoolKey, ThreadPoolExecutor threadPool, HystrixThreadPoolProperties properties)
focal_class.signature:  HystrixThreadPoolMetrics(HystrixThreadPoolKey threadPoolKey, ThreadPoolExecutor threadPool, HystrixThreadPoolProperties properties)
focal_class.class_method_signature: HystrixThreadPoolMetrics.getThreadPool()
focal_class.full_signature: public ThreadPoolExecutor getThreadPool()
focal_class.identifier: getThreadPool
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: ThreadPoolExecutor
focal_class.signature: ThreadPoolExecutor getThreadPool()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getThreadPoolKey()
focal_class.full_signature: public HystrixThreadPoolKey getThreadPoolKey()
focal_class.identifier: getThreadPoolKey
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: HystrixThreadPoolKey
focal_class.signature: HystrixThreadPoolKey getThreadPoolKey()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getProperties()
focal_class.full_signature: public HystrixThreadPoolProperties getProperties()
focal_class.identifier: getProperties
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: HystrixThreadPoolProperties
focal_class.signature: HystrixThreadPoolProperties getProperties()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCurrentActiveCount()
focal_class.full_signature: public Number getCurrentActiveCount()
focal_class.identifier: getCurrentActiveCount
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Number
focal_class.signature: Number getCurrentActiveCount()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCurrentCompletedTaskCount()
focal_class.full_signature: public Number getCurrentCompletedTaskCount()
focal_class.identifier: getCurrentCompletedTaskCount
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Number
focal_class.signature: Number getCurrentCompletedTaskCount()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCurrentCorePoolSize()
focal_class.full_signature: public Number getCurrentCorePoolSize()
focal_class.identifier: getCurrentCorePoolSize
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Number
focal_class.signature: Number getCurrentCorePoolSize()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCurrentLargestPoolSize()
focal_class.full_signature: public Number getCurrentLargestPoolSize()
focal_class.identifier: getCurrentLargestPoolSize
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Number
focal_class.signature: Number getCurrentLargestPoolSize()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCurrentMaximumPoolSize()
focal_class.full_signature: public Number getCurrentMaximumPoolSize()
focal_class.identifier: getCurrentMaximumPoolSize
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Number
focal_class.signature: Number getCurrentMaximumPoolSize()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCurrentPoolSize()
focal_class.full_signature: public Number getCurrentPoolSize()
focal_class.identifier: getCurrentPoolSize
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Number
focal_class.signature: Number getCurrentPoolSize()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCurrentTaskCount()
focal_class.full_signature: public Number getCurrentTaskCount()
focal_class.identifier: getCurrentTaskCount
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Number
focal_class.signature: Number getCurrentTaskCount()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCurrentQueueSize()
focal_class.full_signature: public Number getCurrentQueueSize()
focal_class.identifier: getCurrentQueueSize
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Number
focal_class.signature: Number getCurrentQueueSize()
focal_class.class_method_signature: HystrixThreadPoolMetrics.markThreadExecution()
focal_class.full_signature: public void markThreadExecution()
focal_class.identifier: markThreadExecution
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void markThreadExecution()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getRollingCountThreadsExecuted()
focal_class.full_signature: public long getRollingCountThreadsExecuted()
focal_class.identifier: getRollingCountThreadsExecuted
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getRollingCountThreadsExecuted()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCumulativeCountThreadsExecuted()
focal_class.full_signature: public long getCumulativeCountThreadsExecuted()
focal_class.identifier: getCumulativeCountThreadsExecuted
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getCumulativeCountThreadsExecuted()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getRollingCountThreadsRejected()
focal_class.full_signature: public long getRollingCountThreadsRejected()
focal_class.identifier: getRollingCountThreadsRejected
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getRollingCountThreadsRejected()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCumulativeCountThreadsRejected()
focal_class.full_signature: public long getCumulativeCountThreadsRejected()
focal_class.identifier: getCumulativeCountThreadsRejected
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getCumulativeCountThreadsRejected()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getRollingCount(HystrixEventType.ThreadPool event)
focal_class.full_signature: public long getRollingCount(HystrixEventType.ThreadPool event)
focal_class.identifier: getRollingCount
focal_class.modifiers: public
focal_class.parameters: (HystrixEventType.ThreadPool event)
focal_class.return: long
focal_class.signature: long getRollingCount(HystrixEventType.ThreadPool event)
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCumulativeCount(HystrixEventType.ThreadPool event)
focal_class.full_signature: public long getCumulativeCount(HystrixEventType.ThreadPool event)
focal_class.identifier: getCumulativeCount
focal_class.modifiers: public
focal_class.parameters: (HystrixEventType.ThreadPool event)
focal_class.return: long
focal_class.signature: long getCumulativeCount(HystrixEventType.ThreadPool event)
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCumulativeCount(HystrixRollingNumberEvent event)
focal_class.full_signature: @Override public long getCumulativeCount(HystrixRollingNumberEvent event)
focal_class.identifier: getCumulativeCount
focal_class.modifiers: @Override public
focal_class.parameters: (HystrixRollingNumberEvent event)
focal_class.return: long
focal_class.signature: long getCumulativeCount(HystrixRollingNumberEvent event)
focal_class.class_method_signature: HystrixThreadPoolMetrics.getRollingCount(HystrixRollingNumberEvent event)
focal_class.full_signature: @Override public long getRollingCount(HystrixRollingNumberEvent event)
focal_class.identifier: getRollingCount
focal_class.modifiers: @Override public
focal_class.parameters: (HystrixRollingNumberEvent event)
focal_class.return: long
focal_class.signature: long getRollingCount(HystrixRollingNumberEvent event)
focal_class.class_method_signature: HystrixThreadPoolMetrics.markThreadCompletion()
focal_class.full_signature: public void markThreadCompletion()
focal_class.identifier: markThreadCompletion
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void markThreadCompletion()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getRollingMaxActiveThreads()
focal_class.full_signature: public long getRollingMaxActiveThreads()
focal_class.identifier: getRollingMaxActiveThreads
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getRollingMaxActiveThreads()
focal_class.class_method_signature: HystrixThreadPoolMetrics.markThreadRejection()
focal_class.full_signature: public void markThreadRejection()
focal_class.identifier: markThreadRejection
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void markThreadRejection()
focal_class.class_method_signature: HystrixThreadPoolMetrics.getCurrentConcurrencyThunk(final HystrixThreadPoolKey threadPoolKey)
focal_class.full_signature: public static Func0<Integer> getCurrentConcurrencyThunk(final HystrixThreadPoolKey threadPoolKey)
focal_class.identifier: getCurrentConcurrencyThunk
focal_class.modifiers: public static
focal_class.parameters: (final HystrixThreadPoolKey threadPoolKey)
focal_class.return: Func0<Integer>
focal_class.signature: Func0<Integer> getCurrentConcurrencyThunk(final HystrixThreadPoolKey threadPoolKey)
focal_class.superclass: extends HystrixMetrics
focal_method.body: public static Collection<HystrixThreadPoolMetrics> getInstances() {
          List<HystrixThreadPoolMetrics> threadPoolMetrics = new ArrayList<HystrixThreadPoolMetrics>();
          for (HystrixThreadPoolMetrics tpm: metrics.values()) {
              if (hasExecutedCommandsOnThread(tpm)) {
                  threadPoolMetrics.add(tpm);
              }
          }
  
          return Collections.unmodifiableCollection(threadPoolMetrics);
      }
focal_method.class_method_signature: HystrixThreadPoolMetrics.getInstances()
focal_method.full_signature: public static Collection<HystrixThreadPoolMetrics> getInstances()
focal_method.identifier: getInstances
focal_method.invocations: values hasExecutedCommandsOnThread add unmodifiableCollection
focal_method.modifiers: public static
focal_method.parameters: ()
focal_method.return: Collection<HystrixThreadPoolMetrics>
focal_method.signature: Collection<HystrixThreadPoolMetrics> getInstances()