Top Fields Constructors Methods

reactor.netty.http.client

pack-priv final Class MicrometerPoolMetricsRecorder

Class Inheritance

extends Object
implements Disposable, reactor.netty.internal.shaded.reactor.pool.PoolMetricsRecorder

java.lang.Object
reactor.netty.http.client.MicrometerPoolMetricsRecorder

All Implemented Interfaces

reactor.core.Disposable

Imports

io.micrometer.core.instrument.Tags, io.micrometer.core.instrument.Timer, reactor.core.Disposable, reactor.netty.internal.shaded.reactor.pool.PoolMetricsRecorder, java.net.SocketAddress, java.util.concurrent.TimeUnit

Field Summary

Modifier and Type	Field and Description
pack-priv final io.micrometer.core.instrument.Timer	pendingErrorTimer
pack-priv final io.micrometer.core.instrument.Timer	pendingSuccessTimer

Constructor Summary

Access	Constructor and Description
pack-priv	MicrometerPoolMetricsRecorder(String id, String poolName, SocketAddress remoteAddress)

Method Summary

Modifier and Type	Method and Description
pack-priv static io.micrometer.core.instrument.Timer	buildTimer(String id, String poolName, SocketAddress remoteAddress, String status)
public void	dispose() Implements reactor.core.Disposable.dispose. Cancel or dispose the underlying task or resource.
public void	recordAllocationFailureAndLatency(long latencyMs)
public void	recordAllocationSuccessAndLatency(long latencyMs)
public void	recordDestroyLatency(long latencyMs)
public void	recordFastPath()
public void	recordIdleTime(long millisecondsIdle)
public void	recordLifetimeDuration(long millisecondsSinceAllocation)
public void	recordPendingFailureAndLatency(long latencyMs)
public void	recordPendingSuccessAndLatency(long latencyMs)
public void	recordRecycled()
public void	recordResetLatency(long latencyMs)
public void	recordSlowPath()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

pendingErrorTimer	back to summary
pack-priv final io.micrometer.core.instrument.Timer pendingErrorTimer

pendingSuccessTimer	back to summary
pack-priv final io.micrometer.core.instrument.Timer pendingSuccessTimer

Constructor Detail

MicrometerPoolMetricsRecorder	back to summary
pack-priv MicrometerPoolMetricsRecorder(String id, String poolName, SocketAddress remoteAddress)

Method Detail

buildTimer	back to summary
pack-priv static io.micrometer.core.instrument.Timer buildTimer(String id, String poolName, SocketAddress remoteAddress, String status)

dispose

back to summary

public void dispose()

Implements reactor.core.Disposable.dispose.

Doc from reactor.core.Disposable.dispose.

Cancel or dispose the underlying task or resource.

Implementations are required to make this method idempotent.

Annotations

@Override

recordAllocationFailureAndLatency	back to summary
public void recordAllocationFailureAndLatency(long latencyMs) Annotations @Override

recordAllocationSuccessAndLatency	back to summary
public void recordAllocationSuccessAndLatency(long latencyMs) Annotations @Override

recordDestroyLatency	back to summary
public void recordDestroyLatency(long latencyMs) Annotations @Override

recordFastPath	back to summary
public void recordFastPath() Annotations @Override

recordIdleTime	back to summary
public void recordIdleTime(long millisecondsIdle) Annotations @Override

recordLifetimeDuration	back to summary
public void recordLifetimeDuration(long millisecondsSinceAllocation) Annotations @Override

recordPendingFailureAndLatency	back to summary
public void recordPendingFailureAndLatency(long latencyMs) Annotations @Override

recordPendingSuccessAndLatency	back to summary
public void recordPendingSuccessAndLatency(long latencyMs) Annotations @Override

recordRecycled	back to summary
public void recordRecycled() Annotations @Override

recordResetLatency	back to summary
public void recordResetLatency(long latencyMs) Annotations @Override

recordSlowPath	back to summary
public void recordSlowPath() Annotations @Override