reactor.netty.http

Class MicrometerHttpMetricsRecorder

java.lang.Object

reactor.netty.channel.MicrometerChannelMetricsRecorder

reactor.netty.http.MicrometerHttpMetricsRecorder

All Implemented Interfaces:

ChannelMetricsRecorder, HttpMetricsRecorder

public class MicrometerHttpMetricsRecorder
extends MicrometerChannelMetricsRecorder
implements HttpMetricsRecorder

Field Summary

Fields

Modifier and Type	Field and Description
protected io.micrometer.core.instrument.Timer.Builder	dataReceivedTimeBuilder
protected io.micrometer.core.instrument.Timer.Builder	dataSentTimeBuilder
protected io.micrometer.core.instrument.Timer.Builder	responseTimeBuilder

Fields inherited from class reactor.netty.channel.MicrometerChannelMetricsRecorder

name, registry, remoteAddress

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MicrometerHttpMetricsRecorder(String name, String remoteAddress, String protocol)

Method Summary

Modifier and Type	Method and Description
void	incrementErrorsCount(SocketAddress remoteAddress, String uri) Increments the number of the errors that are occurred
void	recordDataReceived(SocketAddress remoteAddress, String uri, long bytes) Records the amount of the data that is received, in bytes
void	recordDataSent(SocketAddress remoteAddress, String uri, long bytes) Records the amount of the data that is sent, in bytes

Methods inherited from class reactor.netty.channel.MicrometerChannelMetricsRecorder

incrementErrorsCount, name, recordConnectTime, recordDataReceived, recordDataSent, recordResolveAddressTime, recordTlsHandshakeTime, registry, remoteAddress

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, recordConnectTime, recordDataReceived, recordDataSent, recordResolveAddressTime, recordTlsHandshakeTime

Field Detail

dataReceivedTimeBuilder

protected final io.micrometer.core.instrument.Timer.Builder dataReceivedTimeBuilder

dataSentTimeBuilder

protected final io.micrometer.core.instrument.Timer.Builder dataSentTimeBuilder

responseTimeBuilder

protected final io.micrometer.core.instrument.Timer.Builder responseTimeBuilder

Constructor Detail

MicrometerHttpMetricsRecorder

protected MicrometerHttpMetricsRecorder(String name,
                                        @Nullable
                                        String remoteAddress,
                                        String protocol)

Method Detail

recordDataReceived

public void recordDataReceived(SocketAddress remoteAddress,
                               String uri,
                               long bytes)

Description copied from interface: HttpMetricsRecorder

Records the amount of the data that is received, in bytes

Specified by:

recordDataReceived in interface HttpMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI

bytes - The amount of the data that is received, in bytes

recordDataSent

public void recordDataSent(SocketAddress remoteAddress,
                           String uri,
                           long bytes)

Description copied from interface: HttpMetricsRecorder

Records the amount of the data that is sent, in bytes

Specified by:

recordDataSent in interface HttpMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI

bytes - The amount of the data that is sent, in bytes

incrementErrorsCount

public void incrementErrorsCount(SocketAddress remoteAddress,
                                 String uri)

Description copied from interface: HttpMetricsRecorder

Increments the number of the errors that are occurred

Specified by:

incrementErrorsCount in interface HttpMetricsRecorder

Parameters:

remoteAddress - The remote peer

uri - the requested URI