Top Description Inners Fields Constructors Methods
reactor.netty.resources

pack-priv final Class DefaultPooledConnectionProvider

extends PooledConnectionProvider<DefaultPooledConnectionProvider.PooledConnection>
Class Inheritance
Imports
java.io.IOException, java.net.SocketAddress, java.time.Clock, .Duration, java.util.Queue, java.util.concurrent.atomic.AtomicLong, java.util.function.BiPredicate, .Function, io.netty.channel.Channel, .ChannelInitializer, .EventLoop, io.netty.resolver.AddressResolverGroup, io.netty.util.AttributeKey, org.reactivestreams.Publisher, .Subscription, reactor.core.CoreSubscriber, .Disposable, .Disposables, reactor.core.publisher.Mono, .MonoSink, .Operators, .Sinks, reactor.netty.Connection, .ConnectionObserver, .FutureMono, .NettyPipeline, reactor.netty.channel.ChannelOperations, reactor.netty.transport.TransportConfig, .TransportConnector, reactor.pool.InstrumentedPool, .PooledRef, .PooledRefMetadata, reactor.util.Logger, .Loggers, reactor.util.annotation.Nullable, reactor.util.concurrent.Queues, reactor.util.context.Context
A default implementation for pooled ConnectionProvider.
Authors
Stephane Maldini, Violeta Georgieva

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
DefaultPooledConnectionProvider.DisposableAcquire

pack-priv static class
DefaultPooledConnectionProvider.PendingConnectionObserver

pack-priv static class
DefaultPooledConnectionProvider.PooledConnection

pack-priv static class
DefaultPooledConnectionProvider.PooledConnectionAllocator

Field Summary

Modifier and TypeField and Description
pack-priv static final Logger
log

Hides reactor.netty.resources.PooledConnectionProvider.log.

pack-priv static final AttributeKey<ConnectionObserver>
OWNER

Inherited from reactor.netty.resources.PooledConnectionProvider:
builderchannelPoolsCONTEXT_CALLER_EVENTLOOPdefaultPoolFactorydisposeTimeoutinactivePoolDisposeIntervalmaxConnectionsnameonDisposepoolFactoryPerRemoteHostpoolInactivity

Constructor Summary

AccessConstructor and Description
pack-priv
DefaultPooledConnectionProvider(ConnectionProvider.Builder builder)

pack-priv
DefaultPooledConnectionProvider(ConnectionProvider.Builder builder, Clock clock)

Method Summary

Modifier and TypeMethod and Description
protected CoreSubscriber<PooledRef<DefaultPooledConnectionProvider.PooledConnection>>
createDisposableAcquire(TransportConfig config, ConnectionObserver connectionObserver, long pendingAcquireTimeout, InstrumentedPool<DefaultPooledConnectionProvider.PooledConnection> pool, MonoSink<Connection> sink, Context currentContext)

Implements abstract reactor.netty.resources.PooledConnectionProvider.createDisposableAcquire.

protected InstrumentedPool<DefaultPooledConnectionProvider.PooledConnection>
createPool(TransportConfig config, PooledConnectionProvider.PoolFactory<DefaultPooledConnectionProvider.PooledConnection> poolFactory, SocketAddress remoteAddress, AddressResolverGroup<?> resolverGroup)

Implements abstract reactor.netty.resources.PooledConnectionProvider.createPool.

protected InstrumentedPool<DefaultPooledConnectionProvider.PooledConnection>
createPool(String id, TransportConfig config, PooledConnectionProvider.PoolFactory<DefaultPooledConnectionProvider.PooledConnection> poolFactory, SocketAddress remoteAddress, AddressResolverGroup<?> resolverGroup)

Overrides reactor.netty.resources.PooledConnectionProvider.createPool.

Inherited from reactor.netty.resources.PooledConnectionProvider:
acquirecompareAddressesdeRegisterDefaultMetricsdisposeInactivePoolsInBackgrounddisposeLaterdisposeWhenisDisposedlogPoolStatelogPoolStatemaxConnectionsmaxConnectionsPerHostmutatenameonDisposepoolFactoryregisterDefaultMetricsscheduleInactivePoolsDisposal