Top Description Inners Fields Constructors Methods
reactor.netty.channel

public final Class MicrometerChannelMetricsHandler

extends AbstractChannelMetricsHandler
Class Inheritance
Imports
io.micrometer.common.KeyValues, io.micrometer.core.instrument.Timer, io.micrometer.observation.Observation, io.netty.channel.ChannelHandler, .ChannelHandlerContext, .ChannelInboundHandler, .ChannelOutboundHandler, .ChannelPromise, io.netty.handler.ssl.SslHandler, reactor.netty.ReactorNetty, reactor.netty.observability.ReactorNettyHandlerContext, reactor.util.annotation.Nullable, reactor.util.context.ContextView, java.net.InetSocketAddress, .SocketAddress, java.util.function.Supplier
ChannelHandler for collecting metrics on protocol level. This class is based on ChannelMetricsHandler, but it utilizes Micrometer's Observation.
Authors
Marcin Grzejszczak, Violeta Georgieva
Since
1.1.0

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
MicrometerChannelMetricsHandler.ConnectMetricsHandler

pack-priv static class
MicrometerChannelMetricsHandler.TlsMetricsHandler

Field Summary

Modifier and TypeField and Description
pack-priv final MicrometerChannelMetricsRecorder
recorder

Inherited from reactor.netty.channel.AbstractChannelMetricsHandler:
channelOpenedonServerremoteAddress

Constructor Summary

AccessConstructor and Description
pack-priv
MicrometerChannelMetricsHandler(MicrometerChannelMetricsRecorder recorder, SocketAddress remoteAddress, boolean onServer)

Method Summary

Modifier and TypeMethod and Description
public ChannelHandler
connectMetricsHandler()

Implements abstract reactor.netty.channel.AbstractChannelMetricsHandler.connectMetricsHandler.

public MicrometerChannelMetricsRecorder
recorder()

Implements abstract reactor.netty.channel.AbstractChannelMetricsHandler.recorder.

public ChannelHandler
tlsMetricsHandler()

Implements abstract reactor.netty.channel.AbstractChannelMetricsHandler.tlsMetricsHandler.

Inherited from reactor.netty.channel.AbstractChannelMetricsHandler:
channelActivechannelInactivechannelReadchannelRegisteredexceptionCaughtrecordExceptionrecordReadrecordWritewrite