Package io.grpc.netty

Class ProtocolNegotiators

java.lang.Object

io.grpc.netty.ProtocolNegotiators

final class ProtocolNegotiators
extends Object

Common ProtocolNegotiators used by gRPC.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	ProtocolNegotiators.ClientTlsHandler
(package private) static final class	ProtocolNegotiators.ClientTlsProtocolNegotiator
private static final class	ProtocolNegotiators.FixedProtocolNegotiatorServerFactory
static final class	ProtocolNegotiators.FromChannelCredentialsResult
static final class	ProtocolNegotiators.FromServerCredentialsResult
(package private) static final class	ProtocolNegotiators.GrpcNegotiationHandler	Adapts a ProtocolNegotiationEvent to the GrpcHttp2ConnectionHandler.
(package private) static final class	ProtocolNegotiators.HostPort	A tuple of (host, port).
(package private) static final class	ProtocolNegotiators.Http2UpgradeAndGrpcHandler	Acts as a combination of Http2Upgrade and ProtocolNegotiators.GrpcNegotiationHandler.
(package private) static final class	ProtocolNegotiators.PlaintextProtocolNegotiator	A negotiator that only does plain text.
(package private) static final class	ProtocolNegotiators.PlaintextProtocolNegotiatorClientFactory
(package private) static final class	ProtocolNegotiators.PlaintextProtocolNegotiatorServerFactory
(package private) static final class	ProtocolNegotiators.PlaintextUpgradeProtocolNegotiator
private static final class	ProtocolNegotiators.PlaintextUpgradeProtocolNegotiatorClientFactory
(package private) static class	ProtocolNegotiators.ProtocolNegotiationHandler	ProtocolNegotiationHandler is a convenience handler that makes it easy to follow the rules for protocol negotiation.
(package private) static final class	ProtocolNegotiators.ProxyProtocolNegotiationHandler	A Proxy handler follows ProtocolNegotiators.ProtocolNegotiationHandler pattern.
(package private) static final class	ProtocolNegotiators.ServerTlsHandler
(package private) static final class	ProtocolNegotiators.TlsProtocolNegotiatorClientFactory
(package private) static final class	ProtocolNegotiators.TlsProtocolNegotiatorServerFactory
(package private) static final class	ProtocolNegotiators.WaitUntilActiveHandler	Waits for the channel to be active, and then installs the next Handler.

Field Summary

Fields

Modifier and Type	Field	Description
private static final Logger	log
private static final EnumSet<TlsServerCredentials.Feature>	understoodServerTlsFeatures
private static final EnumSet<TlsChannelCredentials.Feature>	understoodTlsFeatures

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ProtocolNegotiators()

Method Summary

Modifier and Type	Method	Description
static ProtocolNegotiator.ServerFactory	fixedServerFactory(ProtocolNegotiator negotiator)
static ProtocolNegotiators.FromChannelCredentialsResult	from(ChannelCredentials creds)
static ProtocolNegotiators.FromServerCredentialsResult	from(ServerCredentials creds)
static ProtocolNegotiator	httpProxy(SocketAddress proxyAddress, String proxyUsername, String proxyPassword, ProtocolNegotiator negotiator)	Returns a ProtocolNegotiator that does HTTP CONNECT proxy negotiation.
(package private) static void	logSslEngineDetails(Level level, io.netty.channel.ChannelHandlerContext ctx, String msg, Throwable t)
(package private) static ProtocolNegotiators.HostPort	parseAuthority(String authority)
static ProtocolNegotiator	plaintext()	Returns a ChannelHandler that ensures that the handler is added to the pipeline writes to the Channel may happen immediately, even before it is active.
static ProtocolNegotiator.ClientFactory	plaintextClientFactory()
static ProtocolNegotiator	plaintextUpgrade()	Returns a ProtocolNegotiator used for upgrading to HTTP/2 from HTTP/1.x.
static ProtocolNegotiator.ClientFactory	plaintextUpgradeClientFactory()
static ProtocolNegotiator	serverPlaintext()	Create a server plaintext handler for gRPC.
static ProtocolNegotiator.ServerFactory	serverPlaintextFactory()	Create a server plaintext handler factory for gRPC.
static ProtocolNegotiator	serverTls(io.netty.handler.ssl.SslContext sslContext)	Create a server TLS handler for HTTP/2 capable of using ALPN/NPN.
static ProtocolNegotiator	serverTls(io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends Executor> executorPool)	Create a server TLS handler for HTTP/2 capable of using ALPN/NPN.
static ProtocolNegotiator.ServerFactory	serverTlsFactory(io.netty.handler.ssl.SslContext sslContext)
static ProtocolNegotiator	tls(io.netty.handler.ssl.SslContext sslContext)	Returns a ProtocolNegotiator that ensures the pipeline is set up so that TLS will be negotiated, the handler is added and writes to the Channel may happen immediately, even before the TLS Handshake is complete.
static ProtocolNegotiator	tls(io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends Executor> executorPool, Optional<Runnable> handshakeCompleteRunnable)	Returns a ProtocolNegotiator that ensures the pipeline is set up so that TLS will be negotiated, the handler is added and writes to the Channel may happen immediately, even before the TLS Handshake is complete.
static ProtocolNegotiator.ClientFactory	tlsClientFactory(io.netty.handler.ssl.SslContext sslContext)
private static RuntimeException	unavailableException(String msg)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

log

private static final Logger log

understoodTlsFeatures

private static final EnumSet<TlsChannelCredentials.Feature> understoodTlsFeatures

understoodServerTlsFeatures

private static final EnumSet<TlsServerCredentials.Feature> understoodServerTlsFeatures

Constructor Details

ProtocolNegotiators

private ProtocolNegotiators()

Method Details

from

public static ProtocolNegotiators.FromChannelCredentialsResult from(ChannelCredentials creds)

from

public static ProtocolNegotiators.FromServerCredentialsResult from(ServerCredentials creds)

fixedServerFactory

public static ProtocolNegotiator.ServerFactory fixedServerFactory(ProtocolNegotiator negotiator)

serverPlaintext

public static ProtocolNegotiator serverPlaintext()

Create a server plaintext handler for gRPC.

serverPlaintextFactory

public static ProtocolNegotiator.ServerFactory serverPlaintextFactory()

Create a server plaintext handler factory for gRPC.

serverTlsFactory

public static ProtocolNegotiator.ServerFactory serverTlsFactory(io.netty.handler.ssl.SslContext sslContext)

serverTls

public static ProtocolNegotiator serverTls(io.netty.handler.ssl.SslContext sslContext,
 ObjectPool<? extends Executor> executorPool)

Create a server TLS handler for HTTP/2 capable of using ALPN/NPN.

Parameters:

executorPool - a dedicated Executor pool for time-consuming TLS tasks

serverTls

public static ProtocolNegotiator serverTls(io.netty.handler.ssl.SslContext sslContext)

Create a server TLS handler for HTTP/2 capable of using ALPN/NPN.

httpProxy

public static ProtocolNegotiator httpProxy(SocketAddress proxyAddress,
 @Nullable
 String proxyUsername,
 @Nullable
 String proxyPassword,
 ProtocolNegotiator negotiator)

Returns a ProtocolNegotiator that does HTTP CONNECT proxy negotiation.

parseAuthority

static ProtocolNegotiators.HostPort parseAuthority(String authority)

tls

public static ProtocolNegotiator tls(io.netty.handler.ssl.SslContext sslContext,
 ObjectPool<? extends Executor> executorPool,
 Optional<Runnable> handshakeCompleteRunnable)

Returns a ProtocolNegotiator that ensures the pipeline is set up so that TLS will be negotiated, the handler is added and writes to the Channel may happen immediately, even before the TLS Handshake is complete.

Parameters:

executorPool - a dedicated Executor pool for time-consuming TLS tasks

tls

public static ProtocolNegotiator tls(io.netty.handler.ssl.SslContext sslContext)

Returns a ProtocolNegotiator that ensures the pipeline is set up so that TLS will be negotiated, the handler is added and writes to the Channel may happen immediately, even before the TLS Handshake is complete.

tlsClientFactory

public static ProtocolNegotiator.ClientFactory tlsClientFactory(io.netty.handler.ssl.SslContext sslContext)

plaintextUpgrade

public static ProtocolNegotiator plaintextUpgrade()

Returns a ProtocolNegotiator used for upgrading to HTTP/2 from HTTP/1.x.

plaintextUpgradeClientFactory

public static ProtocolNegotiator.ClientFactory plaintextUpgradeClientFactory()

plaintext

public static ProtocolNegotiator plaintext()

Returns a ChannelHandler that ensures that the handler is added to the pipeline writes to the Channel may happen immediately, even before it is active.

plaintextClientFactory

public static ProtocolNegotiator.ClientFactory plaintextClientFactory()

unavailableException

private static RuntimeException unavailableException(String msg)

logSslEngineDetails

static void logSslEngineDetails(Level level,
 io.netty.channel.ChannelHandlerContext ctx,
 String msg,
 @Nullable
 Throwable t)