reactor.netty.channel

Class MicrometerChannelMetricsRecorder

java.lang.Object

reactor.netty.channel.MicrometerChannelMetricsRecorder

All Implemented Interfaces:

ChannelMetricsRecorder

Direct Known Subclasses:

MicrometerHttpMetricsRecorder

public class MicrometerChannelMetricsRecorder
extends Object
implements ChannelMetricsRecorder

A ChannelMetricsRecorder implementation for integration with Micrometer.

Since:

0.9

Author:

Violeta Georgieva

Constructor Summary

Constructors

Constructor and Description
MicrometerChannelMetricsRecorder(String name, String protocol)

Method Summary

Modifier and Type	Method and Description
protected static <M extends io.micrometer.core.instrument.Meter> M	filter(M meter)
void	incrementErrorsCount(SocketAddress remoteAddress) Increments the number of the errors that are occurred
void	recordConnectTime(SocketAddress remoteAddress, java.time.Duration time, String status) Records the time that is spent for connecting to the remote address Relevant only when on the client
void	recordDataReceived(SocketAddress remoteAddress, long bytes) Records the amount of the data that is received, in bytes
void	recordDataSent(SocketAddress remoteAddress, long bytes) Records the amount of the data that is sent, in bytes
void	recordResolveAddressTime(SocketAddress remoteAddress, java.time.Duration time, String status) Records the time that is spent for resolving the remote address Relevant only when on the client
void	recordTlsHandshakeTime(SocketAddress remoteAddress, java.time.Duration time, String status) Records the time that is spent for TLS handshake

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MicrometerChannelMetricsRecorder

public MicrometerChannelMetricsRecorder(String name,
                                        String protocol)

Method Detail

recordDataReceived

public void recordDataReceived(SocketAddress remoteAddress,
                               long bytes)

Description copied from interface: ChannelMetricsRecorder

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

Specified by:

recordDataReceived in interface ChannelMetricsRecorder

Parameters:

remoteAddress - The remote peer

bytes - The amount of the data that is received, in bytes

recordDataSent

public void recordDataSent(SocketAddress remoteAddress,
                           long bytes)

Description copied from interface: ChannelMetricsRecorder

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

Specified by:

recordDataSent in interface ChannelMetricsRecorder

Parameters:

remoteAddress - The remote peer

bytes - The amount of the data that is sent, in bytes

incrementErrorsCount

public void incrementErrorsCount(SocketAddress remoteAddress)

Description copied from interface: ChannelMetricsRecorder

Increments the number of the errors that are occurred

Specified by:

incrementErrorsCount in interface ChannelMetricsRecorder

Parameters:

remoteAddress - The remote peer

recordTlsHandshakeTime

public void recordTlsHandshakeTime(SocketAddress remoteAddress,
                                   java.time.Duration time,
                                   String status)

Description copied from interface: ChannelMetricsRecorder

Records the time that is spent for TLS handshake

Specified by:

recordTlsHandshakeTime in interface ChannelMetricsRecorder

Parameters:

remoteAddress - The remote peer

time - the time in nanoseconds that is spent for TLS handshake

status - the status of the operation

recordConnectTime

public void recordConnectTime(SocketAddress remoteAddress,
                              java.time.Duration time,
                              String status)

Description copied from interface: ChannelMetricsRecorder

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

Specified by:

recordConnectTime in interface ChannelMetricsRecorder

Parameters:

remoteAddress - The remote peer

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

status - the status of the operation

recordResolveAddressTime

public void recordResolveAddressTime(SocketAddress remoteAddress,
                                     java.time.Duration time,
                                     String status)

Description copied from interface: ChannelMetricsRecorder

Records the time that is spent for resolving the remote address Relevant only when on the client

Specified by:

recordResolveAddressTime in interface ChannelMetricsRecorder

Parameters:

remoteAddress - The remote peer

time - the time in nanoseconds that is spent for resolving to the remote address

status - the status of the operation

filter

@Nullable
protected static <M extends io.micrometer.core.instrument.Meter> M filter(M meter)