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

An HttpMetricsRecorder implementation for integration with Micrometer.

Since:

0.9

Author:

Violeta Georgieva

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<MeterKey,io.micrometer.core.instrument.Timer>	dataReceivedTimeCache
protected ConcurrentMap<MeterKey,io.micrometer.core.instrument.Timer>	dataSentTimeCache
protected ConcurrentMap<MeterKey,io.micrometer.core.instrument.Timer>	responseTimeCache

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MicrometerHttpMetricsRecorder(String name, 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

filter, getResolveAddressTimer, getTlsHandshakeTimer, incrementErrorsCount, name, protocol, recordConnectTime, recordDataReceived, recordDataSent, recordResolveAddressTime, recordServerConnectionClosed, recordServerConnectionOpened, 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, recordConnectTime, recordDataReceived, recordDataSent, recordResolveAddressTime, recordServerConnectionClosed, recordServerConnectionOpened, recordTlsHandshakeTime

Field Detail

dataReceivedTimeCache

protected final ConcurrentMap<MeterKey,io.micrometer.core.instrument.Timer> dataReceivedTimeCache

dataSentTimeCache

protected final ConcurrentMap<MeterKey,io.micrometer.core.instrument.Timer> dataSentTimeCache

responseTimeCache

protected final ConcurrentMap<MeterKey,io.micrometer.core.instrument.Timer> responseTimeCache

Constructor Detail

MicrometerHttpMetricsRecorder

protected MicrometerHttpMetricsRecorder(String name,
                                        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