All Classes and Interfaces
Class
Description
Disables 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.ChannelPool implementation that takes another ChannelPool implementation and enforce a maximum
number of concurrent connections.Extension of
SimpleChannelPool 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 decorator
ChannelPool that attempts to complete the promise
given to CancellableAcquireChannelPool.acquire(Promise) with the channel acquired from the underlying
pool.A cancelled subscriber.
Keys for attributes attached via
AttributeMap.attr(AttributeKey).Diagnostic information that may be useful to help with debugging during error scenarios.
ChannelPoolHandler to configure the client pipeline.
A default streamed HTTP request.
A default streamed HTTP response.
An abstract implementation of
ChannelHandlerContext that delegates to another
context for non-overridden methods.EventLoopGroup that just delegates to another EventLoopGroup.Utility class for instantiating netty dns resolvers only if they're available on the class path.
This is an HTTP/2 related workaround for an issue where a WINDOW_UPDATE is
queued but not written to the socket, causing a read() on the channel to
hang if the remote endpoint thinks our inbound window is 0.
Closes the channel if the execution future has been cancelled.
Exception thrown when a GOAWAY frame is sent by the service.
Publisher for a Netty Handler.
Removes any per-request
ChannelHandler from the pipeline when releasing it to the pool.Subscriber that publishes received messages to the handler pipeline.
An implementation of
ChannelPool that validates the health of its connections.Wrap a channel pool so that
ChannelAttributeKey.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.
Configuration specific to HTTP/2 connections.
Handles
Http2GoAwayFrames sent on a connection.ChannelPool implementation that handles multiplexed streams.Attached to a
Channel to periodically check the health of HTTP2 connections via PING frames.Wrapper around a
Subscription to send a RST_STREAM frame on cancel.Configure channel based on the
Http2SettingsFrame received from serverException Handler for errors on the Http2 streams.
Converts
Http2Frames to HttpObjects.Channel pool that establishes an initial connection to determine protocol.
Handler that converts written
StreamedHttpRequest messages into HttpRequest messages
followed by HttpContent messages and reads HttpResponse messages followed by
HttpContent messages and produces StreamedHttpResponse messages.Translates HTTP/1.1 Netty objects to the corresponding HTTP/2 frame objects.
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.
Marks
Channels as in-use when they are leased from the pool.A
SdkChannelPool that wraps and delegates to another SdkChannelPool while invoking ListenerInvokingChannelPool.ChannelPoolListeners
for important events that occur.Listener which is called for various actions performed on a
SdkChannelPool.Contains a
Future for the actual socket channel and tracks available
streams based on the MAX_CONCURRENT_STREAMS setting for the connection.Logger facade similar to
Logger, that also includes channel information in the message
when provided.Internal object for configuring netty.
An implementation of
SdkAsyncHttpClient that uses a Netty non-blocking HTTP client to communicate with the service.Builder that allows configuration of the Netty NIO HTTP implementation.
Utilities for collecting and publishing request-level metrics.
Service binding for the Netty default implementation.
Decorator around
EventLoopGroup 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.
An implementation of
ChannelHandlerContext that ensures all writes are performed in the order they are invoked.Tracking the status after sending out the PING frame
Proxy configuration for
NettyNioAsyncHttpClient.Builder for
ProxyConfiguration.Handler that initializes the HTTP tunnel.
Wrapper around a
ChannelPool to protect it from having the same channel released twice.A
ChannelPool implementation that allows a caller to asynchronously retrieve channel-pool related metrics via
SdkChannelPool.collectChannelPoolMetrics(MetricCollector).Replacement for
AbstractChannelPoolMap.A builder for
SdkEventLoopGroup.Provides access and manages a shared
SdkEventLoopGroup.Handles
SslCloseCompletionEvents that are sent whenever an SSL channel
goes inactive.Factory that simply returns a statically provided set of
KeyManagers.Factory SPI that simply returns a statically provided set of
KeyManagers.Combines
HttpMessage and Publisher into one
message.Combines
HttpRequest and StreamedHttpMessage into one
message.Combines
HttpResponse and StreamedHttpMessage into one
message.A handler for exceptions occurring on channels not current in use (according to
ChannelAttributeKey.IN_USE).Handles writer idle events from IdleStateHandler to detect idle body write gaps.