Package io.grpc.internal
Class SubchannelChannel
- java.lang.Object
-
- io.grpc.Channel
-
- io.grpc.internal.SubchannelChannel
-
final class SubchannelChannel extends Channel
-
-
Field Summary
Fields Modifier and Type Field Description private CallTracer
callsTracer
private java.util.concurrent.atomic.AtomicReference<InternalConfigSelector>
configSelector
private java.util.concurrent.ScheduledExecutorService
deadlineCancellationExecutor
private java.util.concurrent.Executor
executor
(package private) static Status
NOT_READY_ERROR
private static FailingClientTransport
notReadyTransport
private InternalSubchannel
subchannel
private ClientCallImpl.ClientStreamProvider
transportProvider
(package private) static Status
WAIT_FOR_READY_ERROR
-
Constructor Summary
Constructors Constructor Description SubchannelChannel(InternalSubchannel subchannel, java.util.concurrent.Executor executor, java.util.concurrent.ScheduledExecutorService deadlineCancellationExecutor, CallTracer callsTracer, java.util.concurrent.atomic.AtomicReference<InternalConfigSelector> configSelector)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
authority()
The authority of the destination this channel connects to.<RequestT,ResponseT>
ClientCall<RequestT,ResponseT>newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor, CallOptions callOptions)
Create aClientCall
to the remote operation specified by the givenMethodDescriptor
.
-
-
-
Field Detail
-
NOT_READY_ERROR
static final Status NOT_READY_ERROR
-
WAIT_FOR_READY_ERROR
static final Status WAIT_FOR_READY_ERROR
-
notReadyTransport
private static final FailingClientTransport notReadyTransport
-
subchannel
private final InternalSubchannel subchannel
-
executor
private final java.util.concurrent.Executor executor
-
deadlineCancellationExecutor
private final java.util.concurrent.ScheduledExecutorService deadlineCancellationExecutor
-
callsTracer
private final CallTracer callsTracer
-
configSelector
private final java.util.concurrent.atomic.AtomicReference<InternalConfigSelector> configSelector
-
transportProvider
private final ClientCallImpl.ClientStreamProvider transportProvider
-
-
Constructor Detail
-
SubchannelChannel
SubchannelChannel(InternalSubchannel subchannel, java.util.concurrent.Executor executor, java.util.concurrent.ScheduledExecutorService deadlineCancellationExecutor, CallTracer callsTracer, java.util.concurrent.atomic.AtomicReference<InternalConfigSelector> configSelector)
-
-
Method Detail
-
newCall
public <RequestT,ResponseT> ClientCall<RequestT,ResponseT> newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor, CallOptions callOptions)
Description copied from class:Channel
Create aClientCall
to the remote operation specified by the givenMethodDescriptor
. The returnedClientCall
does not trigger any remote behavior untilClientCall.start(ClientCall.Listener, Metadata)
is invoked.- Specified by:
newCall
in classChannel
- Parameters:
methodDescriptor
- describes the name and parameter types of the operation to call.callOptions
- runtime options to be applied to this call.- Returns:
- a
ClientCall
bound to the specified method.
-
-