reactor.netty.http.client

Class ContextAwareHttpClientMetricsRecorder

java.lang.Object

reactor.netty.channel.ContextAwareChannelMetricsRecorder

reactor.netty.http.ContextAwareHttpMetricsRecorder

reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder

All Implemented Interfaces:

ChannelMetricsRecorder, HttpClientMetricsRecorder, HttpMetricsRecorder

public abstract class ContextAwareHttpClientMetricsRecorder
extends ContextAwareHttpMetricsRecorder
implements HttpClientMetricsRecorder

ContextView aware class for collecting metrics on HTTP client level.

Since:

1.0.8

Author:

Violeta Georgieva

Constructor Summary

Constructors

Constructor and Description
ContextAwareHttpClientMetricsRecorder()

Method Summary

Modifier and Type	Method and Description
void	incrementErrorsCount(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri) Increments the number of the errors that have occurred.
void	incrementErrorsCount(SocketAddress remoteAddress, SocketAddress proxyAddress, String uri) Increments the number of the errors that have occurred.
void	recordDataReceived(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, long bytes) Records the amount of the data that is received, in bytes.
void	recordDataReceived(SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, long bytes) Records the amount of the data that is received, in bytes.
void	recordDataReceivedTime(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, String method, String status, Duration time) Records the time that is spent in consuming incoming data.
abstract void	recordDataReceivedTime(ContextView contextView, SocketAddress remoteAddress, String uri, String method, String status, Duration time) Records the time that is spent in consuming incoming data.
void	recordDataReceivedTime(SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, String method, String status, Duration time) Records the time that is spent in consuming incoming data.
void	recordDataReceivedTime(SocketAddress remoteAddress, String uri, String method, String status, Duration time) Records the time that is spent in consuming incoming data.
void	recordDataSent(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, long bytes) Records the amount of the data that is sent, in bytes.
void	recordDataSent(SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, long bytes) Records the amount of the data that is sent, in bytes.
void	recordDataSentTime(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, String method, Duration time) Records the time that is spent in sending outgoing data.
abstract void	recordDataSentTime(ContextView contextView, SocketAddress remoteAddress, String uri, String method, Duration time) Records the time that is spent in sending outgoing data.
void	recordDataSentTime(SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, String method, Duration time) Records the time that is spent in sending outgoing data.
void	recordDataSentTime(SocketAddress remoteAddress, String uri, String method, Duration time) Records the time that is spent in sending outgoing data.
void	recordResponseTime(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, String method, String status, Duration time) Records the total time for the request/response.
abstract void	recordResponseTime(ContextView contextView, SocketAddress remoteAddress, String uri, String method, String status, Duration time) Records the total time for the request/response.
void	recordResponseTime(SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, String method, String status, Duration time) Records the total time for the request/response.
void	recordResponseTime(SocketAddress remoteAddress, String uri, String method, String status, Duration time) Records the total time for the request/response.

Methods inherited from class reactor.netty.http.ContextAwareHttpMetricsRecorder

incrementErrorsCount, incrementErrorsCount, recordDataReceived, recordDataReceived, recordDataSent, recordDataSent

Methods inherited from class reactor.netty.channel.ContextAwareChannelMetricsRecorder

incrementErrorsCount, incrementErrorsCount, incrementErrorsCount, incrementErrorsCount, recordConnectTime, recordConnectTime, recordConnectTime, recordConnectTime, recordDataReceived, recordDataReceived, recordDataReceived, recordDataReceived, recordDataSent, recordDataSent, recordDataSent, recordDataSent, recordTlsHandshakeTime, recordTlsHandshakeTime, 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.http.HttpMetricsRecorder

incrementErrorsCount, recordDataReceived, recordDataSent

Methods inherited from interface reactor.netty.channel.ChannelMetricsRecorder

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

Constructor Detail

ContextAwareHttpClientMetricsRecorder

public ContextAwareHttpClientMetricsRecorder()

Method Detail

recordDataReceivedTime

public abstract void recordDataReceivedTime(ContextView contextView,
                                            SocketAddress remoteAddress,
                                            String uri,
                                            String method,
                                            String status,
                                            Duration time)

Records the time that is spent in consuming incoming data.

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

uri - The requested URI

method - The HTTP method

status - The HTTP status

time - The time in nanoseconds that is spent in consuming incoming data

recordDataReceivedTime

public void recordDataReceivedTime(ContextView contextView,
                                   SocketAddress remoteAddress,
                                   SocketAddress proxyAddress,
                                   String uri,
                                   String method,
                                   String status,
                                   Duration time)

Records the time that is spent in consuming incoming data.

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - The requested URI

method - The HTTP method

status - The HTTP status

time - The time in nanoseconds that is spent in consuming incoming data

Since:

1.1.17

recordDataSentTime

public abstract void recordDataSentTime(ContextView contextView,
                                        SocketAddress remoteAddress,
                                        String uri,
                                        String method,
                                        Duration time)

Records the time that is spent in sending outgoing data.

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

uri - The requested URI

method - The HTTP method

time - The time in nanoseconds that is spent in sending outgoing data

recordDataSentTime

public void recordDataSentTime(ContextView contextView,
                               SocketAddress remoteAddress,
                               SocketAddress proxyAddress,
                               String uri,
                               String method,
                               Duration time)

Records the time that is spent in sending outgoing data.

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - The requested URI

method - The HTTP method

time - The time in nanoseconds that is spent in sending outgoing data

Since:

1.1.17

recordResponseTime

public abstract void recordResponseTime(ContextView contextView,
                                        SocketAddress remoteAddress,
                                        String uri,
                                        String method,
                                        String status,
                                        Duration time)

Records the total time for the request/response.

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

uri - The requested URI

method - The HTTP method

status - The HTTP status

time - The total time in nanoseconds for the request/response

recordResponseTime

public void recordResponseTime(ContextView contextView,
                               SocketAddress remoteAddress,
                               SocketAddress proxyAddress,
                               String uri,
                               String method,
                               String status,
                               Duration time)

Records the total time for the request/response.

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - The requested URI

method - The HTTP method

status - The HTTP status

time - The total time in nanoseconds for the request/response

Since:

1.1.17

incrementErrorsCount

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

Increments the number of the errors that have occurred.

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - The requested URI

Since:

1.1.17

recordDataReceived

public void recordDataReceived(ContextView contextView,
                               SocketAddress remoteAddress,
                               SocketAddress proxyAddress,
                               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

proxyAddress - the proxy address

uri - The requested URI

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

Since:

1.1.17

recordDataSent

public void recordDataSent(ContextView contextView,
                           SocketAddress remoteAddress,
                           SocketAddress proxyAddress,
                           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

proxyAddress - the proxy address

uri - The requested URI

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

Since:

1.1.17

recordDataReceivedTime

public void recordDataReceivedTime(SocketAddress remoteAddress,
                                   String uri,
                                   String method,
                                   String status,
                                   Duration time)

Description copied from interface: HttpClientMetricsRecorder

Records the time that is spent in consuming incoming data.

Specified by:

recordDataReceivedTime in interface HttpClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI

method - the HTTP method

status - the HTTP status

time - the time in nanoseconds that is spent in consuming incoming data

recordDataReceivedTime

public void recordDataReceivedTime(SocketAddress remoteAddress,
                                   SocketAddress proxyAddress,
                                   String uri,
                                   String method,
                                   String status,
                                   Duration time)

Description copied from interface: HttpClientMetricsRecorder

Records the time that is spent in consuming incoming data.

Specified by:

recordDataReceivedTime in interface HttpClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - the requested URI

method - the HTTP method

status - the HTTP status

time - the time in nanoseconds that is spent in consuming incoming data

recordDataSentTime

public void recordDataSentTime(SocketAddress remoteAddress,
                               String uri,
                               String method,
                               Duration time)

Description copied from interface: HttpClientMetricsRecorder

Records the time that is spent in sending outgoing data.

Specified by:

recordDataSentTime in interface HttpClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI

method - the HTTP method

time - the time in nanoseconds that is spent in sending outgoing data

recordDataSentTime

public void recordDataSentTime(SocketAddress remoteAddress,
                               SocketAddress proxyAddress,
                               String uri,
                               String method,
                               Duration time)

Description copied from interface: HttpClientMetricsRecorder

Records the time that is spent in sending outgoing data.

Specified by:

recordDataSentTime in interface HttpClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - the requested URI

method - the HTTP method

time - the time in nanoseconds that is spent in sending outgoing data

recordResponseTime

public void recordResponseTime(SocketAddress remoteAddress,
                               String uri,
                               String method,
                               String status,
                               Duration time)

Description copied from interface: HttpClientMetricsRecorder

Records the total time for the request/response.

Specified by:

recordResponseTime in interface HttpClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI

method - the HTTP method

status - the HTTP status

time - the total time in nanoseconds for the request/response

recordResponseTime

public void recordResponseTime(SocketAddress remoteAddress,
                               SocketAddress proxyAddress,
                               String uri,
                               String method,
                               String status,
                               Duration time)

Description copied from interface: HttpClientMetricsRecorder

Records the total time for the request/response.

Specified by:

recordResponseTime in interface HttpClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - the requested URI

method - the HTTP method

status - the HTTP status

time - the total time in nanoseconds for the request/response

recordDataReceived

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

Description copied from interface: HttpClientMetricsRecorder

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

Specified by:

recordDataReceived in interface HttpClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - the requested URI

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

recordDataSent

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

Description copied from interface: HttpClientMetricsRecorder

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

Specified by:

recordDataSent in interface HttpClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - the requested URI

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

incrementErrorsCount

public void incrementErrorsCount(SocketAddress remoteAddress,
                                 SocketAddress proxyAddress,
                                 String uri)

Description copied from interface: HttpClientMetricsRecorder

Increments the number of the errors that have occurred.

Specified by:

incrementErrorsCount in interface HttpClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - the requested URI