io.micronaut.tracing.instrument.hystrix

Class TracingHystrixConcurrentStrategy

java.lang.Object

com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

io.micronaut.tracing.instrument.hystrix.TracingHystrixConcurrentStrategy

@Requires(classes=com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy.class) @Requires(beans=io.opentracing.Tracer.class) @Requires(missingBeans=io.opentracing.noop.NoopTracer.class)
 @Singleton
public class TracingHystrixConcurrentStrategy
extends com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

Replaces the default HystrixConcurrencyStrategy with one that is enhanced for Tracing.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
TracingHystrixConcurrentStrategy(io.opentracing.Tracer tracer, com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy hystrixConcurrencyStrategy) Creates enhanced HystrixConcurrencyStrategy for tracing.

Method Summary

Modifier and Type	Method and Description
BlockingQueue<Runnable>	getBlockingQueue(int maxQueueSize)
<T> com.netflix.hystrix.strategy.concurrency.HystrixRequestVariable<T>	getRequestVariable(com.netflix.hystrix.strategy.concurrency.HystrixRequestVariableLifecycle<T> rv)
ThreadPoolExecutor	getThreadPool(com.netflix.hystrix.HystrixThreadPoolKey threadPoolKey, com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> corePoolSize, com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> maximumPoolSize, com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
ThreadPoolExecutor	getThreadPool(com.netflix.hystrix.HystrixThreadPoolKey threadPoolKey, com.netflix.hystrix.HystrixThreadPoolProperties threadPoolProperties)
<T> Callable<T>	wrapCallable(Callable<T> callable)

Methods inherited from class java.lang.Object

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

Constructor Detail

TracingHystrixConcurrentStrategy

@Inject
public TracingHystrixConcurrentStrategy(io.opentracing.Tracer tracer,
                                                @Nullable
                                                com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy hystrixConcurrencyStrategy)

Creates enhanced HystrixConcurrencyStrategy for tracing.

Parameters:

tracer - For span creation and propagation across arbitrary transports

hystrixConcurrencyStrategy - Different behavior or implementations for concurrency related aspects of the system with default implementations

Method Detail

getThreadPool

public ThreadPoolExecutor getThreadPool(com.netflix.hystrix.HystrixThreadPoolKey threadPoolKey,
                                        com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> corePoolSize,
                                        com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> maximumPoolSize,
                                        com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> keepAliveTime,
                                        TimeUnit unit,
                                        BlockingQueue<Runnable> workQueue)

Overrides:

getThreadPool in class com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

getThreadPool

public ThreadPoolExecutor getThreadPool(com.netflix.hystrix.HystrixThreadPoolKey threadPoolKey,
                                        com.netflix.hystrix.HystrixThreadPoolProperties threadPoolProperties)

Overrides:

getThreadPool in class com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

getBlockingQueue

public BlockingQueue<Runnable> getBlockingQueue(int maxQueueSize)

Overrides:

getBlockingQueue in class com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

wrapCallable

public <T> Callable<T> wrapCallable(Callable<T> callable)

Overrides:

wrapCallable in class com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

getRequestVariable

public <T> com.netflix.hystrix.strategy.concurrency.HystrixRequestVariable<T> getRequestVariable(com.netflix.hystrix.strategy.concurrency.HystrixRequestVariableLifecycle<T> rv)

Overrides:

getRequestVariable in class com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy