Core functionality for the Reactor Netty library 1.1.16 · reactor.netty.resources.MicrometerPoolMetricsRecorder

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

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 the latency in milliseconds latencyMs) Implements reactor.pool.PoolMetricsRecorder.recordAllocationFailureAndLatency. Record a latency for failed allocation.
public void	recordAllocationSuccessAndLatency(long the latency in milliseconds latencyMs) Implements reactor.pool.PoolMetricsRecorder.recordAllocationSuccessAndLatency. Record a latency for successful allocation.
public void	recordDestroyLatency(long the latency in milliseconds latencyMs) Implements reactor.pool.PoolMetricsRecorder.recordDestroyLatency. Record a latency for destroying a resource.
public void	recordFastPath() Implements reactor.pool.PoolMetricsRecorder.recordFastPath. Record the fact that a `Pool` has a fast path of recycling and just used it.
public void	recordIdleTime(long the number of milliseconds an object that was just acquired had previously been idle millisecondsIdle) Implements reactor.pool.PoolMetricsRecorder.recordIdleTime. Record the number of milliseconds an object had been idle when it gets pulled from the pool and passed to a borrower.
public void	recordLifetimeDuration(long the number of milliseconds since the object was allocated, at the time it is destroyed millisecondsSinceAllocation) Implements reactor.pool.PoolMetricsRecorder.recordLifetimeDuration. Record the number of milliseconds a pooled object has been live (ie time between allocation and destruction).
public void	recordPendingFailureAndLatency(long the latency in milliseconds latencyMs) Overrides default reactor.pool.PoolMetricsRecorder.recordPendingFailureAndLatency. Record a latency for failed pending acquire.
public void	recordPendingSuccessAndLatency(long the latency in milliseconds latencyMs) Overrides default reactor.pool.PoolMetricsRecorder.recordPendingSuccessAndLatency. Record a latency for successful pending acquire operation.
public void	recordRecycled() Implements reactor.pool.PoolMetricsRecorder.recordRecycled. Record the fact that a resource was recycled, ie it was reset and tested for reuse.
public void	recordResetLatency(long the latency in milliseconds latencyMs) Implements reactor.pool.PoolMetricsRecorder.recordResetLatency. Record a latency for resetting a resource to a reusable state.
public void	recordSlowPath() Implements reactor.pool.PoolMetricsRecorder.recordSlowPath. Record the fact that a `Pool` has a slow path of recycling and just used it.

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

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

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

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) Implements reactor.pool.PoolMetricsRecorder.recordAllocationFailureAndLatency. Doc from reactor.pool.PoolMetricsRecorder.recordAllocationFailureAndLatency. Record a latency for failed allocation. Implies incrementing an allocation failure counter as well. Parameters latencyMs:long the latency in milliseconds Annotations @Override

recordAllocationFailureAndLatency

back to summary

public void recordAllocationFailureAndLatency(long latencyMs)

Implements reactor.pool.PoolMetricsRecorder.recordAllocationFailureAndLatency.

Doc from reactor.pool.PoolMetricsRecorder.recordAllocationFailureAndLatency.

Record a latency for failed allocation. Implies incrementing an allocation failure counter as well.

Parameters

latencyMs:long: the latency in milliseconds

Annotations

@Override

recordAllocationSuccessAndLatency	back to summary
public void recordAllocationSuccessAndLatency(long latencyMs) Implements reactor.pool.PoolMetricsRecorder.recordAllocationSuccessAndLatency. Doc from reactor.pool.PoolMetricsRecorder.recordAllocationSuccessAndLatency. Record a latency for successful allocation. Implies incrementing an allocation success counter as well. Parameters latencyMs:long the latency in milliseconds Annotations @Override

recordAllocationSuccessAndLatency

back to summary

public void recordAllocationSuccessAndLatency(long latencyMs)

Implements reactor.pool.PoolMetricsRecorder.recordAllocationSuccessAndLatency.

Doc from reactor.pool.PoolMetricsRecorder.recordAllocationSuccessAndLatency.

Record a latency for successful allocation. Implies incrementing an allocation success counter as well.

Parameters

latencyMs:long: the latency in milliseconds

Annotations

@Override

recordDestroyLatency	back to summary
public void recordDestroyLatency(long latencyMs) Implements reactor.pool.PoolMetricsRecorder.recordDestroyLatency. Doc from reactor.pool.PoolMetricsRecorder.recordDestroyLatency. Record a latency for destroying a resource. Implies incrementing a counter as well. Parameters latencyMs:long the latency in milliseconds Annotations @Override

recordDestroyLatency

back to summary

public void recordDestroyLatency(long latencyMs)

Implements reactor.pool.PoolMetricsRecorder.recordDestroyLatency.

Doc from reactor.pool.PoolMetricsRecorder.recordDestroyLatency.

Record a latency for destroying a resource. Implies incrementing a counter as well.

Parameters

latencyMs:long: the latency in milliseconds

Annotations

@Override

recordFastPath back to summary

recordFastPath	back to summary
public void recordFastPath() Implements reactor.pool.PoolMetricsRecorder.recordFastPath. Doc from reactor.pool.PoolMetricsRecorder.recordFastPath. Record the fact that a `Pool` has a fast path of recycling and just used it. Annotations @Override

public void recordFastPath()

Implements reactor.pool.PoolMetricsRecorder.recordFastPath.

Doc from reactor.pool.PoolMetricsRecorder.recordFastPath.

Record the fact that a Pool has a fast path of recycling and just used it.

Annotations

@Override

recordIdleTime	back to summary
public void recordIdleTime(long millisecondsIdle) Implements reactor.pool.PoolMetricsRecorder.recordIdleTime. Doc from reactor.pool.PoolMetricsRecorder.recordIdleTime. Record the number of milliseconds an object had been idle when it gets pulled from the pool and passed to a borrower. Parameters millisecondsIdle:long the number of milliseconds an object that was just acquired had previously been idle Annotations @Override

recordIdleTime

back to summary

public void recordIdleTime(long millisecondsIdle)

Implements reactor.pool.PoolMetricsRecorder.recordIdleTime.

Doc from reactor.pool.PoolMetricsRecorder.recordIdleTime.

Record the number of milliseconds an object had been idle when it gets pulled from the pool and passed to a borrower.

Parameters

millisecondsIdle:long: the number of milliseconds an object that was just acquired had previously been idle

Annotations

@Override

recordLifetimeDuration	back to summary
public void recordLifetimeDuration(long millisecondsSinceAllocation) Implements reactor.pool.PoolMetricsRecorder.recordLifetimeDuration. Doc from reactor.pool.PoolMetricsRecorder.recordLifetimeDuration. Record the number of milliseconds a pooled object has been live (ie time between allocation and destruction). Parameters millisecondsSinceAllocation:long the number of milliseconds since the object was allocated, at the time it is destroyed Annotations @Override

recordLifetimeDuration

back to summary

public void recordLifetimeDuration(long millisecondsSinceAllocation)

Implements reactor.pool.PoolMetricsRecorder.recordLifetimeDuration.

Doc from reactor.pool.PoolMetricsRecorder.recordLifetimeDuration.

Record the number of milliseconds a pooled object has been live (ie time between allocation and destruction).

Parameters

millisecondsSinceAllocation:long: the number of milliseconds since the object was allocated, at the time it is destroyed

Annotations

@Override

recordPendingFailureAndLatency back to summary

recordPendingFailureAndLatency	back to summary
public void recordPendingFailureAndLatency(long latencyMs) Overrides default reactor.pool.PoolMetricsRecorder.recordPendingFailureAndLatency. Doc from reactor.pool.PoolMetricsRecorder.recordPendingFailureAndLatency. Record a latency for failed pending acquire. A failed pending acquire operation is such that finishes with `PoolAcquireTimeoutException`. Implies incrementing a pending acquire failure counter as well. Parameters latencyMs:long the latency in milliseconds Annotations @Override

public void recordPendingFailureAndLatency(long latencyMs)

Overrides default reactor.pool.PoolMetricsRecorder.recordPendingFailureAndLatency.

Doc from reactor.pool.PoolMetricsRecorder.recordPendingFailureAndLatency.

Record a latency for failed pending acquire. A failed pending acquire operation is such that finishes with PoolAcquireTimeoutException. Implies incrementing a pending acquire failure counter as well.

Parameters

latencyMs:long: the latency in milliseconds

Annotations

@Override

recordPendingSuccessAndLatency	back to summary
public void recordPendingSuccessAndLatency(long latencyMs) Overrides default reactor.pool.PoolMetricsRecorder.recordPendingSuccessAndLatency. Doc from reactor.pool.PoolMetricsRecorder.recordPendingSuccessAndLatency. Record a latency for successful pending acquire operation. A successful pending acquire operation is such that triggers an allocation operation. Implies incrementing a pending acquire success counter as well. Parameters latencyMs:long the latency in milliseconds Annotations @Override

recordPendingSuccessAndLatency

back to summary

public void recordPendingSuccessAndLatency(long latencyMs)

Overrides default reactor.pool.PoolMetricsRecorder.recordPendingSuccessAndLatency.

Doc from reactor.pool.PoolMetricsRecorder.recordPendingSuccessAndLatency.

Record a latency for successful pending acquire operation. A successful pending acquire operation is such that triggers an allocation operation. Implies incrementing a pending acquire success counter as well.

Parameters

latencyMs:long: the latency in milliseconds

Annotations

@Override

recordRecycled	back to summary
public void recordRecycled() Implements reactor.pool.PoolMetricsRecorder.recordRecycled. Doc from reactor.pool.PoolMetricsRecorder.recordRecycled. Record the fact that a resource was recycled, ie it was reset and tested for reuse. Annotations @Override

recordRecycled

back to summary

public void recordRecycled()

Implements reactor.pool.PoolMetricsRecorder.recordRecycled.

Doc from reactor.pool.PoolMetricsRecorder.recordRecycled.

Record the fact that a resource was recycled, ie it was reset and tested for reuse.

Annotations

@Override

recordResetLatency	back to summary
public void recordResetLatency(long latencyMs) Implements reactor.pool.PoolMetricsRecorder.recordResetLatency. Doc from reactor.pool.PoolMetricsRecorder.recordResetLatency. Record a latency for resetting a resource to a reusable state. Implies incrementing a counter as well. Parameters latencyMs:long the latency in milliseconds Annotations @Override

recordResetLatency

back to summary

public void recordResetLatency(long latencyMs)

Implements reactor.pool.PoolMetricsRecorder.recordResetLatency.

Doc from reactor.pool.PoolMetricsRecorder.recordResetLatency.

Record a latency for resetting a resource to a reusable state. Implies incrementing a counter as well.

Parameters

latencyMs:long: the latency in milliseconds

Annotations

@Override

recordSlowPath back to summary

recordSlowPath	back to summary
public void recordSlowPath() Implements reactor.pool.PoolMetricsRecorder.recordSlowPath. Doc from reactor.pool.PoolMetricsRecorder.recordSlowPath. Record the fact that a `Pool` has a slow path of recycling and just used it. Annotations @Override

public void recordSlowPath()

Implements reactor.pool.PoolMetricsRecorder.recordSlowPath.

Doc from reactor.pool.PoolMetricsRecorder.recordSlowPath.

Record the fact that a Pool has a slow path of recycling and just used it.

Annotations

@Override

pack-priv final Class MicrometerPoolMetricsRecorder

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail