io.micronaut.tracing.instrument.util

Class TracingRunnableInstrumenter

java.lang.Object

io.micronaut.tracing.instrument.util.TracingRunnableInstrumenter

All Implemented Interfaces:

ReactiveInstrumenter, RunnableInstrumenter, Function<Runnable,Runnable>

@Singleton
 @Requires(beans=io.opentracing.Tracer.class) @Requires(beans=TracingWrapper.class)
public class TracingRunnableInstrumenter
extends Object
implements Function<Runnable,Runnable>, RunnableInstrumenter, ReactiveInstrumenter

A function that instruments an existing Runnable and Callable with TracingWrapper.

Since:

1.0

Author:

graemerocher, dstepanov

Constructor Summary

Constructors

Constructor and Description
TracingRunnableInstrumenter(io.opentracing.Tracer tracer, TracingWrapper tracingWrapper) Create a function that wraps an existing Runnable.

Method Summary

Modifier and Type	Method and Description
Runnable	apply(Runnable runnable)
Runnable	instrument(Runnable command) Implementors can override to instrument a Runnable.
Optional<RunnableInstrumenter>	newInstrumentation() An optional instrumentation.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

TracingRunnableInstrumenter

public TracingRunnableInstrumenter(io.opentracing.Tracer tracer,
                                   TracingWrapper tracingWrapper)

Create a function that wraps an existing Runnable.

Parameters:

tracer - For detecting tracing

tracingWrapper - For wrapping runnable

Method Detail

apply

public Runnable apply(Runnable runnable)

Specified by:

apply in interface Function<Runnable,Runnable>

instrument

public Runnable instrument(Runnable command)

Description copied from interface: RunnableInstrumenter

Implementors can override to instrument a Runnable.

Specified by:

instrument in interface RunnableInstrumenter

Parameters:

command - The command to instrument

Returns:

The instrumented runnable

newInstrumentation

public Optional<RunnableInstrumenter> newInstrumentation()

Description copied from interface: ReactiveInstrumenter

An optional instrumentation.

Specified by:

newInstrumentation in interface ReactiveInstrumenter

Returns:

An optional instrumentation.