Top Description Fields Constructors Methods
reactor.netty5.http

public Class MicrometerHttpMetricsRecorder

extends MicrometerChannelMetricsRecorder
implements HttpMetricsRecorder
Class Inheritance
All Implemented Interfaces
reactor.netty5.http.HttpMetricsRecorder, reactor.netty5.channel.ChannelMetricsRecorder
Known Direct Subclasses
reactor.netty5.http.client.MicrometerHttpClientMetricsRecorder, reactor.netty5.http.server.MicrometerHttpServerMetricsRecorder
Imports
io.micrometer.core.instrument.Counter, io.micrometer.core.instrument.DistributionSummary, io.micrometer.core.instrument.Timer, reactor.netty5.Metrics, reactor.netty5.channel.ChannelMeters, .MeterKey, .MicrometerChannelMetricsRecorder, reactor.netty5.internal.util.MapUtils, java.net.SocketAddress, java.util.concurrent.ConcurrentHashMap, .ConcurrentMap
An HttpMetricsRecorder implementation for integration with Micrometer.
Author
Violeta Georgieva
Since
0.9

Field Summary

Modifier and TypeField and Description
private final ConcurrentMap<MeterKey, io.micrometer.core.instrument.DistributionSummary>
dataReceivedCache

Hides reactor.netty5.channel.MicrometerChannelMetricsRecorder.dataReceivedCache.

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

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

Hides reactor.netty5.channel.MicrometerChannelMetricsRecorder.dataSentCache.

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

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

Hides reactor.netty5.channel.MicrometerChannelMetricsRecorder.errorsCache.

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

Constructor Summary

AccessConstructor and Description
protected
MicrometerHttpMetricsRecorder(String name, String protocol)

Method Summary

Modifier and TypeMethod and Description
public void
incrementErrorsCount(SocketAddress
The remote peer
remoteAddress, String
the requested URI
uri)

Implements reactor.netty5.http.HttpMetricsRecorder.incrementErrorsCount.

Increments the number of the errors that are occurred
public void
recordDataReceived(SocketAddress
The remote peer
remoteAddress, String
the requested URI
uri, long
The amount of the data that is received, in bytes
bytes)

Implements reactor.netty5.http.HttpMetricsRecorder.recordDataReceived.

Records the amount of the data that is received, in bytes
public void
recordDataSent(SocketAddress
The remote peer
remoteAddress, String
the requested URI
uri, long
The amount of the data that is sent, in bytes
bytes)

Implements reactor.netty5.http.HttpMetricsRecorder.recordDataSent.

Records the amount of the data that is sent, in bytes
Inherited from reactor.netty5.channel.MicrometerChannelMetricsRecorder:
filtergetResolveAddressTimergetTlsHandshakeTimerincrementErrorsCountnameprotocolrecordConnectTimerecordDataReceivedrecordDataSentrecordResolveAddressTimerecordServerConnectionClosedrecordServerConnectionOpenedrecordTlsHandshakeTime

Field Detail

dataReceivedCacheback to summary
private final ConcurrentMap<MeterKey, io.micrometer.core.instrument.DistributionSummary> dataReceivedCache

Hides reactor.netty5.channel.MicrometerChannelMetricsRecorder.dataReceivedCache.

dataReceivedTimeCacheback to summary
protected final ConcurrentMap<MeterKey, io.micrometer.core.instrument.Timer> dataReceivedTimeCache
dataSentCacheback to summary
private final ConcurrentMap<MeterKey, io.micrometer.core.instrument.DistributionSummary> dataSentCache

Hides reactor.netty5.channel.MicrometerChannelMetricsRecorder.dataSentCache.

dataSentTimeCacheback to summary
protected final ConcurrentMap<MeterKey, io.micrometer.core.instrument.Timer> dataSentTimeCache
errorsCacheback to summary
private final ConcurrentMap<MeterKey, io.micrometer.core.instrument.Counter> errorsCache

Hides reactor.netty5.channel.MicrometerChannelMetricsRecorder.errorsCache.

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

Constructor Detail

MicrometerHttpMetricsRecorderback to summary
protected MicrometerHttpMetricsRecorder(String name, String protocol)

Method Detail

incrementErrorsCountback to summary
public void incrementErrorsCount(SocketAddress remoteAddress, String uri)

Implements reactor.netty5.http.HttpMetricsRecorder.incrementErrorsCount.

Doc from reactor.netty5.http.HttpMetricsRecorder.incrementErrorsCount.

Increments the number of the errors that are occurred

Parameters
remoteAddress:SocketAddress

The remote peer

uri:String

the requested URI

Annotations
@Override
recordDataReceivedback to summary
public void recordDataReceived(SocketAddress remoteAddress, String uri, long bytes)

Implements reactor.netty5.http.HttpMetricsRecorder.recordDataReceived.

Doc from reactor.netty5.http.HttpMetricsRecorder.recordDataReceived.

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

Parameters
remoteAddress:SocketAddress

The remote peer

uri:String

the requested URI

bytes:long

The amount of the data that is received, in bytes

Annotations
@Override
recordDataSentback to summary
public void recordDataSent(SocketAddress remoteAddress, String uri, long bytes)

Implements reactor.netty5.http.HttpMetricsRecorder.recordDataSent.

Doc from reactor.netty5.http.HttpMetricsRecorder.recordDataSent.

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

Parameters
remoteAddress:SocketAddress

The remote peer

uri:String

the requested URI

bytes:long

The amount of the data that is sent, in bytes

Annotations
@Override