Package 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 -
Method Summary
Modifier and TypeMethodDescriptionvoid
incrementErrorsCount
(SocketAddress remoteAddress, SocketAddress proxyAddress, String uri) Increments the number of the errors that have occurred.void
incrementErrorsCount
(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri) Increments the number of the errors that have occurred.void
recordDataReceived
(SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, long bytes) Records the amount of the data that is received, in bytes.void
recordDataReceived
(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, long bytes) Records the amount of the data that is received, in bytes.void
recordDataReceivedTime
(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.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
(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, String method, String status, Duration time) Records the time that is spent in consuming incoming data.void
recordDataSent
(SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, long bytes) Records the amount of the data that is sent, in bytes.void
recordDataSent
(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, long bytes) Records the amount of the data that is sent, in bytes.void
recordDataSentTime
(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.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
(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, String method, Duration time) Records the time that is spent in sending outgoing data.void
recordResponseTime
(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.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
(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, 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.channel.ChannelMetricsRecorder
incrementErrorsCount, incrementErrorsCount, recordConnectTime, recordConnectTime, recordDataReceived, recordDataReceived, recordDataSent, recordDataSent, recordResolveAddressTime, recordServerConnectionClosed, recordServerConnectionOpened, recordTlsHandshakeTime, recordTlsHandshakeTime
Methods inherited from interface reactor.netty.http.HttpMetricsRecorder
incrementErrorsCount, recordDataReceived, recordDataSent
-
Constructor Details
-
ContextAwareHttpClientMetricsRecorder
public ContextAwareHttpClientMetricsRecorder()
-
-
Method Details
-
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 currentContextView
associated with the Mono/FluxremoteAddress
- The remote peeruri
- The requested URImethod
- The HTTP methodstatus
- The HTTP statustime
- 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 currentContextView
associated with the Mono/FluxremoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- The requested URImethod
- The HTTP methodstatus
- The HTTP statustime
- 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 currentContextView
associated with the Mono/FluxremoteAddress
- The remote peeruri
- The requested URImethod
- The HTTP methodtime
- 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 currentContextView
associated with the Mono/FluxremoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- The requested URImethod
- The HTTP methodtime
- 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 currentContextView
associated with the Mono/FluxremoteAddress
- The remote peeruri
- The requested URImethod
- The HTTP methodstatus
- The HTTP statustime
- 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 currentContextView
associated with the Mono/FluxremoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- The requested URImethod
- The HTTP methodstatus
- The HTTP statustime
- 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 currentContextView
associated with the Mono/FluxremoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- 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 currentContextView
associated with the Mono/FluxremoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- The requested URIbytes
- 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 currentContextView
associated with the Mono/FluxremoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- The requested URIbytes
- 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 interfaceHttpClientMetricsRecorder
- Parameters:
remoteAddress
- The remote peeruri
- the requested URImethod
- the HTTP methodstatus
- the HTTP statustime
- 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 interfaceHttpClientMetricsRecorder
- Parameters:
remoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- the requested URImethod
- the HTTP methodstatus
- the HTTP statustime
- 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 interfaceHttpClientMetricsRecorder
- Parameters:
remoteAddress
- The remote peeruri
- the requested URImethod
- the HTTP methodtime
- 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 interfaceHttpClientMetricsRecorder
- Parameters:
remoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- the requested URImethod
- the HTTP methodtime
- 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 interfaceHttpClientMetricsRecorder
- Parameters:
remoteAddress
- The remote peeruri
- the requested URImethod
- the HTTP methodstatus
- the HTTP statustime
- 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 interfaceHttpClientMetricsRecorder
- Parameters:
remoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- the requested URImethod
- the HTTP methodstatus
- the HTTP statustime
- 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 interfaceHttpClientMetricsRecorder
- Parameters:
remoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- the requested URIbytes
- 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 interfaceHttpClientMetricsRecorder
- Parameters:
remoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- the requested URIbytes
- 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 interfaceHttpClientMetricsRecorder
- Parameters:
remoteAddress
- The remote peerproxyAddress
- the proxy addressuri
- the requested URI
-