Uses of Interface
io.grpc.internal.ObjectPool
-
Packages that use ObjectPool Package Description io.grpc.inprocess The in-process transport which is for when a server is in the same process as the client.io.grpc.internal Interfaces and implementations that are internal to gRPC.io.grpc.netty The main transport implementation based on Netty, for both the client and the server.io.grpc.rls -
-
Uses of ObjectPool in io.grpc.inprocess
Fields in io.grpc.inprocess declared as ObjectPool Modifier and Type Field Description private ObjectPool<java.util.concurrent.ScheduledExecutorService>
InProcessServer. schedulerPool
Defaults to be a SharedResourcePool.(package private) ObjectPool<java.util.concurrent.ScheduledExecutorService>
InProcessServerBuilder. schedulerPool
private ObjectPool<java.util.concurrent.ScheduledExecutorService>
InProcessTransport. serverSchedulerPool
Methods in io.grpc.inprocess that return ObjectPool Modifier and Type Method Description (package private) ObjectPool<java.util.concurrent.ScheduledExecutorService>
InProcessServer. getScheduledExecutorServicePool()
-
Uses of ObjectPool in io.grpc.internal
Classes in io.grpc.internal that implement ObjectPool Modifier and Type Class Description class
FixedObjectPool<T>
An object pool that always returns the same instance and does nothing when returning the object.class
SharedResourcePool<T>
An ObjectPool backed by aSharedResourceHolder.Resource
.Fields in io.grpc.internal declared as ObjectPool Modifier and Type Field Description private ObjectPool<? extends java.util.concurrent.Executor>
ManagedChannelImpl. balancerRpcExecutorPool
private static ObjectPool<? extends java.util.concurrent.Executor>
ManagedChannelImplBuilder. DEFAULT_EXECUTOR_POOL
private static ObjectPool<? extends java.util.concurrent.Executor>
ServerImplBuilder. DEFAULT_EXECUTOR_POOL
private ObjectPool<? extends java.util.concurrent.Executor>
ManagedChannelImpl. executorPool
(package private) ObjectPool<? extends java.util.concurrent.Executor>
ManagedChannelImplBuilder. executorPool
private ObjectPool<? extends java.util.concurrent.Executor>
OobChannel. executorPool
private ObjectPool<? extends java.util.concurrent.Executor>
ServerImpl. executorPool
(package private) ObjectPool<? extends java.util.concurrent.Executor>
ServerImplBuilder. executorPool
(package private) ObjectPool<? extends java.util.concurrent.Executor>
ManagedChannelImplBuilder. offloadExecutorPool
private ObjectPool<? extends java.util.concurrent.Executor>
ManagedChannelImpl.ExecutorHolder. pool
Methods in io.grpc.internal that return ObjectPool Modifier and Type Method Description ObjectPool<? extends java.util.concurrent.Executor>
ServerImplBuilder. getExecutorPool()
Returns the internal ExecutorPool for offloading tasks.ObjectPool<? extends java.util.concurrent.Executor>
ManagedChannelImplBuilder. getOffloadExecutorPool()
Returns the internal offload executor pool for offloading tasks.Constructors in io.grpc.internal with parameters of type ObjectPool Constructor Description ExecutorHolder(ObjectPool<? extends java.util.concurrent.Executor> executorPool)
ManagedChannelImpl(ManagedChannelImplBuilder builder, ClientTransportFactory clientTransportFactory, java.net.URI targetUri, NameResolverProvider nameResolverProvider, BackoffPolicy.Provider backoffPolicyProvider, ObjectPool<? extends java.util.concurrent.Executor> balancerRpcExecutorPool, com.google.common.base.Supplier<com.google.common.base.Stopwatch> stopwatchSupplier, java.util.List<ClientInterceptor> interceptors, TimeProvider timeProvider)
OobChannel(java.lang.String authority, ObjectPool<? extends java.util.concurrent.Executor> executorPool, java.util.concurrent.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 ObjectPool Modifier and Type Field Description private ObjectPool<? extends io.netty.channel.EventLoopGroup>
NettyServerBuilder. bossEventLoopGroupPool
private ObjectPool<? extends io.netty.channel.EventLoopGroup>
NettyServer. bossGroupPool
private static ObjectPool<? extends io.netty.channel.EventLoopGroup>
NettyServerBuilder. DEFAULT_BOSS_EVENT_LOOP_GROUP_POOL
private static ObjectPool<? extends io.netty.channel.EventLoopGroup>
NettyChannelBuilder. DEFAULT_EVENT_LOOP_GROUP_POOL
private static ObjectPool<? extends io.netty.channel.EventLoopGroup>
NettyServerBuilder. DEFAULT_WORKER_EVENT_LOOP_GROUP_POOL
private ObjectPool<? extends io.netty.channel.EventLoopGroup>
NettyChannelBuilder. eventLoopGroupPool
private ObjectPool<? extends java.util.concurrent.Executor>
ProtocolNegotiators.ClientTlsProtocolNegotiator. executorPool
private ObjectPool<? extends io.netty.channel.EventLoopGroup>
NettyChannelBuilder.NettyTransportFactory. groupPool
private ObjectPool<? extends io.netty.channel.EventLoopGroup>
NettyServerBuilder. workerEventLoopGroupPool
private ObjectPool<? extends io.netty.channel.EventLoopGroup>
NettyServer. workerGroupPool
Methods in io.grpc.netty with parameters of type ObjectPool Modifier and Type Method Description (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 java.util.concurrent.Executor> executorPool)
(package private) NettyChannelBuilder
NettyChannelBuilder. eventLoopGroupPool(ObjectPool<? extends io.netty.channel.EventLoopGroup> eventLoopGroupPool)
InternalProtocolNegotiator.ProtocolNegotiator
InternalProtocolNegotiator.ServerFactory. newNegotiator(ObjectPool<? extends java.util.concurrent.Executor> offloadExecutorPool)
ProtocolNegotiator
ProtocolNegotiator.ServerFactory. newNegotiator(ObjectPool<? extends java.util.concurrent.Executor> offloadExecutorPool)
Creates a new negotiator.ProtocolNegotiator
ProtocolNegotiators.FixedProtocolNegotiatorServerFactory. newNegotiator(ObjectPool<? extends java.util.concurrent.Executor> offloadExecutorPool)
ProtocolNegotiator
ProtocolNegotiators.PlaintextProtocolNegotiatorServerFactory. newNegotiator(ObjectPool<? extends java.util.concurrent.Executor> offloadExecutorPool)
ProtocolNegotiator
ProtocolNegotiators.TlsProtocolNegotiatorServerFactory. newNegotiator(ObjectPool<? extends java.util.concurrent.Executor> offloadExecutorPool)
static ProtocolNegotiator
ProtocolNegotiators. serverTls(io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends java.util.concurrent.Executor> executorPool)
Create a server TLS handler for HTTP/2 capable of using ALPN/NPN.static InternalProtocolNegotiator.ProtocolNegotiator
InternalProtocolNegotiators. tls(io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends java.util.concurrent.Executor> executorPool, java.util.Optional<java.lang.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 java.util.concurrent.Executor> executorPool, java.util.Optional<java.lang.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 ObjectPool Constructor Description ClientTlsProtocolNegotiator(io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends java.util.concurrent.Executor> executorPool, java.util.Optional<java.lang.Runnable> handshakeCompleteRunnable)
NettyServer(java.util.List<? extends java.net.SocketAddress> addresses, io.netty.channel.ChannelFactory<? extends io.netty.channel.ServerChannel> channelFactory, java.util.Map<io.netty.channel.ChannelOption<?>,?> channelOptions, java.util.Map<io.netty.channel.ChannelOption<?>,?> childChannelOptions, ObjectPool<? extends io.netty.channel.EventLoopGroup> bossGroupPool, ObjectPool<? extends io.netty.channel.EventLoopGroup> workerGroupPool, boolean forceHeapBuffer, ProtocolNegotiator protocolNegotiator, java.util.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)
NettyTransportFactory(ProtocolNegotiator protocolNegotiator, io.netty.channel.ChannelFactory<? extends io.netty.channel.Channel> channelFactory, java.util.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, java.lang.Class<? extends java.net.SocketAddress> transportSocketType)
ServerTlsHandler(io.netty.channel.ChannelHandler next, io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends java.util.concurrent.Executor> executorPool)
-
Uses of ObjectPool in io.grpc.rls
Classes in io.grpc.rls that implement ObjectPool Modifier and Type Class Description private static class
LbPolicyConfiguration.RefCountedChildPolicyWrapper
-