Package reactor.netty.http.client

Class ContextAwareWebSocketClientMetricsRecorder

java.lang.Object

reactor.netty.channel.ContextAwareChannelMetricsRecorder

reactor.netty.http.ContextAwareHttpMetricsRecorder

reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder

reactor.netty.http.client.ContextAwareWebSocketClientMetricsRecorder

All Implemented Interfaces:

ChannelMetricsRecorder, HttpClientMetricsRecorder, WebSocketClientMetricsRecorder, HttpMetricsRecorder

public abstract class ContextAwareWebSocketClientMetricsRecorder
extends ContextAwareHttpClientMetricsRecorder
implements WebSocketClientMetricsRecorder

ContextView aware class for collecting metrics on WebSocket client level.

Since:

1.3.7

Author:

LivingLikeKrillin

Constructor Summary

Constructors

Constructor	Description
ContextAwareWebSocketClientMetricsRecorder()

Method Summary

Modifier and Type	Method	Description
void	recordWebSocketConnectionDuration(SocketAddress remoteAddress, String uri, Duration time)	Records the duration of the WebSocket connection.
void	recordWebSocketConnectionDuration(SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, Duration time)	Records the duration of the WebSocket connection.
abstract void	recordWebSocketConnectionDuration(ContextView contextView, SocketAddress remoteAddress, String uri, Duration time)	Records the duration of the WebSocket connection.
void	recordWebSocketConnectionDuration(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, Duration time)	Records the duration of the WebSocket connection.
void	recordWebSocketHandshakeTime(SocketAddress remoteAddress, String uri, String status, Duration time)	Records the time that is spent for the WebSocket handshake.
void	recordWebSocketHandshakeTime(SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, String status, Duration time)	Records the time that is spent for the WebSocket handshake.
abstract void	recordWebSocketHandshakeTime(ContextView contextView, SocketAddress remoteAddress, String uri, String status, Duration time)	Records the time that is spent for the WebSocket handshake.
void	recordWebSocketHandshakeTime(ContextView contextView, SocketAddress remoteAddress, SocketAddress proxyAddress, String uri, String status, Duration time)	Records the time that is spent for the WebSocket handshake.

Methods inherited from class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder

incrementErrorsCount, incrementErrorsCount, recordDataReceived, recordDataReceived, recordDataReceivedTime, recordDataReceivedTime, recordDataReceivedTime, recordDataReceivedTime, recordDataSent, recordDataSent, recordDataSentTime, recordDataSentTime, recordDataSentTime, recordDataSentTime, recordResponseTime, recordResponseTime, recordResponseTime, recordResponseTime

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.client.HttpClientMetricsRecorder

incrementErrorsCount, recordDataReceived, recordDataReceivedTime, recordDataReceivedTime, recordDataSent, recordDataSentTime, recordDataSentTime, recordResponseTime, recordResponseTime

Methods inherited from interface reactor.netty.http.HttpMetricsRecorder

incrementErrorsCount, recordDataReceived, recordDataSent

Constructor Details

ContextAwareWebSocketClientMetricsRecorder

public ContextAwareWebSocketClientMetricsRecorder()

Method Details

recordWebSocketHandshakeTime

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

Records the time that is spent for the WebSocket handshake.

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

uri - the requested URI

status - the WebSocket handshake status

time - the time in nanoseconds that is spent for the handshake

recordWebSocketHandshakeTime

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

Records the time that is spent for the WebSocket handshake.

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - the requested URI

status - the WebSocket handshake status

time - the time in nanoseconds that is spent for the handshake

recordWebSocketHandshakeTime

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

Description copied from interface: WebSocketClientMetricsRecorder

Records the time that is spent for the WebSocket handshake.

Specified by:

recordWebSocketHandshakeTime in interface WebSocketClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI

status - the WebSocket handshake status

time - the time that is spent for the handshake

recordWebSocketHandshakeTime

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

Description copied from interface: WebSocketClientMetricsRecorder

Records the time that is spent for the WebSocket handshake.

Specified by:

recordWebSocketHandshakeTime in interface WebSocketClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - the requested URI

status - the WebSocket handshake status

time - the time that is spent for the handshake

recordWebSocketConnectionDuration

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

Records the duration of the WebSocket connection.

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

uri - the requested URI

time - the duration of the connection

recordWebSocketConnectionDuration

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

Records the duration of the WebSocket connection.

Parameters:

contextView - The current ContextView associated with the Mono/Flux

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - the requested URI

time - the duration of the connection

recordWebSocketConnectionDuration

public void recordWebSocketConnectionDuration(SocketAddress remoteAddress,
 String uri,
 Duration time)

Description copied from interface: WebSocketClientMetricsRecorder

Records the duration of the WebSocket connection.

Specified by:

recordWebSocketConnectionDuration in interface WebSocketClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI

time - the duration of the connection

recordWebSocketConnectionDuration

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

Description copied from interface: WebSocketClientMetricsRecorder

Records the duration of the WebSocket connection.

Specified by:

recordWebSocketConnectionDuration in interface WebSocketClientMetricsRecorder

Parameters:

remoteAddress - The remote peer

proxyAddress - the proxy address

uri - the requested URI

time - the duration of the connection