Uses of Interface
io.grpc.netty.ProtocolNegotiator
Packages that use ProtocolNegotiator
Package
Description
The main transport implementation based on Netty,
for both the client and the server.
-
Uses of ProtocolNegotiator in io.grpc.netty
Subinterfaces of ProtocolNegotiator in io.grpc.nettyModifier and TypeInterfaceDescriptionstatic interface
Classes in io.grpc.netty that implement ProtocolNegotiatorModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
A negotiator that only does plain text.(package private) static final class
Fields in io.grpc.netty declared as ProtocolNegotiatorModifier and TypeFieldDescriptionprivate final ProtocolNegotiator
InternalProtocolNegotiator.ProtocolNegotiatorAdapter.negotiator
private final ProtocolNegotiator
NettyClientTransport.negotiator
private final ProtocolNegotiator
NettyChannelBuilder.NettyTransportFactory.protocolNegotiator
private final ProtocolNegotiator
NettyServer.protocolNegotiator
private final ProtocolNegotiator
NettyServerTransport.protocolNegotiator
private final ProtocolNegotiator
ProtocolNegotiators.FixedProtocolNegotiatorServerFactory.protocolNegotiator
Methods in io.grpc.netty that return ProtocolNegotiatorModifier and TypeMethodDescription(package private) static ProtocolNegotiator
NettyChannelBuilder.createProtocolNegotiatorByType
(NegotiationType negotiationType, io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends Executor> executorPool) static ProtocolNegotiator
ProtocolNegotiators.httpProxy
(SocketAddress proxyAddress, String proxyUsername, String proxyPassword, ProtocolNegotiator negotiator) Returns aProtocolNegotiator
that does HTTP CONNECT proxy negotiation.NettyChannelBuilder.DefaultProtocolNegotiator.newNegotiator()
ProtocolNegotiator.ClientFactory.newNegotiator()
Creates a new negotiator.ProtocolNegotiator.ServerFactory.newNegotiator
(ObjectPool<? extends Executor> offloadExecutorPool) Creates a new negotiator.ProtocolNegotiators.FixedProtocolNegotiatorServerFactory.newNegotiator
(ObjectPool<? extends Executor> offloadExecutorPool) ProtocolNegotiators.PlaintextProtocolNegotiatorClientFactory.newNegotiator()
ProtocolNegotiators.PlaintextProtocolNegotiatorServerFactory.newNegotiator
(ObjectPool<? extends Executor> offloadExecutorPool) ProtocolNegotiators.PlaintextUpgradeProtocolNegotiatorClientFactory.newNegotiator()
ProtocolNegotiators.TlsProtocolNegotiatorClientFactory.newNegotiator()
ProtocolNegotiators.TlsProtocolNegotiatorServerFactory.newNegotiator
(ObjectPool<? extends Executor> offloadExecutorPool) static ProtocolNegotiator
ProtocolNegotiators.plaintext()
Returns aChannelHandler
that ensures that thehandler
is added to the pipeline writes to theChannel
may happen immediately, even before it is active.static ProtocolNegotiator
ProtocolNegotiators.plaintextUpgrade()
Returns aProtocolNegotiator
used for upgrading to HTTP/2 from HTTP/1.x.static ProtocolNegotiator
ProtocolNegotiators.serverPlaintext()
Create a server plaintext handler for gRPC.static ProtocolNegotiator
ProtocolNegotiators.serverTls
(io.netty.handler.ssl.SslContext sslContext) Create a server TLS handler for HTTP/2 capable of using ALPN/NPN.static ProtocolNegotiator
ProtocolNegotiators.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
ProtocolNegotiators.tls
(io.netty.handler.ssl.SslContext sslContext) Returns aProtocolNegotiator
that ensures the pipeline is set up so that TLS will be negotiated, thehandler
is added and writes to theChannel
may happen immediately, even before the TLS Handshake is complete.static ProtocolNegotiator
ProtocolNegotiators.tls
(io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends Executor> executorPool, Optional<Runnable> handshakeCompleteRunnable) Returns aProtocolNegotiator
that ensures the pipeline is set up so that TLS will be negotiated, thehandler
is added and writes to theChannel
may happen immediately, even before the TLS Handshake is complete.Methods in io.grpc.netty with parameters of type ProtocolNegotiatorModifier and TypeMethodDescriptionProtocolNegotiators.fixedServerFactory
(ProtocolNegotiator negotiator) static ProtocolNegotiator
ProtocolNegotiators.httpProxy
(SocketAddress proxyAddress, String proxyUsername, String proxyPassword, ProtocolNegotiator negotiator) Returns aProtocolNegotiator
that does HTTP CONNECT proxy negotiation.final NettyServerBuilder
NettyServerBuilder.protocolNegotiator
(ProtocolNegotiator protocolNegotiator) Sets theProtocolNegotiator
to be used.Constructors in io.grpc.netty with parameters of type ProtocolNegotiatorModifierConstructorDescriptionFixedProtocolNegotiatorServerFactory
(ProtocolNegotiator protocolNegotiator) (package private)
NettyClientTransport
(SocketAddress address, io.netty.channel.ChannelFactory<? extends io.netty.channel.Channel> channelFactory, Map<io.netty.channel.ChannelOption<?>, ?> channelOptions, io.netty.channel.EventLoopGroup group, ProtocolNegotiator negotiator, boolean autoFlowControl, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, long keepAliveTimeNanos, long keepAliveTimeoutNanos, boolean keepAliveWithoutCalls, String authority, String userAgent, Runnable tooManyPingsRunnable, TransportTracer transportTracer, Attributes eagAttributes, NettyChannelBuilder.LocalSocketPicker localSocketPicker, ChannelLogger channelLogger, boolean useGetForSafeMethods, com.google.common.base.Ticker ticker) (package private)
NettyServer
(List<? extends SocketAddress> addresses, io.netty.channel.ChannelFactory<? extends io.netty.channel.ServerChannel> channelFactory, Map<io.netty.channel.ChannelOption<?>, ?> channelOptions, Map<io.netty.channel.ChannelOption<?>, ?> childChannelOptions, ObjectPool<? extends io.netty.channel.EventLoopGroup> bossGroupPool, ObjectPool<? extends io.netty.channel.EventLoopGroup> workerGroupPool, boolean forceHeapBuffer, ProtocolNegotiator protocolNegotiator, List<? extends ServerStreamTracer.Factory> streamTracerFactories, TransportTracer.Factory transportTracerFactory, int maxStreamsPerConnection, boolean autoFlowControl, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, long keepAliveTimeInNanos, long keepAliveTimeoutInNanos, long maxConnectionIdleInNanos, long maxConnectionAgeInNanos, long maxConnectionAgeGraceInNanos, boolean permitKeepAliveWithoutCalls, long permitKeepAliveTimeInNanos, int maxRstCount, long maxRstPeriodNanos, Attributes eagAttributes, InternalChannelz channelz) (package private)
NettyServerTransport
(io.netty.channel.Channel channel, io.netty.channel.ChannelPromise channelUnused, ProtocolNegotiator protocolNegotiator, List<? extends ServerStreamTracer.Factory> streamTracerFactories, TransportTracer transportTracer, int maxStreams, boolean autoFlowControl, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, long keepAliveTimeInNanos, long keepAliveTimeoutInNanos, long maxConnectionIdleInNanos, long maxConnectionAgeInNanos, long maxConnectionAgeGraceInNanos, boolean permitKeepAliveWithoutCalls, long permitKeepAliveTimeInNanos, int maxRstCount, long maxRstPeriodNanos, Attributes eagAttributes) (package private)
NettyTransportFactory
(ProtocolNegotiator protocolNegotiator, io.netty.channel.ChannelFactory<? extends io.netty.channel.Channel> channelFactory, Map<io.netty.channel.ChannelOption<?>, ?> channelOptions, ObjectPool<? extends io.netty.channel.EventLoopGroup> groupPool, boolean autoFlowControl, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, long keepAliveTimeNanos, long keepAliveTimeoutNanos, boolean keepAliveWithoutCalls, TransportTracer.Factory transportTracerFactory, NettyChannelBuilder.LocalSocketPicker localSocketPicker, boolean useGetForSafeMethods, Class<? extends SocketAddress> transportSocketType) ProtocolNegotiatorAdapter
(ProtocolNegotiator negotiator)