Package reactor.netty.http.server

Class ContextAwareWebSocketServerMetricsRecorder

java.lang.Object

reactor.netty.channel.ContextAwareChannelMetricsRecorder

reactor.netty.http.ContextAwareHttpMetricsRecorder

reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder

reactor.netty.http.server.ContextAwareWebSocketServerMetricsRecorder

All Implemented Interfaces:

ChannelMetricsRecorder, HttpMetricsRecorder, HttpServerMetricsRecorder, WebSocketServerMetricsRecorder

public abstract class ContextAwareWebSocketServerMetricsRecorder
extends ContextAwareHttpServerMetricsRecorder
implements WebSocketServerMetricsRecorder

ContextView aware class for collecting metrics on WebSocket server level.

Since:

1.3.8

Author:

LivingLikeKrillin

Constructor Summary

Constructors

Constructor	Description
ContextAwareWebSocketServerMetricsRecorder()

Method Summary

Modifier and Type	Method	Description
void	recordWebSocketConnectionDuration(SocketAddress remoteAddress, 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	recordWebSocketHandshakeTime(SocketAddress remoteAddress, 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.

Methods inherited from class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder

recordDataReceivedTime, recordDataReceivedTime, recordDataSentTime, recordDataSentTime, 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.HttpMetricsRecorder

incrementErrorsCount, recordDataReceived, recordDataSent

Methods inherited from interface reactor.netty.http.server.HttpServerMetricsRecorder

recordDataReceivedTime, recordDataSentTime, recordResponseTime, recordServerConnectionActive, recordServerConnectionInactive, recordStreamClosed, recordStreamOpened

Constructor Details

ContextAwareWebSocketServerMetricsRecorder

public ContextAwareWebSocketServerMetricsRecorder()

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(SocketAddress remoteAddress,
 String uri,
 String status,
 Duration time)

Description copied from interface: WebSocketServerMetricsRecorder

Records the time that is spent for the WebSocket handshake.

Specified by:

recordWebSocketHandshakeTime in interface WebSocketServerMetricsRecorder

Parameters:

remoteAddress - The remote peer

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(SocketAddress remoteAddress,
 String uri,
 Duration time)

Description copied from interface: WebSocketServerMetricsRecorder

Records the duration of the WebSocket connection.

Specified by:

recordWebSocketConnectionDuration in interface WebSocketServerMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI

time - the duration of the connection