reactor.netty.http.observability

Class ReactorNettyHttpClientTracingObservationHandler

java.lang.Object

io.micrometer.tracing.handler.HttpClientTracingObservationHandler

reactor.netty.http.observability.ReactorNettyHttpClientTracingObservationHandler

All Implemented Interfaces:

io.micrometer.observation.ObservationHandler<io.micrometer.observation.transport.http.context.HttpClientContext>, io.micrometer.tracing.handler.TracingObservationHandler<io.micrometer.observation.transport.http.context.HttpClientContext>

public final class ReactorNettyHttpClientTracingObservationHandler
extends io.micrometer.tracing.handler.HttpClientTracingObservationHandler

Reactor Netty specific HttpClientTracingObservationHandler

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
ReactorNettyHttpClientTracingObservationHandler(io.micrometer.tracing.Tracer tracer, io.micrometer.tracing.http.HttpClientHandler handler) Creates a new instance of HttpClientTracingObservationHandler.

Method Summary

Modifier and Type	Method and Description
void	onError(CTX arg0)
void	onStart(CTX arg0)
void	onStop(CTX arg0)
boolean	supportsContext(io.micrometer.observation.Observation.Context context)
void	tagSpan(io.micrometer.observation.transport.http.context.HttpClientContext context, io.micrometer.tracing.Span span)

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

getSpanName

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

getRequiredSpan, getTracingContext, onError, onScopeClosed, onScopeOpened

Methods inherited from interface io.micrometer.observation.ObservationHandler

onStart, onStop

Constructor Detail

ReactorNettyHttpClientTracingObservationHandler

public ReactorNettyHttpClientTracingObservationHandler(io.micrometer.tracing.Tracer tracer,
                                                       io.micrometer.tracing.http.HttpClientHandler handler)

Creates a new instance of HttpClientTracingObservationHandler.

Parameters:

tracer - tracer

handler - http client handler

Method Detail

tagSpan

public void tagSpan(io.micrometer.observation.transport.http.context.HttpClientContext 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.http.context.HttpClientContext>

Specified by:

supportsContext in interface io.micrometer.tracing.handler.TracingObservationHandler<io.micrometer.observation.transport.http.context.HttpClientContext>

Overrides:

supportsContext in class io.micrometer.tracing.handler.HttpClientTracingObservationHandler

onStart

public void onStart(CTX arg0)

Specified by:

onStart in interface io.micrometer.observation.ObservationHandler<CTX extends io.micrometer.observation.transport.http.context.HttpContext>

onError

public void onError(CTX arg0)

Specified by:

onError in interface io.micrometer.observation.ObservationHandler<CTX extends io.micrometer.observation.transport.http.context.HttpContext>

Specified by:

onError in interface io.micrometer.tracing.handler.TracingObservationHandler<CTX extends io.micrometer.observation.transport.http.context.HttpContext>

onStop

public void onStop(CTX arg0)

Specified by:

onStop in interface io.micrometer.observation.ObservationHandler<CTX extends io.micrometer.observation.transport.http.context.HttpContext>