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.schedulerPoolDefaults to be a SharedResourcePool.(package private) ObjectPool<ScheduledExecutorService> InProcessServerBuilder.schedulerPoolprivate ObjectPool<ScheduledExecutorService> InProcessTransport.serverSchedulerPoolMethods 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 classAn object pool that always returns the same instance and does nothing when returning the object.final classAn ObjectPool backed by aSharedResourceHolder.Resource.Fields in io.grpc.internal declared as ObjectPoolModifier and TypeFieldDescriptionprivate final ObjectPool<? extends Executor> ManagedChannelImpl.balancerRpcExecutorPoolprivate static final ObjectPool<? extends Executor> ManagedChannelImplBuilder.DEFAULT_EXECUTOR_POOLprivate static final ObjectPool<? extends Executor> ServerImplBuilder.DEFAULT_EXECUTOR_POOLprivate final ObjectPool<? extends Executor> ManagedChannelImpl.executorPool(package private) ObjectPool<? extends Executor> ManagedChannelImplBuilder.executorPoolprivate final ObjectPool<? extends Executor> OobChannel.executorPoolprivate final ObjectPool<? extends Executor> ServerImpl.executorPool(package private) ObjectPool<? extends Executor> ServerImplBuilder.executorPool(package private) ObjectPool<? extends Executor> ManagedChannelImplBuilder.offloadExecutorPoolprivate final ObjectPool<? extends Executor> ManagedChannelImpl.ExecutorHolder.poolMethods 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.bossEventLoopGroupPoolprivate final ObjectPool<? extends io.netty.channel.EventLoopGroup> NettyServer.bossGroupPoolprivate static final ObjectPool<? extends io.netty.channel.EventLoopGroup> NettyServerBuilder.DEFAULT_BOSS_EVENT_LOOP_GROUP_POOLprivate static final ObjectPool<? extends io.netty.channel.EventLoopGroup> NettyChannelBuilder.DEFAULT_EVENT_LOOP_GROUP_POOLprivate static final ObjectPool<? extends io.netty.channel.EventLoopGroup> NettyServerBuilder.DEFAULT_WORKER_EVENT_LOOP_GROUP_POOLprivate ObjectPool<? extends io.netty.channel.EventLoopGroup> NettyChannelBuilder.eventLoopGroupPoolprivate final ObjectPool<? extends Executor> ProtocolNegotiators.ClientTlsProtocolNegotiator.executorPoolprivate final ObjectPool<? extends io.netty.channel.EventLoopGroup> NettyChannelBuilder.NettyTransportFactory.groupPoolprivate ObjectPool<? extends io.netty.channel.EventLoopGroup> NettyServerBuilder.workerEventLoopGroupPoolprivate final ObjectPool<? extends io.netty.channel.EventLoopGroup> NettyServer.workerGroupPoolMethods in io.grpc.netty with parameters of type ObjectPoolModifier and TypeMethodDescription(package private) NettyServerBuilderNettyServerBuilder.bossEventLoopGroupPool(ObjectPool<? extends io.netty.channel.EventLoopGroup> bossEventLoopGroupPool) (package private) static ProtocolNegotiatorNettyChannelBuilder.createProtocolNegotiatorByType(NegotiationType negotiationType, io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends Executor> executorPool) (package private) NettyChannelBuilderNettyChannelBuilder.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 ProtocolNegotiatorProtocolNegotiators.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 aProtocolNegotiatorthat ensures the pipeline is set up so that TLS will be negotiated, thehandleris added and writes to theChannelmay happen immediately, even before the TLS Handshake is complete.static ProtocolNegotiatorProtocolNegotiators.tls(io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends Executor> executorPool, Optional<Runnable> handshakeCompleteRunnable) Returns aProtocolNegotiatorthat ensures the pipeline is set up so that TLS will be negotiated, thehandleris added and writes to theChannelmay happen immediately, even before the TLS Handshake is complete.(package private) NettyServerBuilderNettyServerBuilder.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