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 io.micrometer.core.instrument.DistributionSummary.Builder	dataReceivedBuilder
protected ConcurrentMap<MeterKey,io.micrometer.core.instrument.DistributionSummary>	dataReceivedCache
protected io.micrometer.core.instrument.Timer.Builder	dataReceivedTimeBuilder
protected ConcurrentMap<MeterKey,io.micrometer.core.instrument.Timer>	dataReceivedTimeCache
protected io.micrometer.core.instrument.DistributionSummary.Builder	dataSentBuilder
protected ConcurrentMap<MeterKey,io.micrometer.core.instrument.DistributionSummary>	dataSentCache
protected io.micrometer.core.instrument.Timer.Builder	dataSentTimeBuilder
protected ConcurrentMap<MeterKey,io.micrometer.core.instrument.Timer>	dataSentTimeCache
protected io.micrometer.core.instrument.Counter.Builder	errorsBuilder
protected ConcurrentMap<MeterKey,io.micrometer.core.instrument.Counter>	errorsCache
protected io.micrometer.core.instrument.Timer.Builder	responseTimeBuilder
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, incrementErrorsCount, recordConnectTime, recordDataReceived, recordDataSent, recordResolveAddressTime, 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, recordTlsHandshakeTime

Field Detail

dataReceivedTimeBuilder

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

dataReceivedTimeCache

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

dataSentTimeBuilder

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

dataSentTimeCache

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

responseTimeBuilder

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

responseTimeCache

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

dataReceivedBuilder

protected final io.micrometer.core.instrument.DistributionSummary.Builder dataReceivedBuilder

dataReceivedCache

protected final ConcurrentMap<MeterKey,io.micrometer.core.instrument.DistributionSummary> dataReceivedCache

dataSentBuilder

protected final io.micrometer.core.instrument.DistributionSummary.Builder dataSentBuilder

dataSentCache

protected final ConcurrentMap<MeterKey,io.micrometer.core.instrument.DistributionSummary> dataSentCache

errorsBuilder

protected final io.micrometer.core.instrument.Counter.Builder errorsBuilder

errorsCache

protected final ConcurrentMap<MeterKey,io.micrometer.core.instrument.Counter> errorsCache

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