Top Description Constructors Methods
reactor.netty.http.client

public abstract Class ContextAwareHttpClientMetricsRecorder

extends ContextAwareHttpMetricsRecorder
implements HttpClientMetricsRecorder
Class Inheritance
All Implemented Interfaces
reactor.netty.http.client.HttpClientMetricsRecorder, reactor.netty.http.HttpMetricsRecorder, reactor.netty.channel.ChannelMetricsRecorder
Imports
reactor.netty.http.ContextAwareHttpMetricsRecorder, reactor.util.context.Context, .ContextView, java.net.SocketAddress, java.time.Duration

ContextView aware class for collecting metrics on HTTP client level.
Author
Violeta Georgieva
Since
1.0.8

Constructor Summary

AccessConstructor and Description
public

Method Summary

Modifier and TypeMethod and Description
public abstract void
recordDataReceivedTime(ContextView
The current ContextView associated with the Mono/Flux
contextView
,
SocketAddress
The remote peer
remoteAddress
,
String
The requested URI
uri
,
String
The HTTP method
method
,
String
The HTTP status
status
,
Duration
The time in nanoseconds that is spent in consuming incoming data
time
)

Records the time that is spent in consuming incoming data.

public void
recordDataReceivedTime(SocketAddress
The remote peer
remoteAddress
,
String
the requested URI
uri
,
String
the HTTP method
method
,
String
the HTTP status
status
,
Duration
the time in nanoseconds that is spent in consuming incoming data
time
)

Implements reactor.netty.http.client.HttpClientMetricsRecorder.recordDataReceivedTime.

Records the time that is spent in consuming incoming data.
public abstract void
recordDataSentTime(ContextView
The current ContextView associated with the Mono/Flux
contextView
,
SocketAddress
The remote peer
remoteAddress
,
String
The requested URI
uri
,
String
The HTTP method
method
,
Duration
The time in nanoseconds that is spent in sending outgoing data
time
)

Records the time that is spent in sending outgoing data.

public void
recordDataSentTime(SocketAddress
The remote peer
remoteAddress
,
String
the requested URI
uri
,
String
the HTTP method
method
,
Duration
the time in nanoseconds that is spent in sending outgoing data
time
)

Implements reactor.netty.http.client.HttpClientMetricsRecorder.recordDataSentTime.

Records the time that is spent in sending outgoing data.
public abstract void
recordResponseTime(ContextView
The current ContextView associated with the Mono/Flux
contextView
,
SocketAddress
The remote peer
remoteAddress
,
String
The requested URI
uri
,
String
The HTTP method
method
,
String
The HTTP status
status
,
Duration
The total time in nanoseconds for the request/response
time
)

Records the total time for the request/response.

public void
recordResponseTime(SocketAddress
The remote peer
remoteAddress
,
String
the requested URI
uri
,
String
the HTTP method
method
,
String
the HTTP status
status
,
Duration
the total time in nanoseconds for the request/response
time
)

Implements reactor.netty.http.client.HttpClientMetricsRecorder.recordResponseTime.

Records the total time for the request/response.
Inherited from reactor.netty.http.ContextAwareHttpMetricsRecorder:
incrementErrorsCountincrementErrorsCountrecordDataReceivedrecordDataReceivedrecordDataSentrecordDataSent

Constructor Detail

ContextAwareHttpClientMetricsRecorderback to summary
public ContextAwareHttpClientMetricsRecorder()

Method Detail

recordDataReceivedTimeback to summary
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:ContextView

The current ContextView associated with the Mono/Flux

remoteAddress:SocketAddress

The remote peer

uri:String

The requested URI

method:String

The HTTP method

status:String

The HTTP status

time:Duration

The time in nanoseconds that is spent in consuming incoming data

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

Implements reactor.netty.http.client.HttpClientMetricsRecorder.recordDataReceivedTime.

Doc from reactor.netty.http.client.HttpClientMetricsRecorder.recordDataReceivedTime.

Records the time that is spent in consuming incoming data.

Parameters
remoteAddress:SocketAddress

The remote peer

uri:String

the requested URI

method:String

the HTTP method

status:String

the HTTP status

time:Duration

the time in nanoseconds that is spent in consuming incoming data

Annotations
@Override
recordDataSentTimeback to summary
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:ContextView

The current ContextView associated with the Mono/Flux

remoteAddress:SocketAddress

The remote peer

uri:String

The requested URI

method:String

The HTTP method

time:Duration

The time in nanoseconds that is spent in sending outgoing data

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

Implements reactor.netty.http.client.HttpClientMetricsRecorder.recordDataSentTime.

Doc from reactor.netty.http.client.HttpClientMetricsRecorder.recordDataSentTime.

Records the time that is spent in sending outgoing data.

Parameters
remoteAddress:SocketAddress

The remote peer

uri:String

the requested URI

method:String

the HTTP method

time:Duration

the time in nanoseconds that is spent in sending outgoing data

Annotations
@Override
recordResponseTimeback to summary
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:ContextView

The current ContextView associated with the Mono/Flux

remoteAddress:SocketAddress

The remote peer

uri:String

The requested URI

method:String

The HTTP method

status:String

The HTTP status

time:Duration

The total time in nanoseconds for the request/response

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

Implements reactor.netty.http.client.HttpClientMetricsRecorder.recordResponseTime.

Doc from reactor.netty.http.client.HttpClientMetricsRecorder.recordResponseTime.

Records the total time for the request/response.

Parameters
remoteAddress:SocketAddress

The remote peer

uri:String

the requested URI

method:String

the HTTP method

status:String

the HTTP status

time:Duration

the total time in nanoseconds for the request/response

Annotations
@Override