Top Description Inners Fields Constructors Methods
reactor.netty5.http.client

pack-priv final Class Http2ConnectionProvider

extends PooledConnectionProvider<Connection>
Class Inheritance
Imports
io.netty5.channel.Channel, .ChannelHandlerContext, io.netty5.handler.codec.http2.Http2Connection, .Http2FrameCodec, .Http2LocalFlowController, .Http2StreamChannel, .Http2StreamChannelBootstrap, io.netty5.handler.ssl.ApplicationProtocolNames, io.netty5.resolver.AddressResolverGroup, io.netty5.util.AttributeKey, io.netty5.util.concurrent.Future, .FutureListener, org.reactivestreams.Publisher, .Subscription, reactor.core.CoreSubscriber, .Disposable, .Disposables, reactor.core.publisher.Mono, .MonoSink, .Operators, reactor.netty5.Connection, .ConnectionObserver, reactor.netty5.channel.ChannelMetricsRecorder, .ChannelOperations, reactor.netty5.resources.ConnectionProvider, .PooledConnectionProvider, reactor.netty5.transport.TransportConfig, reactor.netty5.internal.shaded.reactor.pool.InstrumentedPool, reactor.netty5.internal.shaded.reactor.pool.PooledRef, reactor.netty5.internal.shaded.reactor.pool.PooledRefMetadata, reactor.util.Logger, .Loggers, reactor.util.annotation.Nullable, reactor.util.concurrent.Queues, reactor.util.context.Context, java.io.IOException, java.net.SocketAddress, java.time.Duration, java.util.Queue, java.util.function.BiPredicate, .Function, .Supplier
An HTTP/2 implementation for pooled ConnectionProvider.
Author
Violeta Georgieva
Since
1.0.0

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
Http2ConnectionProvider.DelegatingConnectionObserver

pack-priv static class
Http2ConnectionProvider.DisposableAcquire

pack-priv static class
Http2ConnectionProvider.PendingConnectionObserver

pack-priv static class
Http2ConnectionProvider.PooledConnectionAllocator

Field Summary

Modifier and TypeField and Description
pack-priv static final String
CONNECTION_PROVIDER_NAME

pack-priv static final Logger
log

Hides reactor.netty5.resources.PooledConnectionProvider.log.

pack-priv static final String
NAME_SEPARATOR

pack-priv static final AttributeKey<ConnectionObserver>
OWNER

pack-priv final ConnectionProvider
parent

Inherited from reactor.netty5.resources.PooledConnectionProvider:
CONTEXT_CALLER_EVENTLOOP

Constructor Summary

AccessConstructor and Description
pack-priv
Http2ConnectionProvider(ConnectionProvider parent)

Method Summary

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

protected reactor.netty5.internal.shaded.reactor.pool.InstrumentedPool<Connection>
createPool(TransportConfig config, PooledConnectionProvider.PoolFactory<Connection> poolFactory, SocketAddress remoteAddress, AddressResolverGroup<?> resolverGroup)

Implements abstract reactor.netty5.resources.PooledConnectionProvider.createPool.

pack-priv static ConnectionProvider.Builder
initConfiguration(ConnectionProvider parent)

pack-priv static void
invalidate(ConnectionObserver owner)

pack-priv static void
logStreamsState(Channel channel, Http2Connection.Endpoint<Http2LocalFlowController> localEndpoint, String msg)

pack-priv static void
registerClose(Channel channel, ConnectionObserver owner)

protected void
registerDefaultMetrics(String id, SocketAddress remoteAddress, reactor.netty5.internal.shaded.reactor.pool.InstrumentedPool.PoolMetrics metrics)

Inherited from reactor.netty5.resources.PooledConnectionProvider:
acquirecreateDisposableAcquiredisposeLaterdisposeWhenisDisposedlogPoolStatelogPoolStatemaxConnectionsmaxConnectionsPerHostmutatenameonDisposepoolFactoryregisterDefaultMetrics