reactor.netty.http.observability

Class ReactorNettyPropagatingReceiverTracingObservationHandler

java.lang.Object

io.micrometer.tracing.handler.PropagatingReceiverTracingObservationHandler<io.micrometer.observation.transport.ReceiverContext<HttpRequest>>

reactor.netty.http.observability.ReactorNettyPropagatingReceiverTracingObservationHandler

All Implemented Interfaces:

io.micrometer.observation.ObservationHandler<io.micrometer.observation.transport.ReceiverContext<HttpRequest>>, io.micrometer.tracing.handler.TracingObservationHandler<io.micrometer.observation.transport.ReceiverContext<HttpRequest>>

public final class ReactorNettyPropagatingReceiverTracingObservationHandler
extends io.micrometer.tracing.handler.PropagatingReceiverTracingObservationHandler<io.micrometer.observation.transport.ReceiverContext<HttpRequest>>

Reactor Netty specific PropagatingReceiverTracingObservationHandler.

Since:

1.1.0

Author:

Marcin Grzejszczak, Violeta Georgieva

Nested Class Summary

Nested classes/interfaces inherited from interface io.micrometer.tracing.handler.TracingObservationHandler

io.micrometer.tracing.handler.TracingObservationHandler.TracingContext

Nested classes/interfaces inherited from interface io.micrometer.observation.ObservationHandler

io.micrometer.observation.ObservationHandler.AllMatchingCompositeObservationHandler, io.micrometer.observation.ObservationHandler.CompositeObservationHandler, io.micrometer.observation.ObservationHandler.FirstMatchingCompositeObservationHandler

Constructor Summary

Constructors

Constructor and Description
ReactorNettyPropagatingReceiverTracingObservationHandler(io.micrometer.tracing.Tracer tracer, io.micrometer.tracing.propagation.Propagator propagator) Creates a new instance of ReactorNettyPropagatingReceiverTracingObservationHandler.

Method Summary

Modifier and Type	Method and Description
boolean	supportsContext(io.micrometer.observation.Observation.Context context)
void	tagSpan(io.micrometer.observation.transport.ReceiverContext<HttpRequest> context, io.micrometer.tracing.Span span)

Methods inherited from class io.micrometer.tracing.handler.PropagatingReceiverTracingObservationHandler

customizeExtractedSpan, customizeReceiverSpan, getTracer, onError, onStart, onStop

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micrometer.tracing.handler.TracingObservationHandler

endSpan, getParentSpan, getRequiredSpan, getSpanName, getTracingContext, onEvent, onScopeClosed, onScopeOpened, onScopeReset, setMaybeScopeOnTracingContext

Constructor Detail

ReactorNettyPropagatingReceiverTracingObservationHandler

public ReactorNettyPropagatingReceiverTracingObservationHandler(io.micrometer.tracing.Tracer tracer,
                                                                io.micrometer.tracing.propagation.Propagator propagator)

Creates a new instance of ReactorNettyPropagatingReceiverTracingObservationHandler.

Parameters:

tracer - tracer

propagator - tracing propagator

Method Detail

tagSpan

public void tagSpan(io.micrometer.observation.transport.ReceiverContext<HttpRequest> context,
                    io.micrometer.tracing.Span span)

supportsContext

public boolean supportsContext(io.micrometer.observation.Observation.Context context)

Specified by:

supportsContext in interface io.micrometer.observation.ObservationHandler<io.micrometer.observation.transport.ReceiverContext<HttpRequest>>

Specified by:

supportsContext in interface io.micrometer.tracing.handler.TracingObservationHandler<io.micrometer.observation.transport.ReceiverContext<HttpRequest>>

Overrides:

supportsContext in class io.micrometer.tracing.handler.PropagatingReceiverTracingObservationHandler<io.micrometer.observation.transport.ReceiverContext<HttpRequest>>