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 final CallTracer	callsTracer
private final AtomicReference<InternalConfigSelector>	configSelector
private final ScheduledExecutorService	deadlineCancellationExecutor
private final Executor	executor
(package private) static final Status	NOT_READY_ERROR
private static final FailingClientTransport	notReadyTransport
private final InternalSubchannel	subchannel
private final ClientCallImpl.ClientStreamProvider	transportProvider
(package private) static final Status	WAIT_FOR_READY_ERROR

Constructor Summary

Constructors

Constructor	Description
SubchannelChannel(InternalSubchannel subchannel, Executor executor, ScheduledExecutorService deadlineCancellationExecutor, CallTracer callsTracer, AtomicReference<InternalConfigSelector> configSelector)

Method Summary

Modifier and Type	Method	Description
String	authority()	The authority of the destination this channel connects to.
<RequestT, ResponseT> ClientCall<RequestT,ResponseT>	newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor, CallOptions callOptions)	Create a ClientCall to the remote operation specified by the given MethodDescriptor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

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 Executor executor

deadlineCancellationExecutor

private final ScheduledExecutorService deadlineCancellationExecutor

callsTracer

private final CallTracer callsTracer

configSelector

private final AtomicReference<InternalConfigSelector> configSelector

transportProvider

private final ClientCallImpl.ClientStreamProvider transportProvider

Constructor Details

SubchannelChannel

SubchannelChannel(InternalSubchannel subchannel,
 Executor executor,
 ScheduledExecutorService deadlineCancellationExecutor,
 CallTracer callsTracer,
 AtomicReference<InternalConfigSelector> configSelector)

Method Details

newCall

public <RequestT,
ResponseT>
ClientCall<RequestT,ResponseT> newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor,
 CallOptions callOptions)

Description copied from class: Channel

Create a ClientCall to the remote operation specified by the given MethodDescriptor. The returned ClientCall does not trigger any remote behavior until ClientCall.start(ClientCall.Listener, Metadata) is invoked.

Specified by:

newCall in class Channel

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.

authority

public String authority()

Description copied from class: Channel

The authority of the destination this channel connects to. Typically this is in the format host:port.

Specified by:

authority in class Channel