Uses of Interface
io.grpc.internal.ObjectPool
Packages that use ObjectPool
Package
Description
The in-process transport which is for when a server is in the same process as the client.
Interfaces and implementations that are internal to gRPC.
The main transport implementation based on Netty,
for both the client and the server.
-
Uses of ObjectPool in io.grpc.inprocess
Fields in io.grpc.inprocess declared as ObjectPoolModifier and TypeFieldDescriptionprivate final ObjectPool
<ScheduledExecutorService> InProcessServer.schedulerPool
Defaults to be a SharedResourcePool.(package private) ObjectPool
<ScheduledExecutorService> InProcessServerBuilder.schedulerPool
private ObjectPool
<ScheduledExecutorService> InProcessTransport.serverSchedulerPool
Methods in io.grpc.inprocess that return ObjectPoolModifier and TypeMethodDescription(package private) ObjectPool
<ScheduledExecutorService> InProcessServer.getScheduledExecutorServicePool()
-
Uses of ObjectPool in io.grpc.internal
Classes in io.grpc.internal that implement ObjectPoolModifier and TypeClassDescriptionfinal class
An object pool that always returns the same instance and does nothing when returning the object.final class
An ObjectPool backed by aSharedResourceHolder.Resource
.Fields in io.grpc.internal declared as ObjectPoolModifier and TypeFieldDescriptionprivate final ObjectPool
<? extends Executor> ManagedChannelImpl.balancerRpcExecutorPool
private static final ObjectPool
<? extends Executor> ManagedChannelImplBuilder.DEFAULT_EXECUTOR_POOL
private static final ObjectPool
<? extends Executor> ServerImplBuilder.DEFAULT_EXECUTOR_POOL
private final ObjectPool
<? extends Executor> ManagedChannelImpl.executorPool
(package private) ObjectPool
<? extends Executor> ManagedChannelImplBuilder.executorPool
private final ObjectPool
<? extends Executor> OobChannel.executorPool
private final ObjectPool
<? extends Executor> ServerImpl.executorPool
(package private) ObjectPool
<? extends Executor> ServerImplBuilder.executorPool
(package private) ObjectPool
<? extends Executor> ManagedChannelImplBuilder.offloadExecutorPool
private final ObjectPool
<? extends Executor> ManagedChannelImpl.ExecutorHolder.pool
Methods in io.grpc.internal that return ObjectPoolModifier and TypeMethodDescriptionObjectPool
<? extends Executor> ServerImplBuilder.getExecutorPool()
Returns the internal ExecutorPool for offloading tasks.ObjectPool
<? extends Executor> ManagedChannelImplBuilder.getOffloadExecutorPool()
Returns the internal offload executor pool for offloading tasks.Constructors in io.grpc.internal with parameters of type ObjectPoolModifierConstructorDescription(package private)
ExecutorHolder
(ObjectPool<? extends Executor> executorPool) (package private)
ManagedChannelImpl
(ManagedChannelImplBuilder builder, ClientTransportFactory clientTransportFactory, URI targetUri, NameResolverProvider nameResolverProvider, BackoffPolicy.Provider backoffPolicyProvider, ObjectPool<? extends Executor> balancerRpcExecutorPool, com.google.common.base.Supplier<com.google.common.base.Stopwatch> stopwatchSupplier, List<ClientInterceptor> interceptors, TimeProvider timeProvider) (package private)
OobChannel
(String authority, ObjectPool<? extends Executor> executorPool, ScheduledExecutorService deadlineCancellationExecutor, SynchronizationContext syncContext, CallTracer callsTracer, ChannelTracer channelTracer, InternalChannelz channelz, TimeProvider timeProvider) -
Uses of ObjectPool in io.grpc.netty
Fields in io.grpc.netty declared as ObjectPoolModifier and TypeFieldDescriptionprivate ObjectPool
<? extends io.netty.channel.EventLoopGroup> NettyServerBuilder.bossEventLoopGroupPool
private final ObjectPool
<? extends io.netty.channel.EventLoopGroup> NettyServer.bossGroupPool
private static final ObjectPool
<? extends io.netty.channel.EventLoopGroup> NettyServerBuilder.DEFAULT_BOSS_EVENT_LOOP_GROUP_POOL
private static final ObjectPool
<? extends io.netty.channel.EventLoopGroup> NettyChannelBuilder.DEFAULT_EVENT_LOOP_GROUP_POOL
private static final ObjectPool
<? extends io.netty.channel.EventLoopGroup> NettyServerBuilder.DEFAULT_WORKER_EVENT_LOOP_GROUP_POOL
private ObjectPool
<? extends io.netty.channel.EventLoopGroup> NettyChannelBuilder.eventLoopGroupPool
private final ObjectPool
<? extends Executor> ProtocolNegotiators.ClientTlsProtocolNegotiator.executorPool
private final ObjectPool
<? extends io.netty.channel.EventLoopGroup> NettyChannelBuilder.NettyTransportFactory.groupPool
private ObjectPool
<? extends io.netty.channel.EventLoopGroup> NettyServerBuilder.workerEventLoopGroupPool
private final ObjectPool
<? extends io.netty.channel.EventLoopGroup> NettyServer.workerGroupPool
Methods in io.grpc.netty with parameters of type ObjectPoolModifier and TypeMethodDescription(package private) NettyServerBuilder
NettyServerBuilder.bossEventLoopGroupPool
(ObjectPool<? extends io.netty.channel.EventLoopGroup> bossEventLoopGroupPool) (package private) static ProtocolNegotiator
NettyChannelBuilder.createProtocolNegotiatorByType
(NegotiationType negotiationType, io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends Executor> executorPool) (package private) NettyChannelBuilder
NettyChannelBuilder.eventLoopGroupPool
(ObjectPool<? extends io.netty.channel.EventLoopGroup> eventLoopGroupPool) InternalProtocolNegotiator.ServerFactory.newNegotiator
(ObjectPool<? extends Executor> offloadExecutorPool) ProtocolNegotiator.ServerFactory.newNegotiator
(ObjectPool<? extends Executor> offloadExecutorPool) Creates a new negotiator.ProtocolNegotiators.FixedProtocolNegotiatorServerFactory.newNegotiator
(ObjectPool<? extends Executor> offloadExecutorPool) ProtocolNegotiators.PlaintextProtocolNegotiatorServerFactory.newNegotiator
(ObjectPool<? extends Executor> offloadExecutorPool) ProtocolNegotiators.TlsProtocolNegotiatorServerFactory.newNegotiator
(ObjectPool<? extends Executor> offloadExecutorPool) 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.InternalProtocolNegotiators.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.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.(package private) NettyServerBuilder
NettyServerBuilder.workerEventLoopGroupPool
(ObjectPool<? extends io.netty.channel.EventLoopGroup> workerEventLoopGroupPool) Constructors in io.grpc.netty with parameters of type ObjectPoolModifierConstructorDescriptionClientTlsProtocolNegotiator
(io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends Executor> executorPool, Optional<Runnable> handshakeCompleteRunnable) (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)
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) (package private)
ServerTlsHandler
(io.netty.channel.ChannelHandler next, io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends Executor> executorPool) -
Uses of ObjectPool in io.grpc.rls
Classes in io.grpc.rls that implement ObjectPoolModifier and TypeClassDescriptionprivate static final class