Package software.amazon.awssdk.http.nio.netty.internal
package software.amazon.awssdk.http.nio.netty.internal
-
ClassDescriptionDisables auto read on in-use channels to allow upper layers to take care of flow control.Enables auto read on idle channels so that any data that a service sends while it's idling can be handled.Implementation of
SdkChannelPoolMap
that awaits channel pools to be closed upon closing.Extension ofSimpleChannelPool
to add an asynchronous close methodThe primary purpose of this Bootstrap provider is to ensure that all Bootstraps created by it are 'unresolved' InetSocketAddress.Simple decoratorChannelPool
that attempts to complete the promise given toCancellableAcquireChannelPool.acquire(Promise)
with the channel acquired from the underlying pool.Keys for attributes attached viaAttributeMap.attr(AttributeKey)
.Diagnostic information that may be useful to help with debugging during error scenarios.ChannelPoolHandler to configure the client pipeline.EventLoopGroup
that just delegates to anotherEventLoopGroup
.Utility class for instantiating netty dns resolvers only if they're available on the class path.Closes the channel if the execution future has been cancelled.Removes any per-requestChannelHandler
from the pipeline when releasing it to the pool.An implementation ofChannelPool
that validates the health of its connections.Wrap a channel pool so thatChannelAttributeKey.CLOSE_ON_RELEASE
is honored when a channel is released to the underlying pool.Connection pool that knows how to establish a tunnel using the HTTP CONNECT method.A channel pool implementation that tracks the number of "idle" channels in an underlying channel pool.A handler that closes unused channels that have not had any traffic on them for a configurable amount of time.MarksChannel
s as in-use when they are leased from the pool.ASdkChannelPool
that wraps and delegates to anotherSdkChannelPool
while invokingListenerInvokingChannelPool.ChannelPoolListener
s for important events that occur.Listener which is called for various actions performed on aSdkChannelPool
.Internal object for configuring netty.Utilities for collecting and publishing request-level metrics.Decorator aroundEventLoopGroup
that prevents it from being shutdown.A handler that will close channels after they have reached their time-to-live, regardless of usage.A one-time read timeout handler that removes itself from the pipeline after the next successful read.Handler that initializes the HTTP tunnel.Wrapper around aChannelPool
to protect it from having the same channel released twice.AChannelPool
implementation that allows a caller to asynchronously retrieve channel-pool related metrics viaSdkChannelPool.collectChannelPoolMetrics(MetricCollector)
.SdkChannelPoolMap<K,P extends io.netty.channel.pool.ChannelPool> Replacement forAbstractChannelPoolMap
.Provides access and manages a sharedSdkEventLoopGroup
.HandlesSslCloseCompletionEvent
s that are sent whenever an SSL channel goes inactive.Factory that simply returns a statically provided set ofKeyManager
s.Factory SPI that simply returns a statically provided set ofKeyManager
s.A handler for exceptions occurring on channels not current in use (according toChannelAttributeKey.IN_USE
).