Package io.grpc.internal
Class ManagedChannelImpl.RealChannel
- java.lang.Object
-
- io.grpc.Channel
-
- io.grpc.internal.ManagedChannelImpl.RealChannel
-
- Enclosing class:
- ManagedChannelImpl
private class ManagedChannelImpl.RealChannel extends Channel
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
ManagedChannelImpl.RealChannel.PendingCall<ReqT,RespT>
-
Field Summary
Fields Modifier and Type Field Description private java.lang.String
authority
private Channel
clientCallImplChannel
private java.util.concurrent.atomic.AtomicReference<InternalConfigSelector>
configSelector
-
Constructor Summary
Constructors Modifier Constructor Description private
RealChannel(java.lang.String authority)
-
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.<ReqT,RespT>
ClientCall<ReqT,RespT>newCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)
Create aClientCall
to the remote operation specified by the givenMethodDescriptor
.private <ReqT,RespT>
ClientCall<ReqT,RespT>newClientCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)
(package private) void
onConfigError()
(package private) void
shutdown()
(package private) void
shutdownNow()
(package private) void
updateConfigSelector(InternalConfigSelector config)
-
-
-
Field Detail
-
configSelector
private final java.util.concurrent.atomic.AtomicReference<InternalConfigSelector> configSelector
-
authority
private final java.lang.String authority
-
clientCallImplChannel
private final Channel clientCallImplChannel
-
-
Method Detail
-
newCall
public <ReqT,RespT> ClientCall<ReqT,RespT> newCall(MethodDescriptor<ReqT,RespT> method, 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:
method
- 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.
-
updateConfigSelector
void updateConfigSelector(@Nullable InternalConfigSelector config)
-
onConfigError
void onConfigError()
-
shutdown
void shutdown()
-
shutdownNow
void shutdownNow()
-
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 formathost:port
.
-
newClientCall
private <ReqT,RespT> ClientCall<ReqT,RespT> newClientCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)
-
-