org.tikv.kvproto

Interface PDGrpc.AsyncService

All Known Implementing Classes:

PDGrpc.PDImplBase

Enclosing class:

PDGrpc

public static interface PDGrpc.AsyncService

Method Summary

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

Method Detail

getMembers

default 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

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

bootstrap

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

isBootstrapped

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

allocID

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

getStore

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

putStore

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

getAllStores

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

storeHeartbeat

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

regionHeartbeat

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

getRegion

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

getPrevRegion

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

getRegionByID

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

scanRegions

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

askSplit

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

Deprecated.

reportSplit

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

Deprecated.

askBatchSplit

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

reportBatchSplit

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

getClusterConfig

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

putClusterConfig

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

scatterRegion

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

getGCSafePoint

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

updateGCSafePoint

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

updateServiceGCSafePoint

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

syncRegions

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

getOperator

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

syncMaxTS

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

splitRegions

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

splitAndScatterRegions

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

getDCLocationInfo

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

storeGlobalConfig

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

loadGlobalConfig

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

watchGlobalConfig

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

reportBuckets

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

reportMinResolvedTS

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