Package com.netflix.hystrix.strategy.metrics

Class HystrixMetricsPublisherFactory

java.lang.Object

com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisherFactory

public class HystrixMetricsPublisherFactory
extends java.lang.Object

Factory for retrieving metrics publisher implementations.

This uses given HystrixMetricsPublisher implementations to construct publisher instances and caches each instance according to the cache key provided.

Method Summary

Modifier and Type	Method and Description
static HystrixMetricsPublisherCollapser	createOrRetrievePublisherForCollapser(HystrixCollapserKey collapserKey, HystrixCollapserMetrics metrics, HystrixCollapserProperties properties) Get an instance of HystrixMetricsPublisherCollapser with the given factory HystrixMetricsPublisher implementation for each HystrixCollapser instance.
static HystrixMetricsPublisherCommand	createOrRetrievePublisherForCommand(HystrixCommandKey commandKey, HystrixCommandGroupKey commandOwner, HystrixCommandMetrics metrics, HystrixCircuitBreaker circuitBreaker, HystrixCommandProperties properties) Get an instance of HystrixMetricsPublisherCommand with the given factory HystrixMetricsPublisher implementation for each HystrixCommand instance.
static HystrixMetricsPublisherThreadPool	createOrRetrievePublisherForThreadPool(HystrixThreadPoolKey threadPoolKey, HystrixThreadPoolMetrics metrics, HystrixThreadPoolProperties properties) Get an instance of HystrixMetricsPublisherThreadPool with the given factory HystrixMetricsPublisher implementation for each HystrixThreadPool instance.
static void	reset() Resets the SINGLETON object.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createOrRetrievePublisherForThreadPool

public static HystrixMetricsPublisherThreadPool createOrRetrievePublisherForThreadPool(HystrixThreadPoolKey threadPoolKey,
                                                                                       HystrixThreadPoolMetrics metrics,
                                                                                       HystrixThreadPoolProperties properties)

Get an instance of HystrixMetricsPublisherThreadPool with the given factory HystrixMetricsPublisher implementation for each HystrixThreadPool instance.

Parameters:

threadPoolKey - Pass-thru to HystrixMetricsPublisher.getMetricsPublisherForThreadPool(com.netflix.hystrix.HystrixThreadPoolKey, com.netflix.hystrix.HystrixThreadPoolMetrics, com.netflix.hystrix.HystrixThreadPoolProperties) implementation

metrics - Pass-thru to HystrixMetricsPublisher.getMetricsPublisherForThreadPool(com.netflix.hystrix.HystrixThreadPoolKey, com.netflix.hystrix.HystrixThreadPoolMetrics, com.netflix.hystrix.HystrixThreadPoolProperties) implementation

properties - Pass-thru to HystrixMetricsPublisher.getMetricsPublisherForThreadPool(com.netflix.hystrix.HystrixThreadPoolKey, com.netflix.hystrix.HystrixThreadPoolMetrics, com.netflix.hystrix.HystrixThreadPoolProperties) implementation

Returns:

HystrixMetricsPublisherThreadPool instance

createOrRetrievePublisherForCommand

public static HystrixMetricsPublisherCommand createOrRetrievePublisherForCommand(HystrixCommandKey commandKey,
                                                                                 HystrixCommandGroupKey commandOwner,
                                                                                 HystrixCommandMetrics metrics,
                                                                                 HystrixCircuitBreaker circuitBreaker,
                                                                                 HystrixCommandProperties properties)

Get an instance of HystrixMetricsPublisherCommand with the given factory HystrixMetricsPublisher implementation for each HystrixCommand instance.

Parameters:

commandKey - Pass-thru to HystrixMetricsPublisher.getMetricsPublisherForCommand(com.netflix.hystrix.HystrixCommandKey, com.netflix.hystrix.HystrixCommandGroupKey, com.netflix.hystrix.HystrixCommandMetrics, com.netflix.hystrix.HystrixCircuitBreaker, com.netflix.hystrix.HystrixCommandProperties) implementation

commandOwner - Pass-thru to HystrixMetricsPublisher.getMetricsPublisherForCommand(com.netflix.hystrix.HystrixCommandKey, com.netflix.hystrix.HystrixCommandGroupKey, com.netflix.hystrix.HystrixCommandMetrics, com.netflix.hystrix.HystrixCircuitBreaker, com.netflix.hystrix.HystrixCommandProperties) implementation

metrics - Pass-thru to HystrixMetricsPublisher.getMetricsPublisherForCommand(com.netflix.hystrix.HystrixCommandKey, com.netflix.hystrix.HystrixCommandGroupKey, com.netflix.hystrix.HystrixCommandMetrics, com.netflix.hystrix.HystrixCircuitBreaker, com.netflix.hystrix.HystrixCommandProperties) implementation

circuitBreaker - Pass-thru to HystrixMetricsPublisher.getMetricsPublisherForCommand(com.netflix.hystrix.HystrixCommandKey, com.netflix.hystrix.HystrixCommandGroupKey, com.netflix.hystrix.HystrixCommandMetrics, com.netflix.hystrix.HystrixCircuitBreaker, com.netflix.hystrix.HystrixCommandProperties) implementation

properties - Pass-thru to HystrixMetricsPublisher.getMetricsPublisherForCommand(com.netflix.hystrix.HystrixCommandKey, com.netflix.hystrix.HystrixCommandGroupKey, com.netflix.hystrix.HystrixCommandMetrics, com.netflix.hystrix.HystrixCircuitBreaker, com.netflix.hystrix.HystrixCommandProperties) implementation

Returns:

HystrixMetricsPublisherCommand instance

reset

public static void reset()

Resets the SINGLETON object. Clears all state from publishers. If new requests come in instances will be recreated.

createOrRetrievePublisherForCollapser

public static HystrixMetricsPublisherCollapser createOrRetrievePublisherForCollapser(HystrixCollapserKey collapserKey,
                                                                                     HystrixCollapserMetrics metrics,
                                                                                     HystrixCollapserProperties properties)

Get an instance of HystrixMetricsPublisherCollapser with the given factory HystrixMetricsPublisher implementation for each HystrixCollapser instance.

Parameters:

collapserKey - Pass-thru to HystrixMetricsPublisher.getMetricsPublisherForCollapser(com.netflix.hystrix.HystrixCollapserKey, com.netflix.hystrix.HystrixCollapserMetrics, com.netflix.hystrix.HystrixCollapserProperties) implementation

metrics - Pass-thru to HystrixMetricsPublisher.getMetricsPublisherForCollapser(com.netflix.hystrix.HystrixCollapserKey, com.netflix.hystrix.HystrixCollapserMetrics, com.netflix.hystrix.HystrixCollapserProperties) implementation

properties - Pass-thru to HystrixMetricsPublisher.getMetricsPublisherForCollapser(com.netflix.hystrix.HystrixCollapserKey, com.netflix.hystrix.HystrixCollapserMetrics, com.netflix.hystrix.HystrixCollapserProperties) implementation

Returns:

HystrixMetricsPublisherCollapser instance