Top Description Constructors Methods
io.r2dbc.pool

public Class SimplePoolMetricsRecorder

extends Object
implements PoolMetricsRecorder
Class Inheritance
All Implemented Interfaces
reactor.pool.PoolMetricsRecorder
Imports
reactor.pool.PoolMetricsRecorder

Simple PoolMetricsRecorder.

All "record**" methods are not supported.

Authors
Tadaya Tsuyukubo, Mark Paluch

Constructor Summary

AccessConstructor and Description
public

Method Summary

Modifier and TypeMethod and Description
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
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:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

SimplePoolMetricsRecorderback to summary
public SimplePoolMetricsRecorder()

Method Detail

recordAllocationFailureAndLatencyback 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
recordAllocationSuccessAndLatencyback 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
recordDestroyLatencyback 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
recordFastPathback 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
recordIdleTimeback 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
recordLifetimeDurationback 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
recordRecycledback 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
recordResetLatencyback 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
recordSlowPathback 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