reactor.netty.http

Class ContextAwareHttpMetricsRecorder

java.lang.Object

reactor.netty.channel.ContextAwareChannelMetricsRecorder

reactor.netty.http.ContextAwareHttpMetricsRecorder

All Implemented Interfaces:

ChannelMetricsRecorder, HttpMetricsRecorder

Direct Known Subclasses:

ContextAwareHttpClientMetricsRecorder, ContextAwareHttpServerMetricsRecorder

public abstract class ContextAwareHttpMetricsRecorder
extends ContextAwareChannelMetricsRecorder
implements HttpMetricsRecorder

ContextView aware class for recording metrics for HTTP protocol.

Since:

1.0.8

Author:

Violeta Georgieva

Constructor Summary

Constructors

Constructor and Description
ContextAwareHttpMetricsRecorder()

Method Summary

Modifier and Type	Method and Description
abstract void	incrementErrorsCount(ContextView contextView, SocketAddress remoteAddress, String uri) Increments the number of the errors that are occurred
void	incrementErrorsCount(SocketAddress remoteAddress, String uri) Increments the number of the errors that are occurred
abstract void	recordDataReceived(ContextView contextView, SocketAddress remoteAddress, String uri, long bytes) Records the amount of the data that is received, in bytes
void	recordDataReceived(SocketAddress remoteAddress, String uri, long bytes) Records the amount of the data that is received, in bytes
abstract void	recordDataSent(ContextView contextView, SocketAddress remoteAddress, String uri, long bytes) Records the amount of the data that is sent, in bytes
void	recordDataSent(SocketAddress remoteAddress, String uri, long bytes) Records the amount of the data that is sent, in bytes

Methods inherited from class reactor.netty.channel.ContextAwareChannelMetricsRecorder

incrementErrorsCount, incrementErrorsCount, recordConnectTime, recordConnectTime, recordDataReceived, recordDataReceived, recordDataSent, recordDataSent, recordTlsHandshakeTime, recordTlsHandshakeTime

Methods inherited from class java.lang.Object

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

Methods inherited from interface reactor.netty.channel.ChannelMetricsRecorder

incrementErrorsCount, recordConnectTime, recordDataReceived, recordDataSent, recordResolveAddressTime, recordServerConnectionClosed, recordServerConnectionOpened, recordTlsHandshakeTime

Constructor Detail

ContextAwareHttpMetricsRecorder

public ContextAwareHttpMetricsRecorder()

Method Detail

incrementErrorsCount

public abstract void incrementErrorsCount(ContextView contextView,
                                          SocketAddress remoteAddress,
                                          String uri)

Increments the number of the errors that are occurred

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

uri - The requested URI

recordDataReceived

public abstract void recordDataReceived(ContextView contextView,
                                        SocketAddress remoteAddress,
                                        String uri,
                                        long bytes)

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

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

uri - The requested URI

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

recordDataSent

public abstract void recordDataSent(ContextView contextView,
                                    SocketAddress remoteAddress,
                                    String uri,
                                    long bytes)

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

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

uri - The requested URI

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

recordDataReceived

public void recordDataReceived(SocketAddress remoteAddress,
                               String uri,
                               long bytes)

Description copied from interface: HttpMetricsRecorder

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

Specified by:

recordDataReceived in interface HttpMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI

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

recordDataSent

public void recordDataSent(SocketAddress remoteAddress,
                           String uri,
                           long bytes)

Description copied from interface: HttpMetricsRecorder

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

Specified by:

recordDataSent in interface HttpMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI

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

incrementErrorsCount

public void incrementErrorsCount(SocketAddress remoteAddress,
                                 String uri)

Description copied from interface: HttpMetricsRecorder

Increments the number of the errors that are occurred

Specified by:

incrementErrorsCount in interface HttpMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI