Uses of Class
io.grpc.CallOptions
-
Packages that use CallOptions Package Description io.grpc The gRPC core public API.io.grpc.channelz.v1 io.grpc.health.v1 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.lb.v1 io.grpc.lookup.v1 io.grpc.netty The main transport implementation based on Netty, for both the client and the server.io.grpc.protobuf.services Service definitions and utilities with protobuf dependency for the pre-defined gRPC services.io.grpc.reflection.v1 io.grpc.reflection.v1alpha io.grpc.stub API for the Stub layer. -
-
Uses of CallOptions in io.grpc
Fields in io.grpc declared as CallOptions Modifier and Type Field Description private CallOptionsClientStreamTracer.StreamInfo.Builder. callOptionsprivate CallOptionsClientStreamTracer.StreamInfo. callOptionsstatic CallOptionsCallOptions. DEFAULTA blankCallOptionsthat all fields are not set.Methods in io.grpc that return CallOptions Modifier and Type Method Description private CallOptionsCallOptions.Builder. build()CallOptionsCallOptions. clearOnReadyThreshold()Resets to the default number of bytes that must be queued before the call will leave the 'wait for ready' state.CallOptionsCallCredentials.RequestInfo. getCallOptions()The call options used to call this RPC.CallOptionsClientStreamTracer.StreamInfo. getCallOptions()Returns the effective CallOptions of the call.abstract CallOptionsLoadBalancer.PickSubchannelArgs. getCallOptions()Call options.CallOptionsCallOptions. withAuthority(java.lang.String authority)Override the HTTP/2 authority the channel claims to be connecting to.CallOptionsCallOptions. withCallCredentials(CallCredentials credentials)Returns a newCallOptionswith the given call credentials.CallOptionsCallOptions. withCompression(java.lang.String compressorName)Sets the compression to use for the call.CallOptionsCallOptions. withDeadline(Deadline deadline)Returns a newCallOptionswith the given absolute deadline.CallOptionsCallOptions. withDeadlineAfter(long duration, java.util.concurrent.TimeUnit unit)Returns a newCallOptionswith a deadline that is after the givendurationfrom now.CallOptionsCallOptions. withExecutor(java.util.concurrent.Executor executor)Returns a newCallOptionswithexecutorto be used instead of the default executor specified withManagedChannelBuilder.executor(java.util.concurrent.Executor).CallOptionsCallOptions. withMaxInboundMessageSize(int maxSize)Sets the maximum allowed message size acceptable from the remote peer.CallOptionsCallOptions. withMaxOutboundMessageSize(int maxSize)Sets the maximum allowed message size acceptable sent to the remote peer.CallOptionsCallOptions. withOnReadyThreshold(int numBytes)Specifies how many bytes must be queued before the call is considered not ready to send more messages.<T> CallOptionsCallOptions. withOption(CallOptions.Key<T> key, T value)Sets a custom option.CallOptionsCallOptions. withoutWaitForReady()Disables 'wait for ready' feature for the call.CallOptionsCallOptions. withStreamTracerFactory(ClientStreamTracer.Factory factory)Returns a newCallOptionswith aClientStreamTracerFactoryin addition to the existing factories.CallOptionsCallOptions. withWaitForReady()Enables 'wait for ready' for the call.Methods in io.grpc with parameters of type CallOptions Modifier and Type Method Description static java.lang.BooleanInternalCallOptions. getWaitForReady(CallOptions callOptions)Gets the waitForReady bit ornullif it was never set.<ReqT,RespT>
ClientCall<ReqT,RespT>ClientInterceptor. interceptCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, Channel next)abstract <RequestT,ResponseT>
ClientCall<RequestT,ResponseT>Channel. newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor, CallOptions callOptions)Create aClientCallto the remote operation specified by the givenMethodDescriptor.<ReqT,RespT>
ClientCall<ReqT,RespT>ClientInterceptors.InterceptorChannel. newCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)ClientStreamTracer.StreamInfo.BuilderClientStreamTracer.StreamInfo.Builder. setCallOptions(CallOptions callOptions)Sets the effective CallOptions of the call.private static CallOptions.BuilderCallOptions. toBuilder(CallOptions other)Copy CallOptions.Constructors in io.grpc with parameters of type CallOptions Constructor Description StreamInfo(CallOptions callOptions, int previousAttempts, boolean isTransparentRetry) -
Uses of CallOptions in io.grpc.channelz.v1
Methods in io.grpc.channelz.v1 with parameters of type CallOptions Modifier and Type Method Description protected ChannelzGrpc.ChannelzBlockingStubChannelzGrpc.ChannelzBlockingStub. build(Channel channel, CallOptions callOptions)protected ChannelzGrpc.ChannelzFutureStubChannelzGrpc.ChannelzFutureStub. build(Channel channel, CallOptions callOptions)protected ChannelzGrpc.ChannelzStubChannelzGrpc.ChannelzStub. build(Channel channel, CallOptions callOptions)Constructors in io.grpc.channelz.v1 with parameters of type CallOptions Constructor Description ChannelzBlockingStub(Channel channel, CallOptions callOptions)ChannelzFutureStub(Channel channel, CallOptions callOptions)ChannelzStub(Channel channel, CallOptions callOptions) -
Uses of CallOptions in io.grpc.health.v1
Methods in io.grpc.health.v1 with parameters of type CallOptions Modifier and Type Method Description protected HealthGrpc.HealthBlockingStubHealthGrpc.HealthBlockingStub. build(Channel channel, CallOptions callOptions)protected HealthGrpc.HealthFutureStubHealthGrpc.HealthFutureStub. build(Channel channel, CallOptions callOptions)protected HealthGrpc.HealthStubHealthGrpc.HealthStub. build(Channel channel, CallOptions callOptions)Constructors in io.grpc.health.v1 with parameters of type CallOptions Constructor Description HealthBlockingStub(Channel channel, CallOptions callOptions)HealthFutureStub(Channel channel, CallOptions callOptions)HealthStub(Channel channel, CallOptions callOptions) -
Uses of CallOptions in io.grpc.inprocess
Fields in io.grpc.inprocess declared as CallOptions Modifier and Type Field Description private CallOptionsInProcessTransport.InProcessStream. callOptions(package private) CallOptionsInProcessTransport.InProcessStream.InProcessClientStream. callOptionsMethods in io.grpc.inprocess with parameters of type CallOptions Modifier and Type Method Description ClientStreamInProcessTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)Constructors in io.grpc.inprocess with parameters of type CallOptions Constructor Description InProcessClientStream(CallOptions callOptions, StatsTraceContext statsTraceContext)InProcessStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, java.lang.String authority, StatsTraceContext statsTraceContext) -
Uses of CallOptions in io.grpc.internal
Fields in io.grpc.internal declared as CallOptions Modifier and Type Field Description private CallOptionsClientCallImpl. callOptionsprivate CallOptionsManagedChannelImpl.ConfigSelectingClientCall. callOptions(package private) CallOptionsManagedChannelImpl.RealChannel.PendingCall. callOptionsprivate CallOptionsMetadataApplierImpl. callOptionsprivate CallOptionsPickSubchannelArgsImpl. callOptionsMethods in io.grpc.internal that return CallOptions Modifier and Type Method Description CallOptionsPickSubchannelArgsImpl. getCallOptions()Methods in io.grpc.internal with parameters of type CallOptions Modifier and Type Method Description private java.util.concurrent.ExecutorManagedChannelImpl. getCallExecutor(CallOptions callOptions)static ClientStreamTracer[]GrpcUtil. getClientStreamTracers(CallOptions callOptions, Metadata headers, int previousAttempts, boolean isTransparentRetry)Gets stream tracers based on CallOptions.<ReqT,RespT>
ClientCall<ReqT,RespT>ManagedChannelImplBuilder.InterceptorFactoryWrapper. interceptCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, Channel next)<RequestT,ResponseT>
ClientCall<RequestT,ResponseT>ForwardingManagedChannel. newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor, CallOptions callOptions)<ReqT,RespT>
ClientCall<ReqT,RespT>ManagedChannelImpl. newCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)<ReqT,RespT>
ClientCall<ReqT,RespT>ManagedChannelImpl.RealChannel. newCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)<RequestT,ResponseT>
ClientCall<RequestT,ResponseT>OobChannel. newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor, CallOptions callOptions)<RequestT,ResponseT>
ClientCall<RequestT,ResponseT>SubchannelChannel. newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor, CallOptions callOptions)private <ReqT,RespT>
ClientCall<ReqT,RespT>ManagedChannelImpl.RealChannel. newClientCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)ClientStreamCallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)ClientStreamClientCallImpl.ClientStreamProvider. newStream(MethodDescriptor<?,?> method, CallOptions callOptions, Metadata headers, Context context)ClientStreamClientTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)Creates a new stream for sending messages to a remote end-point.ClientStreamDelayedClientTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)If aLoadBalancer.SubchannelPickeris being, or has been provided viaDelayedClientTransport.reprocess(io.grpc.LoadBalancer.SubchannelPicker), the last picker will be consulted.ClientStreamFailingClientTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)ClientStreamForwardingConnectionClientTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)ClientStreamInternalSubchannel.CallTracingTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)ClientStreamManagedChannelImpl.ChannelStreamProvider. newStream(MethodDescriptor<?,?> method, CallOptions callOptions, Metadata headers, Context context)static booleanGrpcUtil. shouldBeCountedForInUse(CallOptions callOptions)Returns true if an RPC with the given properties should be counted when calculating the in-use state of a transport.Constructors in io.grpc.internal with parameters of type CallOptions Constructor Description AbstractClientStream(WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, Metadata headers, CallOptions callOptions, boolean useGet)ClientCallImpl(MethodDescriptor<ReqT,RespT> method, java.util.concurrent.Executor executor, CallOptions callOptions, ClientCallImpl.ClientStreamProvider clientStreamProvider, java.util.concurrent.ScheduledExecutorService deadlineCancellationExecutor, CallTracer channelCallsTracer, InternalConfigSelector configSelector)ConfigSelectingClientCall(InternalConfigSelector configSelector, Channel channel, java.util.concurrent.Executor channelExecutor, MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)Http2ClientStreamTransportState(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, CallOptions options)MetadataApplierImpl(ClientTransport transport, MethodDescriptor<?,?> method, Metadata origHeaders, CallOptions callOptions, MetadataApplierImpl.MetadataApplierListener listener, ClientStreamTracer[] tracers)PendingCall(Context context, MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)PickSubchannelArgsImpl(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, LoadBalancer.PickDetailsConsumer pickDetailsConsumer)Creates call args object for given method with its call options, metadata.TransportState(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, CallOptions options) -
Uses of CallOptions in io.grpc.lb.v1
Methods in io.grpc.lb.v1 with parameters of type CallOptions Modifier and Type Method Description protected LoadBalancerGrpc.LoadBalancerBlockingStubLoadBalancerGrpc.LoadBalancerBlockingStub. build(Channel channel, CallOptions callOptions)protected LoadBalancerGrpc.LoadBalancerFutureStubLoadBalancerGrpc.LoadBalancerFutureStub. build(Channel channel, CallOptions callOptions)protected LoadBalancerGrpc.LoadBalancerStubLoadBalancerGrpc.LoadBalancerStub. build(Channel channel, CallOptions callOptions)Constructors in io.grpc.lb.v1 with parameters of type CallOptions Constructor Description LoadBalancerBlockingStub(Channel channel, CallOptions callOptions)LoadBalancerFutureStub(Channel channel, CallOptions callOptions)LoadBalancerStub(Channel channel, CallOptions callOptions) -
Uses of CallOptions in io.grpc.lookup.v1
Methods in io.grpc.lookup.v1 with parameters of type CallOptions Modifier and Type Method Description protected RouteLookupServiceGrpc.RouteLookupServiceBlockingStubRouteLookupServiceGrpc.RouteLookupServiceBlockingStub. build(Channel channel, CallOptions callOptions)protected RouteLookupServiceGrpc.RouteLookupServiceFutureStubRouteLookupServiceGrpc.RouteLookupServiceFutureStub. build(Channel channel, CallOptions callOptions)protected RouteLookupServiceGrpc.RouteLookupServiceStubRouteLookupServiceGrpc.RouteLookupServiceStub. build(Channel channel, CallOptions callOptions)Constructors in io.grpc.lookup.v1 with parameters of type CallOptions Constructor Description RouteLookupServiceBlockingStub(Channel channel, CallOptions callOptions)RouteLookupServiceFutureStub(Channel channel, CallOptions callOptions)RouteLookupServiceStub(Channel channel, CallOptions callOptions) -
Uses of CallOptions in io.grpc.netty
Methods in io.grpc.netty with parameters of type CallOptions Modifier and Type Method Description ClientStreamNettyClientTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)Constructors in io.grpc.netty with parameters of type CallOptions Constructor Description NettyClientStream(NettyClientStream.TransportState state, MethodDescriptor<?,?> method, Metadata headers, io.netty.channel.Channel channel, io.netty.util.AsciiString authority, io.netty.util.AsciiString scheme, io.netty.util.AsciiString userAgent, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, CallOptions callOptions, boolean useGetForSafeMethods)TransportState(NettyClientHandler handler, io.netty.channel.EventLoop eventLoop, int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, java.lang.String methodName, CallOptions options) -
Uses of CallOptions in io.grpc.protobuf.services
Methods in io.grpc.protobuf.services with parameters of type CallOptions Modifier and Type Method Description protected abstract ClientInterceptorBinaryLogProvider. getClientInterceptor(java.lang.String fullMethodName, CallOptions callOptions)Returns aClientInterceptorfor binary logging.ClientInterceptorBinaryLogProviderImpl. getClientInterceptor(java.lang.String fullMethodName, CallOptions callOptions)<ReqT,RespT>
ClientCall<ReqT,RespT>BinaryLogProvider.BinaryLogShim. interceptCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, Channel next) -
Uses of CallOptions in io.grpc.reflection.v1
Methods in io.grpc.reflection.v1 with parameters of type CallOptions Modifier and Type Method Description protected ServerReflectionGrpc.ServerReflectionBlockingStubServerReflectionGrpc.ServerReflectionBlockingStub. build(Channel channel, CallOptions callOptions)protected ServerReflectionGrpc.ServerReflectionFutureStubServerReflectionGrpc.ServerReflectionFutureStub. build(Channel channel, CallOptions callOptions)protected ServerReflectionGrpc.ServerReflectionStubServerReflectionGrpc.ServerReflectionStub. build(Channel channel, CallOptions callOptions)Constructors in io.grpc.reflection.v1 with parameters of type CallOptions Constructor Description ServerReflectionBlockingStub(Channel channel, CallOptions callOptions)ServerReflectionFutureStub(Channel channel, CallOptions callOptions)ServerReflectionStub(Channel channel, CallOptions callOptions) -
Uses of CallOptions in io.grpc.reflection.v1alpha
Methods in io.grpc.reflection.v1alpha with parameters of type CallOptions Modifier and Type Method Description protected ServerReflectionGrpc.ServerReflectionBlockingStubServerReflectionGrpc.ServerReflectionBlockingStub. build(Channel channel, CallOptions callOptions)protected ServerReflectionGrpc.ServerReflectionFutureStubServerReflectionGrpc.ServerReflectionFutureStub. build(Channel channel, CallOptions callOptions)protected ServerReflectionGrpc.ServerReflectionStubServerReflectionGrpc.ServerReflectionStub. build(Channel channel, CallOptions callOptions)Constructors in io.grpc.reflection.v1alpha with parameters of type CallOptions Constructor Description ServerReflectionBlockingStub(Channel channel, CallOptions callOptions)ServerReflectionFutureStub(Channel channel, CallOptions callOptions)ServerReflectionStub(Channel channel, CallOptions callOptions) -
Uses of CallOptions in io.grpc.stub
Fields in io.grpc.stub declared as CallOptions Modifier and Type Field Description private CallOptionsAbstractStub. callOptionsMethods in io.grpc.stub that return CallOptions Modifier and Type Method Description CallOptionsAbstractStub. getCallOptions()TheCallOptionsof the stub.static CallOptionsInternalClientCalls. setStubType(CallOptions callOptions, InternalClientCalls.StubType stubType)ReturnsCallOptionswith the correspondingClientCalls.StubTypeset.Methods in io.grpc.stub with parameters of type CallOptions Modifier and Type Method Description static <ReqT,RespT>
java.util.Iterator<RespT>ClientCalls. blockingServerStreamingCall(Channel channel, MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, ReqT req)Executes a server-streaming call returning a blockingIteratorover the response stream.static <ReqT,RespT>
RespTClientCalls. blockingUnaryCall(Channel channel, MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, ReqT req)Executes a unary call and blocks on the response.protected abstract SAbstractStub. build(Channel channel, CallOptions callOptions)Returns a new stub with the given channel for the provided method configurations.static InternalClientCalls.StubTypeInternalClientCalls. getStubType(CallOptions callOptions)ReturnsInternalClientCalls.StubTypefrom call options.<ReqT,RespT>
ClientCall<ReqT,RespT>MetadataUtils.HeaderAttachingClientInterceptor. interceptCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, Channel next)<ReqT,RespT>
ClientCall<ReqT,RespT>MetadataUtils.MetadataCapturingClientInterceptor. interceptCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, Channel next)static <T extends AbstractStub<T>>
TAbstractAsyncStub. newStub(AbstractStub.StubFactory<T> factory, Channel channel, CallOptions callOptions)Returns a new async stub with the given channel for the provided method configurations.static <T extends AbstractStub<T>>
TAbstractBlockingStub. newStub(AbstractStub.StubFactory<T> factory, Channel channel, CallOptions callOptions)Returns a new blocking stub with the given channel for the provided method configurations.static <T extends AbstractStub<T>>
TAbstractFutureStub. newStub(AbstractStub.StubFactory<T> factory, Channel channel, CallOptions callOptions)Returns a new future stub with the given channel for the provided method configurations.static <T extends AbstractStub<T>>
TAbstractStub. newStub(AbstractStub.StubFactory<T> factory, Channel channel, CallOptions callOptions)Returns a new stub with the given channel for the provided method configurations.TAbstractStub.StubFactory. newStub(Channel channel, CallOptions callOptions)static CallOptionsInternalClientCalls. setStubType(CallOptions callOptions, InternalClientCalls.StubType stubType)ReturnsCallOptionswith the correspondingClientCalls.StubTypeset.Constructors in io.grpc.stub with parameters of type CallOptions Constructor Description AbstractAsyncStub(Channel channel, CallOptions callOptions)AbstractBlockingStub(Channel channel, CallOptions callOptions)AbstractFutureStub(Channel channel, CallOptions callOptions)AbstractStub(Channel channel, CallOptions callOptions)Constructor for use by subclasses.
-