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

pack-priv final Class MicrometerHttpServerMetricsHandler

extends AbstractHttpServerMetricsHandler
Class Inheritance
Imports
io.micrometer.common.KeyValues, io.micrometer.core.instrument.Timer, io.micrometer.observation.Observation, io.micrometer.observation.transport.RequestReplyReceiverContext, io.netty5.handler.codec.http.HttpRequest, .HttpResponse, reactor.netty5.observability.ReactorNettyHandlerContext, reactor.util.annotation.Nullable, java.net.InetSocketAddress, 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
MicrometerHttpServerMetricsHandler.ResponseTimeHandlerContext

Requirements for HTTP servers

https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/trace/api.md#span

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-server

Field Summary

Modifier and TypeField and Description
pack-priv final MicrometerHttpServerMetricsRecorder
recorder

pack-priv MicrometerHttpServerMetricsHandler.ResponseTimeHandlerContext
responseTimeHandlerContext

pack-priv final String
responseTimeName

pack-priv Observation
responseTimeObservation

Inherited from reactor.netty5.http.server.AbstractHttpServerMetricsHandler:
dataReceiveddataReceivedTimedataSentdataSentTimeuriTagValue

Constructor Summary

AccessConstructor and Description
pack-priv
MicrometerHttpServerMetricsHandler(MicrometerHttpServerMetricsRecorder recorder, Function<String, String> uriTagValue)

pack-priv
MicrometerHttpServerMetricsHandler(MicrometerHttpServerMetricsHandler copy)

Method Summary

Modifier and TypeMethod and Description
protected HttpServerMetricsRecorder
recorder()

Implements abstract reactor.netty5.http.server.AbstractHttpServerMetricsHandler.recorder.

protected void
recordWrite(HttpServerOperations ops, String path, String method, String status)

Overrides reactor.netty5.http.server.AbstractHttpServerMetricsHandler.recordWrite.

protected void
startRead(HttpServerOperations ops, String path, String method)

Overrides reactor.netty5.http.server.AbstractHttpServerMetricsHandler.startRead.

protected void
startWrite(HttpServerOperations ops, String path, String method, String status)

Overrides reactor.netty5.http.server.AbstractHttpServerMetricsHandler.startWrite.

Inherited from reactor.netty5.http.server.AbstractHttpServerMetricsHandler:
channelActivechannelExceptionCaughtchannelInactivechannelReadrecordActiveConnectionrecordClosedStreamrecordExceptionrecordInactiveConnectionrecordOpenStreamrecordReadwrite

Field Detail

recorderback to summary
pack-priv final MicrometerHttpServerMetricsRecorder recorder
responseTimeHandlerContextback to summary
pack-priv MicrometerHttpServerMetricsHandler.ResponseTimeHandlerContext responseTimeHandlerContext
responseTimeNameback to summary
pack-priv final String responseTimeName
responseTimeObservationback to summary
pack-priv Observation responseTimeObservation

Constructor Detail

MicrometerHttpServerMetricsHandlerback to summary
pack-priv MicrometerHttpServerMetricsHandler(MicrometerHttpServerMetricsRecorder recorder, Function<String, String> uriTagValue)
MicrometerHttpServerMetricsHandlerback to summary
pack-priv MicrometerHttpServerMetricsHandler(MicrometerHttpServerMetricsHandler copy)

Method Detail

recorderback to summary
protected HttpServerMetricsRecorder recorder()

Implements abstract reactor.netty5.http.server.AbstractHttpServerMetricsHandler.recorder.

Annotations
@Override
recordWriteback to summary
protected void recordWrite(HttpServerOperations ops, String path, String method, String status)

Overrides reactor.netty5.http.server.AbstractHttpServerMetricsHandler.recordWrite.

Annotations
@Override
startReadback to summary
protected void startRead(HttpServerOperations ops, String path, String method)

Overrides reactor.netty5.http.server.AbstractHttpServerMetricsHandler.startRead.

Annotations
@Override
startWriteback to summary
protected void startWrite(HttpServerOperations ops, String path, String method, String status)

Overrides reactor.netty5.http.server.AbstractHttpServerMetricsHandler.startWrite.

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

pack-priv final Class MicrometerHttpServerMetricsHandler.ResponseTimeHandlerContext

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

https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/trace/api.md#span

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-server

Field Summary

Modifier and TypeField and Description
pack-priv final String
method

pack-priv final String
netHostName

pack-priv final String
netHostPort

pack-priv final String
path

pack-priv final MicrometerHttpServerMetricsRecorder
recorder

pack-priv final String
scheme

pack-priv String
status

pack-priv static final String
TYPE

Constructor Summary

AccessConstructor and Description
pack-priv
ResponseTimeHandlerContext(MicrometerHttpServerMetricsRecorder recorder, String path, HttpServerOperations ops)

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.RequestReplyReceiverContext:
getResponsesetResponse

Field Detail

methodback to summary
pack-priv final String method
netHostNameback to summary
pack-priv final String netHostName
netHostPortback to summary
pack-priv final String netHostPort
pathback to summary
pack-priv final String path
recorderback to summary
pack-priv final MicrometerHttpServerMetricsRecorder recorder
schemeback to summary
pack-priv final String scheme
statusback to summary
pack-priv String status
TYPEback to summary
pack-priv static final String TYPE

Constructor Detail

ResponseTimeHandlerContextback to summary
pack-priv ResponseTimeHandlerContext(MicrometerHttpServerMetricsRecorder recorder, String path, HttpServerOperations ops)

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