Top Description Inners Fields Constructors Methods
io.r2dbc.pool

public final Class ConnectionPoolConfiguration

extends Object
Class Inheritance
Imports
io.r2dbc.spi.Connection, .ConnectionFactory, .Lifecycle, .ValidationDepth, org.reactivestreams.Publisher, reactor.core.publisher.Mono, reactor.core.scheduler.Scheduler, .Schedulers, reactor.pool.PoolBuilder, .PoolConfig, .PoolMetricsRecorder, reactor.util.annotation.Nullable, java.time.Clock, .Duration, java.util.function.Consumer, .Function
Connection pool configuration.

Negative Duration values for timeouts are considered as no timeout.

Authors
Mark Paluch, Tadaya Tsuyukubo, Steffen Kreutz, Rodolfo Beletatti, Petromir Dzhunev, Gabriel Calin

Nested and Inner Type Summary

Modifier and TypeClass and Description
public static class
ConnectionPoolConfiguration.Builder

A builder for ConnectionPoolConfiguration instances.

Field Summary

Modifier and TypeField and Description
private final int
acquireRetry

private final Scheduler
allocatorSubscribeOn

private final Duration
backgroundEvictionInterval

private final Clock
clock

private final ConnectionFactory
connectionFactory

private final Consumer<PoolBuilder<Connection, ? extends PoolConfig<? extends Connection>>>
customizer

private final int
initialSize

private final Duration
maxAcquireTime

private final Duration
maxCreateConnectionTime

private final Duration
maxIdleTime

private final Duration
maxLifeTime

private final int
maxSize

private final Duration
maxValidationTime

private final PoolMetricsRecorder
metricsRecorder

private final int
minIdle

private final String
name

public static final Duration
NO_TIMEOUT

Constant indicating that timeout should not apply.

private final Function<? super Connection, ? extends Publisher<Void>>
postAllocate

private final Function<? super Connection, ? extends Publisher<Void>>
preRelease

private final boolean
registerJmx

private final ValidationDepth
validationDepth

private final String
validationQuery

Constructor Summary

AccessConstructor and Description
private
ConnectionPoolConfiguration(Scheduler allocatorSubscribeOn, int acquireRetry, Duration backgroundEvictionInterval, ConnectionFactory connectionFactory, Clock clock, Consumer<PoolBuilder<Connection, ? extends PoolConfig<? extends Connection>>> customizer, int initialSize, int maxSize, int minIdle, Duration maxAcquireTime, Duration maxCreateConnectionTime, Duration maxIdleTime, Duration maxLifeTime, Duration maxValidationTime, PoolMetricsRecorder metricsRecorder, String name, Function<? super Connection, ? extends Publisher<Void>> postAllocate, Function<? super Connection, ? extends Publisher<Void>> preRelease, boolean registerJmx, ValidationDepth validationDepth, String validationQuery)

Method Summary

Modifier and TypeMethod and Description
public static ConnectionPoolConfiguration.Builder

Returns:

a new Builder
builder(ConnectionFactory
the ConnectionFactory to wrap.
connectionFactory)

Returns a new Builder.

public static ConnectionPoolConfiguration.Builder

Returns:

a new Builder
builder()

Returns a new Builder.

pack-priv int
getAcquireRetry()

pack-priv Scheduler
getAllocatorSubscribeOn()

pack-priv Duration
getBackgroundEvictionInterval()

pack-priv Clock
getClock()

pack-priv ConnectionFactory
getConnectionFactory()

pack-priv Consumer<PoolBuilder<Connection, ? extends PoolConfig<? extends Connection>>>
getCustomizer()

pack-priv int
getInitialSize()

pack-priv Duration
getMaxAcquireTime()

pack-priv Duration
getMaxCreateConnectionTime()

pack-priv Duration
getMaxIdleTime()

pack-priv Duration
getMaxLifeTime()

pack-priv int
getMaxSize()

pack-priv Duration
getMaxValidationTime()

pack-priv PoolMetricsRecorder
getMetricsRecorder()

pack-priv int
getMinIdle()

pack-priv String
getName()

pack-priv Function<? super Connection, ? extends Publisher<Void>>
getPostAllocate()

pack-priv Function<? super Connection, ? extends Publisher<Void>>
getPreRelease()

pack-priv ValidationDepth
getValidationDepth()

pack-priv String
getValidationQuery()

pack-priv boolean
isRegisterJmx()

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait