Top Description Inners Fields Constructors Methods
reactor.netty5.channel

public Class ChannelMetricsHandler

extends AbstractChannelMetricsHandler
Class Inheritance
Imports
io.netty5.channel.ChannelHandler, .ChannelHandlerAdapter, .ChannelHandlerContext, io.netty5.handler.ssl.SslHandler, io.netty5.util.concurrent.Future, reactor.util.annotation.Nullable, java.net.SocketAddress, java.time.Duration
ChannelHandler for collecting metrics on protocol level.
Author
Violeta Georgieva

Nested and Inner Type Summary

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

pack-priv static class
ChannelMetricsHandler.TlsMetricsHandler

Field Summary

Modifier and TypeField and Description
pack-priv final ChannelMetricsRecorder
recorder

Inherited from reactor.netty5.channel.AbstractChannelMetricsHandler:
onServerremoteAddress

Constructor Summary

AccessConstructor and Description
pack-priv
ChannelMetricsHandler(ChannelMetricsRecorder recorder, SocketAddress remoteAddress, boolean onServer)

Method Summary

Modifier and TypeMethod and Description
public ChannelHandler
connectMetricsHandler()

Implements abstract reactor.netty5.channel.AbstractChannelMetricsHandler.connectMetricsHandler.

public ChannelMetricsRecorder
recorder()

Implements abstract reactor.netty5.channel.AbstractChannelMetricsHandler.recorder.

public ChannelHandler
tlsMetricsHandler()

Implements abstract reactor.netty5.channel.AbstractChannelMetricsHandler.tlsMetricsHandler.

Inherited from reactor.netty5.channel.AbstractChannelMetricsHandler:
channelActivechannelExceptionCaughtchannelInactivechannelReadchannelRegisteredrecordExceptionrecordReadrecordWritewrite

Field Detail

recorderback to summary
pack-priv final ChannelMetricsRecorder recorder

Constructor Detail

ChannelMetricsHandlerback to summary
pack-priv ChannelMetricsHandler(ChannelMetricsRecorder recorder, SocketAddress remoteAddress, boolean onServer)

Method Detail

connectMetricsHandlerback to summary
public ChannelHandler connectMetricsHandler()

Implements abstract reactor.netty5.channel.AbstractChannelMetricsHandler.connectMetricsHandler.

Annotations
@Override
recorderback to summary
public ChannelMetricsRecorder recorder()

Implements abstract reactor.netty5.channel.AbstractChannelMetricsHandler.recorder.

Annotations
@Override
tlsMetricsHandlerback to summary
public ChannelHandler tlsMetricsHandler()

Implements abstract reactor.netty5.channel.AbstractChannelMetricsHandler.tlsMetricsHandler.

Annotations
@Override
reactor.netty5.channel back to summary

pack-priv final Class ChannelMetricsHandler.ConnectMetricsHandler

extends ChannelHandlerAdapter
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final ChannelMetricsRecorder
recorder

Constructor Summary

AccessConstructor and Description
pack-priv
ConnectMetricsHandler(ChannelMetricsRecorder recorder)

Method Summary

Modifier and TypeMethod and Description
public Future<Void>
connect(ChannelHandlerContext
the ChannelHandlerContext for which the connect operation is made
ctx, SocketAddress
the SocketAddress to which it should connect
remoteAddress, SocketAddress
the SocketAddress which is used as source on connect
localAddress)

Overrides default io.netty5.channel.ChannelHandler.connect.

Called once a connect operation is made.

Field Detail

recorderback to summary
pack-priv final ChannelMetricsRecorder recorder

Constructor Detail

ConnectMetricsHandlerback to summary
pack-priv ConnectMetricsHandler(ChannelMetricsRecorder recorder)

Method Detail

connectback to summary
public Future<Void> connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress)

Overrides default io.netty5.channel.ChannelHandler.connect.

Doc from io.netty5.channel.ChannelHandler.connect.

Called once a connect operation is made.

Parameters
ctx:ChannelHandlerContext

the ChannelHandlerContext for which the connect operation is made

remoteAddress:SocketAddress

the SocketAddress to which it should connect

localAddress:SocketAddress

the SocketAddress which is used as source on connect

Returns:Future<Void>

the Future which will be notified once the operation completes.

Annotations
@Override
reactor.netty5.channel back to summary

pack-priv Class ChannelMetricsHandler.TlsMetricsHandler

extends ChannelHandlerAdapter
Class Inheritance
Known Direct Subclasses
reactor.netty5.channel.ContextAwareChannelMetricsHandler.TlsMetricsHandler

Field Summary

Modifier and TypeField and Description
protected final ChannelMetricsRecorder
recorder

Constructor Summary

AccessConstructor and Description
pack-priv
TlsMetricsHandler(ChannelMetricsRecorder recorder)

Method Summary

Modifier and TypeMethod and Description
public void
channelActive(ChannelHandlerContext ctx)

Overrides default io.netty5.channel.ChannelHandler.channelActive.

The Channel of the ChannelHandlerContext is now active
protected void
recordTlsHandshakeTime(ChannelHandlerContext ctx, long tlsHandshakeTimeStart, String status)

Field Detail

recorderback to summary
protected final ChannelMetricsRecorder recorder

Constructor Detail

TlsMetricsHandlerback to summary
pack-priv TlsMetricsHandler(ChannelMetricsRecorder recorder)

Method Detail

channelActiveback to summary
public void channelActive(ChannelHandlerContext ctx)

Overrides default io.netty5.channel.ChannelHandler.channelActive.

Doc from io.netty5.channel.ChannelHandler.channelActive.

The Channel of the ChannelHandlerContext is now active

Annotations
@Override
recordTlsHandshakeTimeback to summary
protected void recordTlsHandshakeTime(ChannelHandlerContext ctx, long tlsHandshakeTimeStart, String status)