Top Inners Fields Constructors Methods
reactor.netty5.http.client

pack-priv final Class MicrometerHttpClientMetricsHandler

extends AbstractHttpClientMetricsHandler
Class Inheritance
Imports
io.micrometer.common.KeyValues, io.micrometer.core.instrument.Timer, io.micrometer.observation.Observation, io.micrometer.observation.transport.RequestReplySenderContext, io.netty5.channel.Channel, io.netty5.handler.codec.http.HttpRequest, .HttpResponse, reactor.netty5.observability.ReactorNettyHandlerContext, reactor.util.annotation.Nullable, reactor.util.context.ContextView, java.net.InetSocketAddress, .SocketAddress, java.time.Duration, java.util.Objects, java.util.function.Function, .Supplier
Authors
Marcin Grzejszczak, Violeta Georgieva
Since
1.1.0

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
MicrometerHttpClientMetricsHandler.ResponseTimeHandlerContext

Requirements for HTTP clients

https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/trace/semantic_conventions/http.md#name The contextual name must be in the format 'HTTP <method>'

https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/trace/semantic_conventions/http.md#common-attributes

https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/trace/semantic_conventions/http.md#http-client

Field Summary

Modifier and TypeField and Description
pack-priv final MicrometerHttpClientMetricsRecorder
recorder

pack-priv MicrometerHttpClientMetricsHandler.ResponseTimeHandlerContext
responseTimeHandlerContext

pack-priv Observation
responseTimeObservation

Inherited from reactor.netty5.http.client.AbstractHttpClientMetricsHandler:
contextViewdataReceiveddataReceivedTimedataSentdataSentTimeflagsmethodpathREQUEST_SENTRESPONSE_RECEIVEDstatusuriTagValue

Constructor Summary

AccessConstructor and Description
pack-priv
MicrometerHttpClientMetricsHandler(MicrometerHttpClientMetricsRecorder recorder, Function<String, String> uriTagValue)

pack-priv
MicrometerHttpClientMetricsHandler(MicrometerHttpClientMetricsHandler copy)

Method Summary

Modifier and TypeMethod and Description
protected HttpClientMetricsRecorder
recorder()

Implements abstract reactor.netty5.http.client.AbstractHttpClientMetricsHandler.recorder.

protected void
recordRead(SocketAddress address)

Overrides reactor.netty5.http.client.AbstractHttpClientMetricsHandler.recordRead.

protected void
reset()

Overrides reactor.netty5.http.client.AbstractHttpClientMetricsHandler.reset.

protected void
startRead(HttpResponse msg)

Overrides reactor.netty5.http.client.AbstractHttpClientMetricsHandler.startRead.

protected void
startWrite(HttpRequest msg, Channel channel, ContextView contextView)

Overrides reactor.netty5.http.client.AbstractHttpClientMetricsHandler.startWrite.

Inherited from reactor.netty5.http.client.AbstractHttpClientMetricsHandler:
channelExceptionCaughtchannelReadrecordExceptionrecordWritewrite

Field Detail

recorderback to summary
pack-priv final MicrometerHttpClientMetricsRecorder recorder
responseTimeHandlerContextback to summary
pack-priv MicrometerHttpClientMetricsHandler.ResponseTimeHandlerContext responseTimeHandlerContext
responseTimeObservationback to summary
pack-priv Observation responseTimeObservation

Constructor Detail

MicrometerHttpClientMetricsHandlerback to summary
pack-priv MicrometerHttpClientMetricsHandler(MicrometerHttpClientMetricsRecorder recorder, Function<String, String> uriTagValue)
MicrometerHttpClientMetricsHandlerback to summary
pack-priv MicrometerHttpClientMetricsHandler(MicrometerHttpClientMetricsHandler copy)

Method Detail

recorderback to summary
protected HttpClientMetricsRecorder recorder()

Implements abstract reactor.netty5.http.client.AbstractHttpClientMetricsHandler.recorder.

Annotations
@Override
recordReadback to summary
protected void recordRead(SocketAddress address)

Overrides reactor.netty5.http.client.AbstractHttpClientMetricsHandler.recordRead.

Annotations
@Override
resetback to summary
protected void reset()

Overrides reactor.netty5.http.client.AbstractHttpClientMetricsHandler.reset.

Annotations
@Override
startReadback to summary
protected void startRead(HttpResponse msg)

Overrides reactor.netty5.http.client.AbstractHttpClientMetricsHandler.startRead.

Annotations
@Override
startWriteback to summary
protected void startWrite(HttpRequest msg, Channel channel, ContextView contextView)

Overrides reactor.netty5.http.client.AbstractHttpClientMetricsHandler.startWrite.

Annotations
@Override
reactor.netty5.http.client back to summary

pack-priv final Class MicrometerHttpClientMetricsHandler.ResponseTimeHandlerContext

extends RequestReplySenderContext<HttpRequest, HttpResponse>
implements ReactorNettyHandlerContext, Supplier<Observation.Context>
Class Inheritance
All Implemented Interfaces
java.util.function.Supplier, reactor.netty5.observability.ReactorNettyHandlerContext
Requirements for HTTP clients

https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/trace/semantic_conventions/http.md#name The contextual name must be in the format 'HTTP <method>'

https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/trace/semantic_conventions/http.md#common-attributes

https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/trace/semantic_conventions/http.md#http-client

Field Summary

Modifier and TypeField and Description
pack-priv static final String
HTTP_PREFIX

pack-priv final String
method

pack-priv final String
netPeerName

pack-priv final String
netPeerPort

pack-priv final String
path

pack-priv final MicrometerHttpClientMetricsRecorder
recorder

pack-priv String
status

pack-priv static final String
TYPE

Constructor Summary

AccessConstructor and Description
pack-priv
ResponseTimeHandlerContext(MicrometerHttpClientMetricsRecorder recorder, HttpRequest request, String path, SocketAddress remoteAddress)

Method Summary

Modifier and TypeMethod and Description
public Observation.Context
get()

Implements java.util.function.Supplier.get.

Gets a result.
public KeyValues
getHighCardinalityKeyValues()

Overrides io.micrometer.observation.Observation.Context.getHighCardinalityKeyValues.

Implements io.micrometer.observation.Observation.ContextView.getHighCardinalityKeyValues.

Returns high cardinality key values.
public KeyValues
getLowCardinalityKeyValues()

Overrides io.micrometer.observation.Observation.Context.getLowCardinalityKeyValues.

Implements io.micrometer.observation.Observation.ContextView.getLowCardinalityKeyValues.

Returns low cardinality key values.
public io.micrometer.core.instrument.Timer
getTimer()

Implements reactor.netty5.observability.ReactorNettyHandlerContext.getTimer.

Obtain the timer associated to this reactor netty context.
Inherited from io.micrometer.observation.transport.RequestReplySenderContext:
getResponsesetResponse

Field Detail

HTTP_PREFIXback to summary
pack-priv static final String HTTP_PREFIX
methodback to summary
pack-priv final String method
netPeerNameback to summary
pack-priv final String netPeerName
netPeerPortback to summary
pack-priv final String netPeerPort
pathback to summary
pack-priv final String path
recorderback to summary
pack-priv final MicrometerHttpClientMetricsRecorder recorder
statusback to summary
pack-priv String status
TYPEback to summary
pack-priv static final String TYPE

Constructor Detail

ResponseTimeHandlerContextback to summary
pack-priv ResponseTimeHandlerContext(MicrometerHttpClientMetricsRecorder recorder, HttpRequest request, String path, SocketAddress remoteAddress)

Method Detail

getback to summary
public Observation.Context get()

Implements java.util.function.Supplier.get.

Doc from java.util.function.Supplier.get.

Gets a result.

Returns:Observation.Context

a result

Annotations
@Override
getHighCardinalityKeyValuesback to summary
public KeyValues getHighCardinalityKeyValues()

Overrides io.micrometer.observation.Observation.Context.getHighCardinalityKeyValues.

Implements io.micrometer.observation.Observation.ContextView.getHighCardinalityKeyValues.

Doc from io.micrometer.observation.Observation.ContextView.getHighCardinalityKeyValues.

Returns high cardinality key values.

Returns:KeyValues

high cardinality key values

Annotations
@Override
getLowCardinalityKeyValuesback to summary
public KeyValues getLowCardinalityKeyValues()

Overrides io.micrometer.observation.Observation.Context.getLowCardinalityKeyValues.

Implements io.micrometer.observation.Observation.ContextView.getLowCardinalityKeyValues.

Doc from io.micrometer.observation.Observation.ContextView.getLowCardinalityKeyValues.

Returns low cardinality key values.

Returns:KeyValues

low cardinality key values

Annotations
@Override
getTimerback to summary
public io.micrometer.core.instrument.Timer getTimer()

Implements reactor.netty5.observability.ReactorNettyHandlerContext.getTimer.

Doc from reactor.netty5.observability.ReactorNettyHandlerContext.getTimer.

Obtain the timer associated to this reactor netty context.

Returns:io.micrometer.core.instrument.Timer

the current reactor netty handler context timer

Annotations
@Override