org.tikv.kvproto

Class PDGrpc.PDStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<PDGrpc.PDStub>

org.tikv.kvproto.PDGrpc.PDStub

Enclosing class:

PDGrpc

public static final class PDGrpc.PDStub
extends io.grpc.stub.AbstractAsyncStub<PDGrpc.PDStub>

A stub to allow clients to do asynchronous rpc calls to service PD.

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method and Description
void	allocID(Pdpb.AllocIDRequest request, io.grpc.stub.StreamObserver<Pdpb.AllocIDResponse> responseObserver)
void	askBatchSplit(Pdpb.AskBatchSplitRequest request, io.grpc.stub.StreamObserver<Pdpb.AskBatchSplitResponse> responseObserver)
void	askSplit(Pdpb.AskSplitRequest request, io.grpc.stub.StreamObserver<Pdpb.AskSplitResponse> responseObserver) Deprecated.
void	bootstrap(Pdpb.BootstrapRequest request, io.grpc.stub.StreamObserver<Pdpb.BootstrapResponse> responseObserver)
protected PDGrpc.PDStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	getAllStores(Pdpb.GetAllStoresRequest request, io.grpc.stub.StreamObserver<Pdpb.GetAllStoresResponse> responseObserver)
void	getClusterConfig(Pdpb.GetClusterConfigRequest request, io.grpc.stub.StreamObserver<Pdpb.GetClusterConfigResponse> responseObserver)
void	getDCLocationInfo(Pdpb.GetDCLocationInfoRequest request, io.grpc.stub.StreamObserver<Pdpb.GetDCLocationInfoResponse> responseObserver)
void	getGCSafePoint(Pdpb.GetGCSafePointRequest request, io.grpc.stub.StreamObserver<Pdpb.GetGCSafePointResponse> responseObserver)
void	getMembers(Pdpb.GetMembersRequest request, io.grpc.stub.StreamObserver<Pdpb.GetMembersResponse> responseObserver) GetMembers get the member list of this cluster.
void	getOperator(Pdpb.GetOperatorRequest request, io.grpc.stub.StreamObserver<Pdpb.GetOperatorResponse> responseObserver)
void	getPrevRegion(Pdpb.GetRegionRequest request, io.grpc.stub.StreamObserver<Pdpb.GetRegionResponse> responseObserver)
void	getRegion(Pdpb.GetRegionRequest request, io.grpc.stub.StreamObserver<Pdpb.GetRegionResponse> responseObserver)
void	getRegionByID(Pdpb.GetRegionByIDRequest request, io.grpc.stub.StreamObserver<Pdpb.GetRegionResponse> responseObserver)
void	getStore(Pdpb.GetStoreRequest request, io.grpc.stub.StreamObserver<Pdpb.GetStoreResponse> responseObserver)
void	isBootstrapped(Pdpb.IsBootstrappedRequest request, io.grpc.stub.StreamObserver<Pdpb.IsBootstrappedResponse> responseObserver)
void	loadGlobalConfig(Pdpb.LoadGlobalConfigRequest request, io.grpc.stub.StreamObserver<Pdpb.LoadGlobalConfigResponse> responseObserver)
void	putClusterConfig(Pdpb.PutClusterConfigRequest request, io.grpc.stub.StreamObserver<Pdpb.PutClusterConfigResponse> responseObserver)
void	putStore(Pdpb.PutStoreRequest request, io.grpc.stub.StreamObserver<Pdpb.PutStoreResponse> responseObserver)
io.grpc.stub.StreamObserver<Pdpb.RegionHeartbeatRequest>	regionHeartbeat(io.grpc.stub.StreamObserver<Pdpb.RegionHeartbeatResponse> responseObserver)
void	reportBatchSplit(Pdpb.ReportBatchSplitRequest request, io.grpc.stub.StreamObserver<Pdpb.ReportBatchSplitResponse> responseObserver)
io.grpc.stub.StreamObserver<Pdpb.ReportBucketsRequest>	reportBuckets(io.grpc.stub.StreamObserver<Pdpb.ReportBucketsResponse> responseObserver)
void	reportMinResolvedTS(Pdpb.ReportMinResolvedTsRequest request, io.grpc.stub.StreamObserver<Pdpb.ReportMinResolvedTsResponse> responseObserver)
void	reportSplit(Pdpb.ReportSplitRequest request, io.grpc.stub.StreamObserver<Pdpb.ReportSplitResponse> responseObserver) Deprecated.
void	scanRegions(Pdpb.ScanRegionsRequest request, io.grpc.stub.StreamObserver<Pdpb.ScanRegionsResponse> responseObserver)
void	scatterRegion(Pdpb.ScatterRegionRequest request, io.grpc.stub.StreamObserver<Pdpb.ScatterRegionResponse> responseObserver)
void	splitAndScatterRegions(Pdpb.SplitAndScatterRegionsRequest request, io.grpc.stub.StreamObserver<Pdpb.SplitAndScatterRegionsResponse> responseObserver)
void	splitRegions(Pdpb.SplitRegionsRequest request, io.grpc.stub.StreamObserver<Pdpb.SplitRegionsResponse> responseObserver)
void	storeGlobalConfig(Pdpb.StoreGlobalConfigRequest request, io.grpc.stub.StreamObserver<Pdpb.StoreGlobalConfigResponse> responseObserver)
void	storeHeartbeat(Pdpb.StoreHeartbeatRequest request, io.grpc.stub.StreamObserver<Pdpb.StoreHeartbeatResponse> responseObserver)
void	syncMaxTS(Pdpb.SyncMaxTSRequest request, io.grpc.stub.StreamObserver<Pdpb.SyncMaxTSResponse> responseObserver)
io.grpc.stub.StreamObserver<Pdpb.SyncRegionRequest>	syncRegions(io.grpc.stub.StreamObserver<Pdpb.SyncRegionResponse> responseObserver)
io.grpc.stub.StreamObserver<Pdpb.TsoRequest>	tso(io.grpc.stub.StreamObserver<Pdpb.TsoResponse> responseObserver)
void	updateGCSafePoint(Pdpb.UpdateGCSafePointRequest request, io.grpc.stub.StreamObserver<Pdpb.UpdateGCSafePointResponse> responseObserver)
void	updateServiceGCSafePoint(Pdpb.UpdateServiceGCSafePointRequest request, io.grpc.stub.StreamObserver<Pdpb.UpdateServiceGCSafePointResponse> responseObserver)
void	watchGlobalConfig(Pdpb.WatchGlobalConfigRequest request, io.grpc.stub.StreamObserver<Pdpb.WatchGlobalConfigResponse> responseObserver)

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected PDGrpc.PDStub build(io.grpc.Channel channel,
                              io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<PDGrpc.PDStub>

getMembers

public void getMembers(Pdpb.GetMembersRequest request,
                       io.grpc.stub.StreamObserver<Pdpb.GetMembersResponse> responseObserver)

 GetMembers get the member list of this cluster. It does not require
 the cluster_id in request matchs the id of this cluster.
 

tso

public io.grpc.stub.StreamObserver<Pdpb.TsoRequest> tso(io.grpc.stub.StreamObserver<Pdpb.TsoResponse> responseObserver)

bootstrap

public void bootstrap(Pdpb.BootstrapRequest request,
                      io.grpc.stub.StreamObserver<Pdpb.BootstrapResponse> responseObserver)

isBootstrapped

public void isBootstrapped(Pdpb.IsBootstrappedRequest request,
                           io.grpc.stub.StreamObserver<Pdpb.IsBootstrappedResponse> responseObserver)

allocID

public void allocID(Pdpb.AllocIDRequest request,
                    io.grpc.stub.StreamObserver<Pdpb.AllocIDResponse> responseObserver)

getStore

public void getStore(Pdpb.GetStoreRequest request,
                     io.grpc.stub.StreamObserver<Pdpb.GetStoreResponse> responseObserver)

putStore

public void putStore(Pdpb.PutStoreRequest request,
                     io.grpc.stub.StreamObserver<Pdpb.PutStoreResponse> responseObserver)

getAllStores

public void getAllStores(Pdpb.GetAllStoresRequest request,
                         io.grpc.stub.StreamObserver<Pdpb.GetAllStoresResponse> responseObserver)

storeHeartbeat

public void storeHeartbeat(Pdpb.StoreHeartbeatRequest request,
                           io.grpc.stub.StreamObserver<Pdpb.StoreHeartbeatResponse> responseObserver)

regionHeartbeat

public io.grpc.stub.StreamObserver<Pdpb.RegionHeartbeatRequest> regionHeartbeat(io.grpc.stub.StreamObserver<Pdpb.RegionHeartbeatResponse> responseObserver)

getRegion

public void getRegion(Pdpb.GetRegionRequest request,
                      io.grpc.stub.StreamObserver<Pdpb.GetRegionResponse> responseObserver)

getPrevRegion

public void getPrevRegion(Pdpb.GetRegionRequest request,
                          io.grpc.stub.StreamObserver<Pdpb.GetRegionResponse> responseObserver)

getRegionByID

public void getRegionByID(Pdpb.GetRegionByIDRequest request,
                          io.grpc.stub.StreamObserver<Pdpb.GetRegionResponse> responseObserver)

scanRegions

public void scanRegions(Pdpb.ScanRegionsRequest request,
                        io.grpc.stub.StreamObserver<Pdpb.ScanRegionsResponse> responseObserver)

askSplit

@Deprecated
public void askSplit(Pdpb.AskSplitRequest request,
                                 io.grpc.stub.StreamObserver<Pdpb.AskSplitResponse> responseObserver)

Deprecated.

reportSplit

@Deprecated
public void reportSplit(Pdpb.ReportSplitRequest request,
                                    io.grpc.stub.StreamObserver<Pdpb.ReportSplitResponse> responseObserver)

Deprecated.

askBatchSplit

public void askBatchSplit(Pdpb.AskBatchSplitRequest request,
                          io.grpc.stub.StreamObserver<Pdpb.AskBatchSplitResponse> responseObserver)

reportBatchSplit

public void reportBatchSplit(Pdpb.ReportBatchSplitRequest request,
                             io.grpc.stub.StreamObserver<Pdpb.ReportBatchSplitResponse> responseObserver)

getClusterConfig

public void getClusterConfig(Pdpb.GetClusterConfigRequest request,
                             io.grpc.stub.StreamObserver<Pdpb.GetClusterConfigResponse> responseObserver)

putClusterConfig

public void putClusterConfig(Pdpb.PutClusterConfigRequest request,
                             io.grpc.stub.StreamObserver<Pdpb.PutClusterConfigResponse> responseObserver)

scatterRegion

public void scatterRegion(Pdpb.ScatterRegionRequest request,
                          io.grpc.stub.StreamObserver<Pdpb.ScatterRegionResponse> responseObserver)

getGCSafePoint

public void getGCSafePoint(Pdpb.GetGCSafePointRequest request,
                           io.grpc.stub.StreamObserver<Pdpb.GetGCSafePointResponse> responseObserver)

updateGCSafePoint

public void updateGCSafePoint(Pdpb.UpdateGCSafePointRequest request,
                              io.grpc.stub.StreamObserver<Pdpb.UpdateGCSafePointResponse> responseObserver)

updateServiceGCSafePoint

public void updateServiceGCSafePoint(Pdpb.UpdateServiceGCSafePointRequest request,
                                     io.grpc.stub.StreamObserver<Pdpb.UpdateServiceGCSafePointResponse> responseObserver)

syncRegions

public io.grpc.stub.StreamObserver<Pdpb.SyncRegionRequest> syncRegions(io.grpc.stub.StreamObserver<Pdpb.SyncRegionResponse> responseObserver)

getOperator

public void getOperator(Pdpb.GetOperatorRequest request,
                        io.grpc.stub.StreamObserver<Pdpb.GetOperatorResponse> responseObserver)

syncMaxTS

public void syncMaxTS(Pdpb.SyncMaxTSRequest request,
                      io.grpc.stub.StreamObserver<Pdpb.SyncMaxTSResponse> responseObserver)

splitRegions

public void splitRegions(Pdpb.SplitRegionsRequest request,
                         io.grpc.stub.StreamObserver<Pdpb.SplitRegionsResponse> responseObserver)

splitAndScatterRegions

public void splitAndScatterRegions(Pdpb.SplitAndScatterRegionsRequest request,
                                   io.grpc.stub.StreamObserver<Pdpb.SplitAndScatterRegionsResponse> responseObserver)

getDCLocationInfo

public void getDCLocationInfo(Pdpb.GetDCLocationInfoRequest request,
                              io.grpc.stub.StreamObserver<Pdpb.GetDCLocationInfoResponse> responseObserver)

storeGlobalConfig

public void storeGlobalConfig(Pdpb.StoreGlobalConfigRequest request,
                              io.grpc.stub.StreamObserver<Pdpb.StoreGlobalConfigResponse> responseObserver)

loadGlobalConfig

public void loadGlobalConfig(Pdpb.LoadGlobalConfigRequest request,
                             io.grpc.stub.StreamObserver<Pdpb.LoadGlobalConfigResponse> responseObserver)

watchGlobalConfig

public void watchGlobalConfig(Pdpb.WatchGlobalConfigRequest request,
                              io.grpc.stub.StreamObserver<Pdpb.WatchGlobalConfigResponse> responseObserver)

reportBuckets

public io.grpc.stub.StreamObserver<Pdpb.ReportBucketsRequest> reportBuckets(io.grpc.stub.StreamObserver<Pdpb.ReportBucketsResponse> responseObserver)

reportMinResolvedTS

public void reportMinResolvedTS(Pdpb.ReportMinResolvedTsRequest request,
                                io.grpc.stub.StreamObserver<Pdpb.ReportMinResolvedTsResponse> responseObserver)