Package | Description |
---|---|
io.grpc |
The gRPC core public API.
|
io.grpc.internal |
Interfaces and implementations that are internal to gRPC.
|
Modifier and Type | Field and Description |
---|---|
static CallOptions |
CallOptions.DEFAULT
A blank
CallOptions that all fields are not set. |
Modifier and Type | Method and Description |
---|---|
abstract CallOptions |
LoadBalancer.PickSubchannelArgs.getCallOptions()
Call options.
|
abstract CallOptions |
ClientStreamTracer.StreamInfo.getCallOptions()
Returns the effective CallOptions of the call.
|
CallOptions |
CallOptions.withAuthority(String authority)
Override the HTTP/2 authority the channel claims to be connecting to.
|
CallOptions |
CallOptions.withCallCredentials(CallCredentials credentials)
Returns a new
CallOptions with the given call credentials. |
CallOptions |
CallOptions.withCompression(String compressorName)
Sets the compression to use for the call.
|
CallOptions |
CallOptions.withDeadline(Deadline deadline)
Returns a new
CallOptions with the given absolute deadline. |
CallOptions |
CallOptions.withDeadlineAfter(long duration,
TimeUnit unit)
Returns a new
CallOptions with a deadline that is after the given duration from
now. |
CallOptions |
CallOptions.withExecutor(Executor executor)
Returns a new
CallOptions with executor to be used instead of the default
executor specified with ManagedChannelBuilder.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.
|
<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 new
CallOptions with a ClientStreamTracerFactory in addition to
the existing factories. |
CallOptions |
CallOptions.withWaitForReady()
Enables
'wait for ready' feature for the call.
|
Modifier and Type | Method and Description |
---|---|
<ReqT,RespT> |
ClientInterceptor.interceptCall(MethodDescriptor<ReqT,RespT> method,
CallOptions callOptions,
Channel next)
|
abstract <RequestT,ResponseT> |
Channel.newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor,
CallOptions callOptions)
Create a
ClientCall to the remote operation specified by the given
MethodDescriptor . |
ClientStreamTracer |
ClientStreamTracer.Factory.newClientStreamTracer(CallOptions callOptions,
Metadata headers)
Deprecated.
use
#newClientStreamTracer(StreamInfo, Metadata) instead |
Modifier and Type | Method and Description |
---|---|
static StatsTraceContext |
StatsTraceContext.newClientContext(CallOptions callOptions,
Attributes transportAttrs,
Metadata headers)
Factory method for the client-side.
|
ClientStream |
ClientTransport.newStream(MethodDescriptor<?,?> method,
Metadata headers,
CallOptions callOptions)
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.
|
Constructor and Description |
---|
AbstractClientStream(WritableBufferAllocator bufferAllocator,
StatsTraceContext statsTraceCtx,
TransportTracer transportTracer,
Metadata headers,
CallOptions callOptions,
boolean useGet) |
Copyright © 2019. All rights reserved.