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
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, String uri, String method, String status, Duration time) Records the time that is spent in consuming incoming 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, String uri, String method, Duration time) Records the time that is spent in sending outgoing data
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, 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, 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.http.HttpMetricsRecorder

incrementErrorsCount, recordDataReceived, recordDataSent

Methods inherited from interface reactor.netty.channel.ChannelMetricsRecorder

incrementErrorsCount, recordConnectTime, recordDataReceived, recordDataSent, recordResolveAddressTime, recordServerConnectionClosed, recordServerConnectionOpened, 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

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

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

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

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

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