Top Fields Constructors Methods
reactor.netty.resources

pack-priv final Class DelegatingConnectionPoolMetrics

extends Object
implements ConnectionPoolMetrics
Class Inheritance
All Implemented Interfaces
reactor.netty.resources.ConnectionPoolMetrics
Imports
reactor.pool.InstrumentedPool

Field Summary

Modifier and TypeField and Description
private final InstrumentedPool.PoolMetrics

Constructor Summary

AccessConstructor and Description
pack-priv

Method Summary

Modifier and TypeMethod and Description
public int
acquiredSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.acquiredSize.

Measure the current number of resources that have been successfully acquired and are in active use.
public int
allocatedSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.allocatedSize.

Measure the current number of allocated resources in the pool, acquired or idle.
public int
idleSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.idleSize.

Measure the current number of idle resources in the pool.
public int
maxAllocatedSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.maxAllocatedSize.

Get the maximum number of live resources this Pool will allow.
public int
maxPendingAcquireSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.maxPendingAcquireSize.

Get the maximum number of Pool.acquire() this Pool can queue in a pending state when no available resource is immediately handy (and the Pool cannot allocate more resources).
public int
pendingAcquireSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.pendingAcquireSize.

Measure the current number of "pending" acquire Monos in the Pool.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

delegateback to summary
private final InstrumentedPool.PoolMetrics delegate

Constructor Detail

DelegatingConnectionPoolMetricsback to summary
pack-priv DelegatingConnectionPoolMetrics(InstrumentedPool.PoolMetrics delegate)

Method Detail

acquiredSizeback to summary
public int acquiredSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.acquiredSize.

Doc from reactor.netty.resources.ConnectionPoolMetrics.acquiredSize.

Measure the current number of resources that have been successfully acquired and are in active use.

Returns:int

the number of acquired resources

Annotations
@Override
allocatedSizeback to summary
public int allocatedSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.allocatedSize.

Doc from reactor.netty.resources.ConnectionPoolMetrics.allocatedSize.

Measure the current number of allocated resources in the pool, acquired or idle.

Returns:int

the total number of allocated resources managed by the pool

Annotations
@Override
idleSizeback to summary
public int idleSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.idleSize.

Doc from reactor.netty.resources.ConnectionPoolMetrics.idleSize.

Measure the current number of idle resources in the pool.

Note that some resources might be lazily evicted when they're next considered for an incoming acquire call. Such resources would still count towards this method.

Returns:int

the number of idle resources

Annotations
@Override
maxAllocatedSizeback to summary
public int maxAllocatedSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.maxAllocatedSize.

Doc from reactor.netty.resources.ConnectionPoolMetrics.maxAllocatedSize.

Get the maximum number of live resources this Pool will allow.

A Pool might be unbounded, in which case this method returns Integer.MAX_VALUE.

Returns:int

the maximum number of live resources that can be allocated by this Pool

Annotations
@Override
maxPendingAcquireSizeback to summary
public int maxPendingAcquireSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.maxPendingAcquireSize.

Doc from reactor.netty.resources.ConnectionPoolMetrics.maxPendingAcquireSize.

Get the maximum number of Pool.acquire() this Pool can queue in a pending state when no available resource is immediately handy (and the Pool cannot allocate more resources).

A Pool pending queue might be unbounded, in which case this method returns Integer.MAX_VALUE.

Returns:int

the maximum number of pending acquire that can be enqueued by this Pool

Annotations
@Override
pendingAcquireSizeback to summary
public int pendingAcquireSize()

Implements reactor.netty.resources.ConnectionPoolMetrics.pendingAcquireSize.

Doc from reactor.netty.resources.ConnectionPoolMetrics.pendingAcquireSize.

Measure the current number of "pending" acquire Monos in the Pool.

An acquire is in the pending state when it is attempted at a point when no idle resource is available in the pool, and no new resource can be created.

Returns:int

the number of pending acquire

Annotations
@Override