reactor.netty.resources

Class ConnectionProvider.Builder

java.lang.Object

reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec<ConnectionProvider.Builder>

reactor.netty.resources.ConnectionProvider.Builder

All Implemented Interfaces:

java.util.function.Supplier<ConnectionProvider.Builder>

Enclosing interface:

ConnectionProvider

public static final class ConnectionProvider.Builder
extends ConnectionProvider.ConnectionPoolSpec<ConnectionProvider.Builder>

Build a ConnectionProvider to cache and reuse a fixed maximum number of Connection. Further connections will be pending acquisition depending on pendingAcquireTime. The maximum number of connections is for the connections in a single connection pool, where a connection pool corresponds to a concrete remote host. The configuration can be either global for all connection pools or be tuned for each individual connection pool, per remote host.

Since:

0.9.5

Method Summary

Modifier and Type	Method and Description
ConnectionProvider	build() Builds new ConnectionProvider
ConnectionProvider.Builder	forRemoteHost(SocketAddress remoteHost, java.util.function.Consumer<ConnectionProvider.HostSpecificSpec> spec) Connection pool configuration for a specific remote host.
ConnectionProvider.Builder	name(String name) ConnectionProvider name is used for metrics

Methods inherited from class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec

evictInBackground, fifo, get, lifo, maxConnections, maxIdleTime, maxLifeTime, metrics, metrics, pendingAcquireMaxCount, pendingAcquireTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

name

public final ConnectionProvider.Builder name(String name)

ConnectionProvider name is used for metrics

Parameters:

name - ConnectionProvider name

Returns:

this

Throws:

NullPointerException - if name is null

forRemoteHost

public final ConnectionProvider.Builder forRemoteHost(SocketAddress remoteHost,
                                                      java.util.function.Consumer<ConnectionProvider.HostSpecificSpec> spec)

Connection pool configuration for a specific remote host.

Parameters:

remoteHost - the remote host

spec - connection pool configuration for a this remote host

Returns:

this

Throws:

NullPointerException - if remoteHost or/and spec are null

build

public ConnectionProvider build()

Builds new ConnectionProvider

Returns:

builds new ConnectionProvider