Uses of Class
io.grpc.CallOptions
Packages that use CallOptions
Package
Description
The gRPC core public API.
Interfaces and implementations that are internal to gRPC.
API for the Stub layer.
-
Uses of CallOptions in dev.enola.core.proto
Methods in dev.enola.core.proto with parameters of type CallOptionsModifier and TypeMethodDescriptionEnolaServiceGrpc.EnolaServiceBlockingStub.build
(Channel channel, CallOptions callOptions) protected EnolaServiceGrpc.EnolaServiceFutureStub
EnolaServiceGrpc.EnolaServiceFutureStub.build
(Channel channel, CallOptions callOptions) protected EnolaServiceGrpc.EnolaServiceStub
EnolaServiceGrpc.EnolaServiceStub.build
(Channel channel, CallOptions callOptions) -
Uses of CallOptions in io.grpc
Fields in io.grpc declared as CallOptionsModifier and TypeFieldDescriptionstatic final CallOptions
CallOptions.DEFAULT
A blankCallOptions
that all fields are not set.Methods in io.grpc that return CallOptionsModifier and TypeMethodDescriptionCallOptions.clearOnReadyThreshold()
Resets to the default number of bytes that must be queued before the call will leave the 'wait for ready' state.CallCredentials.RequestInfo.getCallOptions()
The call options used to call this RPC.ClientStreamTracer.StreamInfo.getCallOptions()
Returns the effective CallOptions of the call.abstract CallOptions
LoadBalancer.PickSubchannelArgs.getCallOptions()
Call options.CallOptions.withAuthority
(String authority) Override the HTTP/2 authority the channel claims to be connecting to.CallOptions.withCallCredentials
(CallCredentials credentials) Returns a newCallOptions
with the given call credentials.CallOptions.withCompression
(String compressorName) Sets the compression to use for the call.CallOptions.withDeadline
(Deadline deadline) Returns a newCallOptions
with the given absolute deadline.CallOptions.withDeadlineAfter
(long duration, TimeUnit unit) Returns a newCallOptions
with a deadline that is after the givenduration
from now.CallOptions.withDeadlineAfter
(Duration duration) CallOptions.withExecutor
(Executor executor) Returns a newCallOptions
withexecutor
to be used instead of the default executor specified withManagedChannelBuilder.executor(java.util.concurrent.Executor)
.CallOptions.withMaxInboundMessageSize
(int maxSize) Sets the maximum allowed message size acceptable from the remote peer.CallOptions.withMaxOutboundMessageSize
(int maxSize) Sets the maximum allowed message size acceptable sent to the remote peer.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.withoutWaitForReady()
Disables 'wait for ready' feature for the call.CallOptions.withStreamTracerFactory
(ClientStreamTracer.Factory factory) Returns a newCallOptions
with aClientStreamTracerFactory
in addition to the existing factories.CallOptions.withWaitForReady()
Enables 'wait for ready' for the call.Methods in io.grpc with parameters of type CallOptionsModifier and TypeMethodDescriptionstatic 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
.ClientStreamTracer.StreamInfo.Builder.setCallOptions
(CallOptions callOptions) Sets the effective CallOptions of the call. -
Uses of CallOptions in io.grpc.internal
Methods in io.grpc.internal that return CallOptionsMethods in io.grpc.internal with parameters of type CallOptionsModifier and TypeMethodDescriptionstatic ClientStreamTracer[]
GrpcUtil.getClientStreamTracers
(CallOptions callOptions, Metadata headers, int previousAttempts, boolean isTransparentRetry) Gets stream tracers based on CallOptions.ClientTransport.newStream
(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) Creates a new stream for sending messages to a remote end-point.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 CallOptionsModifierConstructorDescriptionprotected
AbstractClientStream
(WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, Metadata headers, CallOptions callOptions, boolean useGet) protected
Http2ClientStreamTransportState
(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, CallOptions options) PickSubchannelArgsImpl
(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, LoadBalancer.PickDetailsConsumer pickDetailsConsumer) Creates call args object for given method with its call options, metadata.protected
TransportState
(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, CallOptions options) -
Uses of CallOptions in io.grpc.stub
Methods in io.grpc.stub that return CallOptionsModifier and TypeMethodDescriptionfinal 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 CallOptionsModifier and TypeMethodDescriptionstatic <ReqT,
RespT>
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.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.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 CallOptionsModifierConstructorDescriptionprotected
AbstractAsyncStub
(Channel channel, CallOptions callOptions) protected
AbstractBlockingStub
(Channel channel, CallOptions callOptions) protected
AbstractFutureStub
(Channel channel, CallOptions callOptions) protected
AbstractStub
(Channel channel, CallOptions callOptions) Constructor for use by subclasses.