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 CallOptions
ClientStreamTracer.StreamInfo.Builder. callOptions
private CallOptions
ClientStreamTracer.StreamInfo. callOptions
static CallOptions
CallOptions. DEFAULT
A blankCallOptions
that all fields are not set.Methods in io.grpc that return CallOptions Modifier and Type Method Description private CallOptions
CallOptions.Builder. build()
CallOptions
CallOptions. clearOnReadyThreshold()
Resets to the default number of bytes that must be queued before the call will leave the 'wait for ready' state.CallOptions
CallCredentials.RequestInfo. getCallOptions()
The call options used to call this RPC.CallOptions
ClientStreamTracer.StreamInfo. getCallOptions()
Returns the effective CallOptions of the call.abstract CallOptions
LoadBalancer.PickSubchannelArgs. getCallOptions()
Call options.CallOptions
CallOptions. withAuthority(java.lang.String authority)
Override the HTTP/2 authority the channel claims to be connecting to.CallOptions
CallOptions. withCallCredentials(CallCredentials credentials)
Returns a newCallOptions
with the given call credentials.CallOptions
CallOptions. withCompression(java.lang.String compressorName)
Sets the compression to use for the call.CallOptions
CallOptions. withDeadline(Deadline deadline)
Returns a newCallOptions
with the given absolute deadline.CallOptions
CallOptions. withDeadlineAfter(long duration, java.util.concurrent.TimeUnit unit)
Returns a newCallOptions
with a deadline that is after the givenduration
from now.CallOptions
CallOptions. withExecutor(java.util.concurrent.Executor executor)
Returns a newCallOptions
withexecutor
to be used instead of the default executor specified withManagedChannelBuilder.executor(java.util.concurrent.Executor)
.CallOptions
CallOptions. withMaxInboundMessageSize(int maxSize)
Sets the maximum allowed message size acceptable from the remote peer.CallOptions
CallOptions. withMaxOutboundMessageSize(int maxSize)
Sets the maximum allowed message size acceptable sent to the remote peer.CallOptions
CallOptions. withOnReadyThreshold(int numBytes)
Specifies how many bytes must be queued before the call is considered not ready to send more messages.<T> CallOptions
CallOptions. withOption(CallOptions.Key<T> key, T value)
Sets a custom option.CallOptions
CallOptions. withoutWaitForReady()
Disables 'wait for ready' feature for the call.CallOptions
CallOptions. withStreamTracerFactory(ClientStreamTracer.Factory factory)
Returns a newCallOptions
with aClientStreamTracerFactory
in addition to the existing factories.CallOptions
CallOptions. 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.Boolean
InternalCallOptions. getWaitForReady(CallOptions callOptions)
Gets the waitForReady bit ornull
if 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 aClientCall
to the remote operation specified by the givenMethodDescriptor
.<ReqT,RespT>
ClientCall<ReqT,RespT>ClientInterceptors.InterceptorChannel. newCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)
ClientStreamTracer.StreamInfo.Builder
ClientStreamTracer.StreamInfo.Builder. setCallOptions(CallOptions callOptions)
Sets the effective CallOptions of the call.private static CallOptions.Builder
CallOptions. 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.ChannelzBlockingStub
ChannelzGrpc.ChannelzBlockingStub. build(Channel channel, CallOptions callOptions)
protected ChannelzGrpc.ChannelzFutureStub
ChannelzGrpc.ChannelzFutureStub. build(Channel channel, CallOptions callOptions)
protected ChannelzGrpc.ChannelzStub
ChannelzGrpc.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.HealthBlockingStub
HealthGrpc.HealthBlockingStub. build(Channel channel, CallOptions callOptions)
protected HealthGrpc.HealthFutureStub
HealthGrpc.HealthFutureStub. build(Channel channel, CallOptions callOptions)
protected HealthGrpc.HealthStub
HealthGrpc.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 CallOptions
InProcessTransport.InProcessStream. callOptions
(package private) CallOptions
InProcessTransport.InProcessStream.InProcessClientStream. callOptions
Methods in io.grpc.inprocess with parameters of type CallOptions Modifier and Type Method Description ClientStream
InProcessTransport. 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 CallOptions
ClientCallImpl. callOptions
private CallOptions
ManagedChannelImpl.ConfigSelectingClientCall. callOptions
(package private) CallOptions
ManagedChannelImpl.RealChannel.PendingCall. callOptions
private CallOptions
MetadataApplierImpl. callOptions
private CallOptions
PickSubchannelArgsImpl. callOptions
Methods in io.grpc.internal that return CallOptions Modifier and Type Method Description CallOptions
PickSubchannelArgsImpl. getCallOptions()
Methods in io.grpc.internal with parameters of type CallOptions Modifier and Type Method Description private java.util.concurrent.Executor
ManagedChannelImpl. 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)
ClientStream
CallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)
ClientStream
ClientCallImpl.ClientStreamProvider. newStream(MethodDescriptor<?,?> method, CallOptions callOptions, Metadata headers, Context context)
ClientStream
ClientTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)
Creates a new stream for sending messages to a remote end-point.ClientStream
DelayedClientTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)
If aLoadBalancer.SubchannelPicker
is being, or has been provided viaDelayedClientTransport.reprocess(io.grpc.LoadBalancer.SubchannelPicker)
, the last picker will be consulted.ClientStream
FailingClientTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)
ClientStream
ForwardingConnectionClientTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)
ClientStream
InternalSubchannel.CallTracingTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)
ClientStream
ManagedChannelImpl.ChannelStreamProvider. newStream(MethodDescriptor<?,?> method, CallOptions callOptions, Metadata headers, Context context)
static boolean
GrpcUtil. 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.LoadBalancerBlockingStub
LoadBalancerGrpc.LoadBalancerBlockingStub. build(Channel channel, CallOptions callOptions)
protected LoadBalancerGrpc.LoadBalancerFutureStub
LoadBalancerGrpc.LoadBalancerFutureStub. build(Channel channel, CallOptions callOptions)
protected LoadBalancerGrpc.LoadBalancerStub
LoadBalancerGrpc.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.RouteLookupServiceBlockingStub
RouteLookupServiceGrpc.RouteLookupServiceBlockingStub. build(Channel channel, CallOptions callOptions)
protected RouteLookupServiceGrpc.RouteLookupServiceFutureStub
RouteLookupServiceGrpc.RouteLookupServiceFutureStub. build(Channel channel, CallOptions callOptions)
protected RouteLookupServiceGrpc.RouteLookupServiceStub
RouteLookupServiceGrpc.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 ClientStream
NettyClientTransport. 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 ClientInterceptor
BinaryLogProvider. getClientInterceptor(java.lang.String fullMethodName, CallOptions callOptions)
Returns aClientInterceptor
for binary logging.ClientInterceptor
BinaryLogProviderImpl. 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.ServerReflectionBlockingStub
ServerReflectionGrpc.ServerReflectionBlockingStub. build(Channel channel, CallOptions callOptions)
protected ServerReflectionGrpc.ServerReflectionFutureStub
ServerReflectionGrpc.ServerReflectionFutureStub. build(Channel channel, CallOptions callOptions)
protected ServerReflectionGrpc.ServerReflectionStub
ServerReflectionGrpc.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.ServerReflectionBlockingStub
ServerReflectionGrpc.ServerReflectionBlockingStub. build(Channel channel, CallOptions callOptions)
protected ServerReflectionGrpc.ServerReflectionFutureStub
ServerReflectionGrpc.ServerReflectionFutureStub. build(Channel channel, CallOptions callOptions)
protected ServerReflectionGrpc.ServerReflectionStub
ServerReflectionGrpc.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 CallOptions
AbstractStub. callOptions
Methods in io.grpc.stub that return CallOptions Modifier and Type Method Description CallOptions
AbstractStub. getCallOptions()
TheCallOptions
of the stub.static CallOptions
InternalClientCalls. setStubType(CallOptions callOptions, InternalClientCalls.StubType stubType)
ReturnsCallOptions
with the correspondingClientCalls.StubType
set.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 blockingIterator
over 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 S
AbstractStub. build(Channel channel, CallOptions callOptions)
Returns a new stub with the given channel for the provided method configurations.static InternalClientCalls.StubType
InternalClientCalls. getStubType(CallOptions callOptions)
ReturnsInternalClientCalls.StubType
from 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.T
AbstractStub.StubFactory. newStub(Channel channel, CallOptions callOptions)
static CallOptions
InternalClientCalls. setStubType(CallOptions callOptions, InternalClientCalls.StubType stubType)
ReturnsCallOptions
with the correspondingClientCalls.StubType
set.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.
-