程序包 org.apache.dubbo.rpc.protocol.grpc

类 ReferenceCountManagedChannel

java.lang.Object

io.grpc.Channel

io.grpc.ManagedChannel

org.apache.dubbo.rpc.protocol.grpc.ReferenceCountManagedChannel

public class ReferenceCountManagedChannel
extends io.grpc.ManagedChannel

Also see ReferenceCountExchangeClient

构造器概要

构造器

构造器	说明
ReferenceCountManagedChannel(io.grpc.ManagedChannel delegated)

方法概要

修饰符和类型	方法	说明
String	authority()
boolean	awaitTermination(long timeout, TimeUnit unit)
int	incrementAndGetCount()	The reference count of current ExchangeClient, connection will be closed if all invokers destroyed.
boolean	isShutdown()
boolean	isTerminated()
<RequestT,ResponseT> io.grpc.ClientCall<RequestT,ResponseT>	newCall(io.grpc.MethodDescriptor<RequestT,ResponseT> methodDescriptor, io.grpc.CallOptions callOptions)
io.grpc.ManagedChannel	shutdown()
io.grpc.ManagedChannel	shutdownNow()

从类继承的方法 io.grpc.ManagedChannel

enterIdle, getState, notifyWhenStateChanged, resetConnectBackoff

从类继承的方法 java.lang.Object

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

构造器详细资料

ReferenceCountManagedChannel

public ReferenceCountManagedChannel(io.grpc.ManagedChannel delegated)

方法详细资料

incrementAndGetCount

public int incrementAndGetCount()

The reference count of current ExchangeClient, connection will be closed if all invokers destroyed.

shutdown

public io.grpc.ManagedChannel shutdown()

指定者:

shutdown 在类中 io.grpc.ManagedChannel

isShutdown

public boolean isShutdown()

指定者:

isShutdown 在类中 io.grpc.ManagedChannel

isTerminated

public boolean isTerminated()

指定者:

isTerminated 在类中 io.grpc.ManagedChannel

shutdownNow

public io.grpc.ManagedChannel shutdownNow()

指定者:

shutdownNow 在类中 io.grpc.ManagedChannel

awaitTermination

public boolean awaitTermination(long timeout,
                                TimeUnit unit)
                         throws InterruptedException

指定者:

awaitTermination 在类中 io.grpc.ManagedChannel

抛出:

InterruptedException

newCall

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

指定者:

newCall 在类中 io.grpc.Channel

authority

public String authority()

指定者:

authority 在类中 io.grpc.Channel