org.tikv.common

Class AbstractGRPCClient<BlockingStubT extends io.grpc.stub.AbstractStub<BlockingStubT>,FutureStubT extends io.grpc.stub.AbstractFutureStub<FutureStubT>>

java.lang.Object

org.tikv.common.AbstractGRPCClient<BlockingStubT,FutureStubT>

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

AbstractRegionStoreClient, ImporterStoreClient, PDClient

public abstract class AbstractGRPCClient<BlockingStubT extends io.grpc.stub.AbstractStub<BlockingStubT>,FutureStubT extends io.grpc.stub.AbstractFutureStub<FutureStubT>>
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field and Description
protected FutureStubT	asyncStub
protected BlockingStubT	blockingStub
protected ChannelFactory	channelFactory
protected TiConfiguration	conf
protected org.slf4j.Logger	logger
protected long	timeout

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractGRPCClient(TiConfiguration conf, ChannelFactory channelFactory)
protected	AbstractGRPCClient(TiConfiguration conf, ChannelFactory channelFactory, BlockingStubT blockingStub, FutureStubT asyncStub)

Method Summary

Modifier and Type	Method and Description
protected <ReqT,RespT> void	callAsyncWithRetry(BackOffer backOffer, io.grpc.MethodDescriptor<ReqT,RespT> method, Supplier<ReqT> requestFactory, io.grpc.stub.StreamObserver<RespT> responseObserver, ErrorHandler<RespT> handler)
<ReqT,RespT> StreamingResponse	callServerStreamingWithRetry(BackOffer backOffer, io.grpc.MethodDescriptor<ReqT,RespT> method, Supplier<ReqT> requestFactory, ErrorHandler<StreamingResponse> handler)
<ReqT,RespT> RespT	callWithRetry(BackOffer backOffer, io.grpc.MethodDescriptor<ReqT,RespT> method, Supplier<ReqT> requestFactory, ErrorHandler<RespT> handler)
protected boolean	checkHealth(BackOffer backOffer, String addressStr, HostMapping hostMapping)
protected abstract FutureStubT	getAsyncStub()
protected abstract BlockingStubT	getBlockingStub()
TiConfiguration	getConf()
long	getTimeout()
void	setTimeout(long timeout)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.AutoCloseable

close

Field Detail

logger

protected final org.slf4j.Logger logger

channelFactory

protected final ChannelFactory channelFactory

conf

protected TiConfiguration conf

timeout

protected long timeout

blockingStub

protected BlockingStubT extends io.grpc.stub.AbstractStub<BlockingStubT> blockingStub

asyncStub

protected FutureStubT extends io.grpc.stub.AbstractFutureStub<FutureStubT> asyncStub

Constructor Detail

AbstractGRPCClient

protected AbstractGRPCClient(TiConfiguration conf,
                             ChannelFactory channelFactory)

AbstractGRPCClient

protected AbstractGRPCClient(TiConfiguration conf,
                             ChannelFactory channelFactory,
                             BlockingStubT blockingStub,
                             FutureStubT asyncStub)

Method Detail

getConf

public TiConfiguration getConf()

callWithRetry

public <ReqT,RespT> RespT callWithRetry(BackOffer backOffer,
                                        io.grpc.MethodDescriptor<ReqT,RespT> method,
                                        Supplier<ReqT> requestFactory,
                                        ErrorHandler<RespT> handler)

callAsyncWithRetry

protected <ReqT,RespT> void callAsyncWithRetry(BackOffer backOffer,
                                               io.grpc.MethodDescriptor<ReqT,RespT> method,
                                               Supplier<ReqT> requestFactory,
                                               io.grpc.stub.StreamObserver<RespT> responseObserver,
                                               ErrorHandler<RespT> handler)

callServerStreamingWithRetry

public <ReqT,RespT> StreamingResponse callServerStreamingWithRetry(BackOffer backOffer,
                                                                   io.grpc.MethodDescriptor<ReqT,RespT> method,
                                                                   Supplier<ReqT> requestFactory,
                                                                   ErrorHandler<StreamingResponse> handler)

setTimeout

public void setTimeout(long timeout)

getTimeout

public long getTimeout()

getBlockingStub

protected abstract BlockingStubT getBlockingStub()

getAsyncStub

protected abstract FutureStubT getAsyncStub()

checkHealth

protected boolean checkHealth(BackOffer backOffer,
                              String addressStr,
                              HostMapping hostMapping)