Top Description Constructors Methods
reactor.netty.channel

public abstract Class ContextAwareChannelMetricsRecorder

extends Object
implements ChannelMetricsRecorder
Class Inheritance
All Implemented Interfaces
reactor.netty.channel.ChannelMetricsRecorder
Imports
reactor.util.context.Context, .ContextView, java.net.SocketAddress, java.time.Duration

ContextView aware class for recording metrics on protocol level.
Author
Violeta Georgieva
Since
1.0.8

Constructor Summary

AccessConstructor and Description
public

Method Summary

Modifier and TypeMethod and Description
public abstract void
incrementErrorsCount(ContextView
The current ContextView associated with the Mono/Flux pipeline
contextView
,
SocketAddress
The remote peer
remoteAddress
)

Increments the number of the errors that are occurred.

public void
incrementErrorsCount(SocketAddress
The remote peer
remoteAddress
)

Implements reactor.netty.channel.ChannelMetricsRecorder.incrementErrorsCount.

Increments the number of the errors that are occurred.
public abstract void
recordConnectTime(ContextView
The current ContextView associated with the Mono/Flux pipeline
contextView
,
SocketAddress
The remote peer
remoteAddress
,
Duration
The time in nanoseconds that is spent for connecting to the remote address
time
,
String
The status of the operation
status
)

Records the time that is spent for connecting to the remote address.

public void
recordConnectTime(SocketAddress
The remote peer
remoteAddress
,
Duration
the time in nanoseconds that is spent for connecting to the remote address
time
,
String
the status of the operation
status
)

Implements reactor.netty.channel.ChannelMetricsRecorder.recordConnectTime.

Records the time that is spent for connecting to the remote address.
public abstract void
recordDataReceived(ContextView
The current ContextView associated with the Mono/Flux pipeline
contextView
,
SocketAddress
The remote peer
remoteAddress
,
long
The amount of the data that is received, in bytes
bytes
)

Records the amount of the data that is received, in bytes.

public void
recordDataReceived(SocketAddress
The remote peer
remoteAddress
,
long
The amount of the data that is received, in bytes
bytes
)

Implements reactor.netty.channel.ChannelMetricsRecorder.recordDataReceived.

Records the amount of the data that is received, in bytes.
public abstract void
recordDataSent(ContextView
The current ContextView associated with the Mono/Flux pipeline
contextView
,
SocketAddress
The remote peer
remoteAddress
,
long
The amount of the data that is sent, in bytes
bytes
)

Records the amount of the data that is sent, in bytes.

public void
recordDataSent(SocketAddress
The remote peer
remoteAddress
,
long
The amount of the data that is sent, in bytes
bytes
)

Implements reactor.netty.channel.ChannelMetricsRecorder.recordDataSent.

Records the amount of the data that is sent, in bytes.
public abstract void
recordTlsHandshakeTime(ContextView
The current ContextView associated with the Mono/Flux pipeline
contextView
,
SocketAddress
The remote peer
remoteAddress
,
Duration
The time in nanoseconds that is spent for TLS handshake
time
,
String
The status of the operation
status
)

Records the time that is spent for TLS handshake.

public void
recordTlsHandshakeTime(SocketAddress
The remote peer
remoteAddress
,
Duration
the time in nanoseconds that is spent for TLS handshake
time
,
String
the status of the operation
status
)

Implements reactor.netty.channel.ChannelMetricsRecorder.recordTlsHandshakeTime.

Records the time that is spent for TLS handshake.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

ContextAwareChannelMetricsRecorderback to summary
public ContextAwareChannelMetricsRecorder()

Method Detail

incrementErrorsCountback to summary
public abstract void incrementErrorsCount(ContextView contextView, SocketAddress remoteAddress)

Increments the number of the errors that are occurred.

Parameters
contextView:ContextView

The current ContextView associated with the Mono/Flux pipeline

remoteAddress:SocketAddress

The remote peer

incrementErrorsCountback to summary
public void incrementErrorsCount(SocketAddress remoteAddress)

Implements reactor.netty.channel.ChannelMetricsRecorder.incrementErrorsCount.

Doc from reactor.netty.channel.ChannelMetricsRecorder.incrementErrorsCount.

Increments the number of the errors that are occurred.

Parameters
remoteAddress:SocketAddress

The remote peer

Annotations
@Override
recordConnectTimeback to summary
public abstract void recordConnectTime(ContextView contextView, SocketAddress remoteAddress, Duration time, String status)

Records the time that is spent for connecting to the remote address. Relevant only when on the client.

Parameters
contextView:ContextView

The current ContextView associated with the Mono/Flux pipeline

remoteAddress:SocketAddress

The remote peer

time:Duration

The time in nanoseconds that is spent for connecting to the remote address

status:String

The status of the operation

recordConnectTimeback to summary
public void recordConnectTime(SocketAddress remoteAddress, Duration time, String status)

Implements reactor.netty.channel.ChannelMetricsRecorder.recordConnectTime.

Doc from reactor.netty.channel.ChannelMetricsRecorder.recordConnectTime.

Records the time that is spent for connecting to the remote address. Relevant only when on the client

Parameters
remoteAddress:SocketAddress

The remote peer

time:Duration

the time in nanoseconds that is spent for connecting to the remote address

status:String

the status of the operation

Annotations
@Override
recordDataReceivedback to summary
public abstract void recordDataReceived(ContextView contextView, SocketAddress remoteAddress, long bytes)

Records the amount of the data that is received, in bytes.

Parameters
contextView:ContextView

The current ContextView associated with the Mono/Flux pipeline

remoteAddress:SocketAddress

The remote peer

bytes:long

The amount of the data that is received, in bytes

recordDataReceivedback to summary
public void recordDataReceived(SocketAddress remoteAddress, long bytes)

Implements reactor.netty.channel.ChannelMetricsRecorder.recordDataReceived.

Doc from reactor.netty.channel.ChannelMetricsRecorder.recordDataReceived.

Records the amount of the data that is received, in bytes.

Parameters
remoteAddress:SocketAddress

The remote peer

bytes:long

The amount of the data that is received, in bytes

Annotations
@Override
recordDataSentback to summary
public abstract void recordDataSent(ContextView contextView, SocketAddress remoteAddress, long bytes)

Records the amount of the data that is sent, in bytes.

Parameters
contextView:ContextView

The current ContextView associated with the Mono/Flux pipeline

remoteAddress:SocketAddress

The remote peer

bytes:long

The amount of the data that is sent, in bytes

recordDataSentback to summary
public void recordDataSent(SocketAddress remoteAddress, long bytes)

Implements reactor.netty.channel.ChannelMetricsRecorder.recordDataSent.

Doc from reactor.netty.channel.ChannelMetricsRecorder.recordDataSent.

Records the amount of the data that is sent, in bytes.

Parameters
remoteAddress:SocketAddress

The remote peer

bytes:long

The amount of the data that is sent, in bytes

Annotations
@Override
recordTlsHandshakeTimeback to summary
public abstract void recordTlsHandshakeTime(ContextView contextView, SocketAddress remoteAddress, Duration time, String status)

Records the time that is spent for TLS handshake.

Parameters
contextView:ContextView

The current ContextView associated with the Mono/Flux pipeline

remoteAddress:SocketAddress

The remote peer

time:Duration

The time in nanoseconds that is spent for TLS handshake

status:String

The status of the operation

recordTlsHandshakeTimeback to summary
public void recordTlsHandshakeTime(SocketAddress remoteAddress, Duration time, String status)

Implements reactor.netty.channel.ChannelMetricsRecorder.recordTlsHandshakeTime.

Doc from reactor.netty.channel.ChannelMetricsRecorder.recordTlsHandshakeTime.

Records the time that is spent for TLS handshake.

Parameters
remoteAddress:SocketAddress

The remote peer

time:Duration

the time in nanoseconds that is spent for TLS handshake

status:String

the status of the operation

Annotations
@Override