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. schedulerPoolDefaults to be a SharedResourcePool.(package private) ObjectPool<java.util.concurrent.ScheduledExecutorService>InProcessServerBuilder. schedulerPoolprivate ObjectPool<java.util.concurrent.ScheduledExecutorService>InProcessTransport. serverSchedulerPoolMethods 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 classFixedObjectPool<T>An object pool that always returns the same instance and does nothing when returning the object.classSharedResourcePool<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. balancerRpcExecutorPoolprivate static ObjectPool<? extends java.util.concurrent.Executor>ManagedChannelImplBuilder. DEFAULT_EXECUTOR_POOLprivate static ObjectPool<? extends java.util.concurrent.Executor>ServerImplBuilder. DEFAULT_EXECUTOR_POOLprivate ObjectPool<? extends java.util.concurrent.Executor>ManagedChannelImpl. executorPool(package private) ObjectPool<? extends java.util.concurrent.Executor>ManagedChannelImplBuilder. executorPoolprivate ObjectPool<? extends java.util.concurrent.Executor>OobChannel. executorPoolprivate 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. offloadExecutorPoolprivate ObjectPool<? extends java.util.concurrent.Executor>ManagedChannelImpl.ExecutorHolder. poolMethods 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. bossEventLoopGroupPoolprivate ObjectPool<? extends io.netty.channel.EventLoopGroup>NettyServer. bossGroupPoolprivate static ObjectPool<? extends io.netty.channel.EventLoopGroup>NettyServerBuilder. DEFAULT_BOSS_EVENT_LOOP_GROUP_POOLprivate static ObjectPool<? extends io.netty.channel.EventLoopGroup>NettyChannelBuilder. DEFAULT_EVENT_LOOP_GROUP_POOLprivate static ObjectPool<? extends io.netty.channel.EventLoopGroup>NettyServerBuilder. DEFAULT_WORKER_EVENT_LOOP_GROUP_POOLprivate ObjectPool<? extends io.netty.channel.EventLoopGroup>NettyChannelBuilder. eventLoopGroupPoolprivate ObjectPool<? extends java.util.concurrent.Executor>ProtocolNegotiators.ClientTlsProtocolNegotiator. executorPoolprivate ObjectPool<? extends io.netty.channel.EventLoopGroup>NettyChannelBuilder.NettyTransportFactory. groupPoolprivate ObjectPool<? extends io.netty.channel.EventLoopGroup>NettyServerBuilder. workerEventLoopGroupPoolprivate ObjectPool<? extends io.netty.channel.EventLoopGroup>NettyServer. workerGroupPoolMethods in io.grpc.netty with parameters of type ObjectPool Modifier and Type Method Description (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 java.util.concurrent.Executor> executorPool)(package private) NettyChannelBuilderNettyChannelBuilder. eventLoopGroupPool(ObjectPool<? extends io.netty.channel.EventLoopGroup> eventLoopGroupPool)InternalProtocolNegotiator.ProtocolNegotiatorInternalProtocolNegotiator.ServerFactory. newNegotiator(ObjectPool<? extends java.util.concurrent.Executor> offloadExecutorPool)ProtocolNegotiatorProtocolNegotiator.ServerFactory. newNegotiator(ObjectPool<? extends java.util.concurrent.Executor> offloadExecutorPool)Creates a new negotiator.ProtocolNegotiatorProtocolNegotiators.FixedProtocolNegotiatorServerFactory. newNegotiator(ObjectPool<? extends java.util.concurrent.Executor> offloadExecutorPool)ProtocolNegotiatorProtocolNegotiators.PlaintextProtocolNegotiatorServerFactory. newNegotiator(ObjectPool<? extends java.util.concurrent.Executor> offloadExecutorPool)ProtocolNegotiatorProtocolNegotiators.TlsProtocolNegotiatorServerFactory. newNegotiator(ObjectPool<? extends java.util.concurrent.Executor> offloadExecutorPool)static ProtocolNegotiatorProtocolNegotiators. 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.ProtocolNegotiatorInternalProtocolNegotiators. tls(io.netty.handler.ssl.SslContext sslContext, ObjectPool<? extends java.util.concurrent.Executor> executorPool, java.util.Optional<java.lang.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 java.util.concurrent.Executor> executorPool, java.util.Optional<java.lang.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 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 classLbPolicyConfiguration.RefCountedChildPolicyWrapper
-