Package | Description |
---|---|
org.tikv.common | |
org.tikv.common.operation | |
org.tikv.common.policy |
Modifier and Type | Method and Description |
---|---|
protected <ReqT,RespT> |
AbstractGRPCClient.callAsyncWithRetry(BackOffer backOffer,
io.grpc.MethodDescriptor<ReqT,RespT> method,
Supplier<ReqT> requestFactory,
io.grpc.stub.StreamObserver<RespT> responseObserver,
ErrorHandler<RespT> handler) |
<ReqT,RespT> |
AbstractGRPCClient.callServerStreamingWithRetry(BackOffer backOffer,
io.grpc.MethodDescriptor<ReqT,RespT> method,
Supplier<ReqT> requestFactory,
ErrorHandler<StreamingResponse> handler) |
<ReqT,RespT> |
AbstractGRPCClient.callWithRetry(BackOffer backOffer,
io.grpc.MethodDescriptor<ReqT,RespT> method,
Supplier<ReqT> requestFactory,
ErrorHandler<RespT> handler) |
Modifier and Type | Class and Description |
---|---|
class |
KVErrorHandler<RespT> |
class |
NoopHandler<RespT> |
class |
PDErrorHandler<RespT> |
class |
RegionErrorHandler<RespT> |
Modifier and Type | Method and Description |
---|---|
RetryPolicy<T> |
RetryMaxMs.Builder.create(ErrorHandler<T> handler) |
RetryPolicy<T> |
RetryPolicy.Builder.create(ErrorHandler<T> handler) |
Copyright © 2024 PingCAP. All rights reserved.