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

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 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 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 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 java.lang.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