Package io.grpc.netty
@CheckReturnValue
package io.grpc.netty
The main transport implementation based on Netty,
for both the client and the server.
-
ClassDescriptionBase class for all Netty gRPC handlers.Controls whether PINGs like those for BDP are permitted to be sent at the current time.Command sent from a Netty client stream to the handler to cancel the stream.Command sent from a Netty server stream to the handler to cancel the stream.Maintainer of transport lifecycle status.A command to create a new stream.A KeyManagerFactory that returns a fixed list of key managers.A TrustManagerFactory that returns a fixed list of trust managers.A command to trigger close and close all streams.A command to trigger close.A command to trigger close and allow streams naturally close.gRPC wrapper for
Http2ConnectionHandler
.A headers utils providing custom gRPC implementations ofDefaultHttp2HeadersDecoder
.AHttp2Headers
implementation optimized for inbound/received headers.AGrpcHttp2HeadersUtils.GrpcHttp2InboundHeaders
implementation, optimized for HTTP/2 request headers.This class only implements the methods used byNettyClientHandler
and tests.A custom implementation of Http2Headers that only includes methods used by gRPC.Utility for configuring SslContext for gRPC.DecoratingHttp2ConnectionEncoder
which guards against a remote peer that will trigger a massive amount of control frames but will not consume our responses to these.An insecure credential that upgrades from HTTP/1 to HTTP/2.Internal accessor forGracefulServerCloseCommand
.InternalNettyChannelBuilder
accessor.A class that provides a Netty handler to control protocol negotiation.InternalNettyChannelCredentials
accessor.InternalNettyServerBuilder
accessor.InternalNettyServerCredentials
accessor.An internal accessor.Internal accessor forProtocolNegotiationEvent
.Internal accessor forInternalProtocolNegotiator.ProtocolNegotiator
.Internal accessor forProtocolNegotiators
.Utility class forWriteBufferingAndExceptionHandler
.Utility class for determining support for Jetty TLS ALPN/NPN.Identifies the negotiation used for starting up HTTP/2."Adaptive" cumulator: cumulateByteBuf
s by dynamically switching between merge and compose strategies.A builder to help simplify construction of channels using the Netty transport.This class is meant to be overriden with a custom implementation ofNettyChannelBuilder.LocalSocketPicker.createSocketAddress(java.net.SocketAddress, io.grpc.Attributes)
.Creates Netty transports.A credential with full control over the security handshake.Provider forNettyChannelBuilder
instances.Client-side Netty handler for GRPC processing.Client stream for a Netty transport.This should only be called from the transport thread.A Netty-basedConnectionClientTransport
implementation.ABuffer
implementation that is backed by a NettyByteBuf
.Netty-based server implementation.A class that can answer channelz queries about the server listen sockets.A builder to help simplify the construction of a Netty-based GRPC server.A credential with full control over the security handshake.Server-side Netty handler for GRPC processing.Provider forNettyServerBuilder
instances.Server stream for a Netty HTTP2 transport.This should only be called from the transport thread.The Netty-based server transport.An class for getting low level socket info.A TcpInfo and additional other info that will be turned into channelz socket options.A credential that performs TLS with Netty's SslContext as configuration.A credential that performs TLS with Netty's SslContext as configuration.TheWritableBuffer
used by the Netty transport.The default allocator forNettyWritableBuffer
s used by the Netty transport.Represents a completion of a protocol negotiation stage.An class that provides a Netty handler to control protocol negotiation.CommonProtocolNegotiator
s used by gRPC.Adapts aProtocolNegotiationEvent
to theGrpcHttp2ConnectionHandler
.A tuple of (host, port).Acts as a combination of Http2Upgrade andProtocolNegotiators.GrpcNegotiationHandler
.A negotiator that only does plain text.ProtocolNegotiationHandler is a convenience handler that makes it easy to follow the rules for protocol negotiation.A Proxy handler followsProtocolNegotiators.ProtocolNegotiationHandler
pattern.Waits for the channel to be active, and then installs the next Handler.Command sent from the transport to the Netty channel to send a GRPC frame to the remote endpoint.Command sent from the transport to the Netty channel to send a PING frame.Command sent from the transport to the Netty channel to send response headers to the client.Container for stream ids.Provider forNettyChannelBuilder
instances for UDS channels.A stand-in provider when you must provide a provider but you don't actually have one.Common utility methods.Buffers all writes until eitherWriteBufferingAndExceptionHandler.writeBufferedAndRemove(ChannelHandlerContext)
orWriteBufferingAndExceptionHandler.failWrites(Throwable)
is called.A queue of pending writes to aChannel
that is flushed as a single unit.Simple wrapper type around a command and its optional completion listener.