Top Description Inners Fields Constructors Methods
reactor.netty.channel

pack-priv final Class ContextAwareChannelMetricsHandler

extends AbstractChannelMetricsHandler
Class Inheritance
Imports
io.netty.channel.ChannelHandler, .ChannelHandlerContext, .ChannelOutboundHandlerAdapter, .ChannelPromise, reactor.netty.Connection, .ConnectionObserver, reactor.util.annotation.Nullable, reactor.util.context.ContextView, java.net.SocketAddress, java.time.Duration
AbstractChannelMetricsHandler that propagates ContextView.
Author
Violeta Georgieva
Since
1.0.8

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
ContextAwareChannelMetricsHandler.ContextAwareConnectMetricsHandler

pack-priv static class
ContextAwareChannelMetricsHandler.TlsMetricsHandler

Field Summary

Modifier and TypeField and Description
pack-priv final ContextAwareChannelMetricsRecorder
recorder

Inherited from reactor.netty.channel.AbstractChannelMetricsHandler:
channelOpenedonServerremoteAddress

Constructor Summary

AccessConstructor and Description
pack-priv
ContextAwareChannelMetricsHandler(ContextAwareChannelMetricsRecorder recorder, SocketAddress remoteAddress, boolean onServer)

Method Summary

Modifier and TypeMethod and Description
public ChannelHandler
connectMetricsHandler()

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

public ContextAwareChannelMetricsRecorder
recorder()

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

protected void
recordException(ChannelHandlerContext ctx, SocketAddress address)

Overrides reactor.netty.channel.AbstractChannelMetricsHandler.recordException.

protected void
recordRead(ChannelHandlerContext ctx, SocketAddress address, long bytes)

Overrides reactor.netty.channel.AbstractChannelMetricsHandler.recordRead.

protected void
recordWrite(ChannelHandlerContext ctx, SocketAddress address, long bytes)

Overrides reactor.netty.channel.AbstractChannelMetricsHandler.recordWrite.

public ChannelHandler
tlsMetricsHandler()

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

Inherited from reactor.netty.channel.AbstractChannelMetricsHandler:
channelActivechannelInactivechannelReadchannelRegisteredexceptionCaughtwrite

Field Detail

recorderback to summary
pack-priv final ContextAwareChannelMetricsRecorder recorder

Constructor Detail

ContextAwareChannelMetricsHandlerback to summary
pack-priv ContextAwareChannelMetricsHandler(ContextAwareChannelMetricsRecorder recorder, SocketAddress remoteAddress, boolean onServer)

Method Detail

connectMetricsHandlerback to summary
public ChannelHandler connectMetricsHandler()

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

Annotations
@Override
recorderback to summary
public ContextAwareChannelMetricsRecorder recorder()

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

Annotations
@Override
recordExceptionback to summary
protected void recordException(ChannelHandlerContext ctx, SocketAddress address)

Overrides reactor.netty.channel.AbstractChannelMetricsHandler.recordException.

Annotations
@Override
recordReadback to summary
protected void recordRead(ChannelHandlerContext ctx, SocketAddress address, long bytes)

Overrides reactor.netty.channel.AbstractChannelMetricsHandler.recordRead.

Annotations
@Override
recordWriteback to summary
protected void recordWrite(ChannelHandlerContext ctx, SocketAddress address, long bytes)

Overrides reactor.netty.channel.AbstractChannelMetricsHandler.recordWrite.

Annotations
@Override
tlsMetricsHandlerback to summary
public ChannelHandler tlsMetricsHandler()

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

Annotations
@Override
reactor.netty.channel back to summary

pack-priv final Class ContextAwareChannelMetricsHandler.ContextAwareConnectMetricsHandler

extends ChannelOutboundHandlerAdapter
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final ContextAwareChannelMetricsRecorder
recorder

Constructor Summary

AccessConstructor and Description
pack-priv
ContextAwareConnectMetricsHandler(ContextAwareChannelMetricsRecorder recorder)

Method Summary

Modifier and TypeMethod and Description
public 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, ChannelPromise
the ChannelPromise to notify once the operation completes
promise)

Overrides io.netty.channel.ChannelOutboundHandlerAdapter.connect.

Implements io.netty.channel.ChannelOutboundHandler.connect.

Calls ChannelHandlerContext#connect(SocketAddress, SocketAddress, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline.
pack-priv void
recordConnectTime(ChannelHandlerContext ctx, SocketAddress address, long connectTimeStart, String status)

Inherited from io.netty.channel.ChannelOutboundHandlerAdapter:
bindclosederegisterdisconnectflushreadwrite

Field Detail

recorderback to summary
pack-priv final ContextAwareChannelMetricsRecorder recorder

Constructor Detail

ContextAwareConnectMetricsHandlerback to summary
pack-priv ContextAwareConnectMetricsHandler(ContextAwareChannelMetricsRecorder recorder)

Method Detail

connectback to summary
public void connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) throws Exception

Overrides io.netty.channel.ChannelOutboundHandlerAdapter.connect.

Implements io.netty.channel.ChannelOutboundHandler.connect.

Doc from io.netty.channel.ChannelOutboundHandlerAdapter.connect.

Calls ChannelHandlerContext#connect(SocketAddress, SocketAddress, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Parameters
ctx:ChannelHandlerContext

Doc from io.netty.channel.ChannelOutboundHandler.connect.

the ChannelHandlerContext for which the connect operation is made

remoteAddress:SocketAddress

Doc from io.netty.channel.ChannelOutboundHandler.connect.

the SocketAddress to which it should connect

localAddress:SocketAddress

Doc from io.netty.channel.ChannelOutboundHandler.connect.

the SocketAddress which is used as source on connect

promise:ChannelPromise

Doc from io.netty.channel.ChannelOutboundHandler.connect.

the ChannelPromise to notify once the operation completes

Annotations
@Override
Exceptions
Exception:

Doc from io.netty.channel.ChannelOutboundHandler.connect.

thrown if an error occurs

recordConnectTimeback to summary
pack-priv void recordConnectTime(ChannelHandlerContext ctx, SocketAddress address, long connectTimeStart, String status)
reactor.netty.channel back to summary

pack-priv final Class ContextAwareChannelMetricsHandler.TlsMetricsHandler

extends TlsMetricsHandler
Class Inheritance

Field Summary

Inherited from reactor.netty.channel.ChannelMetricsHandler.TlsMetricsHandler:
listenerAddedrecorder

Constructor Summary

AccessConstructor and Description
pack-priv
TlsMetricsHandler(ContextAwareChannelMetricsRecorder recorder)

Method Summary

Modifier and TypeMethod and Description
protected void
recordTlsHandshakeTime(ChannelHandlerContext ctx, long tlsHandshakeTimeStart, String status)

Overrides reactor.netty.channel.ChannelMetricsHandler.TlsMetricsHandler.recordTlsHandshakeTime.

Inherited from reactor.netty.channel.ChannelMetricsHandler.TlsMetricsHandler:
channelActiveuserEventTriggered

Constructor Detail

TlsMetricsHandlerback to summary
pack-priv TlsMetricsHandler(ContextAwareChannelMetricsRecorder recorder)

Method Detail

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

Overrides reactor.netty.channel.ChannelMetricsHandler.TlsMetricsHandler.recordTlsHandshakeTime.

Annotations
@Override