org.tikv.kvproto

Class PDGrpc.PDFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<PDGrpc.PDFutureStub>

org.tikv.kvproto.PDGrpc.PDFutureStub

Enclosing class:

PDGrpc

public static final class PDGrpc.PDFutureStub
extends io.grpc.stub.AbstractFutureStub<PDGrpc.PDFutureStub>

A stub to allow clients to do ListenableFuture-style 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
com.google.common.util.concurrent.ListenableFuture<Pdpb.AllocIDResponse>	allocID(Pdpb.AllocIDRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.AskBatchSplitResponse>	askBatchSplit(Pdpb.AskBatchSplitRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.AskSplitResponse>	askSplit(Pdpb.AskSplitRequest request) Deprecated.
com.google.common.util.concurrent.ListenableFuture<Pdpb.BootstrapResponse>	bootstrap(Pdpb.BootstrapRequest request)
protected PDGrpc.PDFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<Pdpb.GetAllStoresResponse>	getAllStores(Pdpb.GetAllStoresRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.GetClusterConfigResponse>	getClusterConfig(Pdpb.GetClusterConfigRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.GetDCLocationInfoResponse>	getDCLocationInfo(Pdpb.GetDCLocationInfoRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.GetGCSafePointResponse>	getGCSafePoint(Pdpb.GetGCSafePointRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.GetMembersResponse>	getMembers(Pdpb.GetMembersRequest request) GetMembers get the member list of this cluster.
com.google.common.util.concurrent.ListenableFuture<Pdpb.GetOperatorResponse>	getOperator(Pdpb.GetOperatorRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.GetRegionResponse>	getPrevRegion(Pdpb.GetRegionRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.GetRegionResponse>	getRegion(Pdpb.GetRegionRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.GetRegionResponse>	getRegionByID(Pdpb.GetRegionByIDRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.GetStoreResponse>	getStore(Pdpb.GetStoreRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.IsBootstrappedResponse>	isBootstrapped(Pdpb.IsBootstrappedRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.LoadGlobalConfigResponse>	loadGlobalConfig(Pdpb.LoadGlobalConfigRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.PutClusterConfigResponse>	putClusterConfig(Pdpb.PutClusterConfigRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.PutStoreResponse>	putStore(Pdpb.PutStoreRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.ReportBatchSplitResponse>	reportBatchSplit(Pdpb.ReportBatchSplitRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.ReportMinResolvedTsResponse>	reportMinResolvedTS(Pdpb.ReportMinResolvedTsRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.ReportSplitResponse>	reportSplit(Pdpb.ReportSplitRequest request) Deprecated.
com.google.common.util.concurrent.ListenableFuture<Pdpb.ScanRegionsResponse>	scanRegions(Pdpb.ScanRegionsRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.ScatterRegionResponse>	scatterRegion(Pdpb.ScatterRegionRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.SplitAndScatterRegionsResponse>	splitAndScatterRegions(Pdpb.SplitAndScatterRegionsRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.SplitRegionsResponse>	splitRegions(Pdpb.SplitRegionsRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.StoreGlobalConfigResponse>	storeGlobalConfig(Pdpb.StoreGlobalConfigRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.StoreHeartbeatResponse>	storeHeartbeat(Pdpb.StoreHeartbeatRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.SyncMaxTSResponse>	syncMaxTS(Pdpb.SyncMaxTSRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.UpdateGCSafePointResponse>	updateGCSafePoint(Pdpb.UpdateGCSafePointRequest request)
com.google.common.util.concurrent.ListenableFuture<Pdpb.UpdateServiceGCSafePointResponse>	updateServiceGCSafePoint(Pdpb.UpdateServiceGCSafePointRequest request)

Methods inherited from class io.grpc.stub.AbstractFutureStub

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.PDFutureStub build(io.grpc.Channel channel,
                                    io.grpc.CallOptions callOptions)

Specified by:

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

getMembers

public com.google.common.util.concurrent.ListenableFuture<Pdpb.GetMembersResponse> getMembers(Pdpb.GetMembersRequest request)

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

bootstrap

public com.google.common.util.concurrent.ListenableFuture<Pdpb.BootstrapResponse> bootstrap(Pdpb.BootstrapRequest request)

isBootstrapped

public com.google.common.util.concurrent.ListenableFuture<Pdpb.IsBootstrappedResponse> isBootstrapped(Pdpb.IsBootstrappedRequest request)

allocID

public com.google.common.util.concurrent.ListenableFuture<Pdpb.AllocIDResponse> allocID(Pdpb.AllocIDRequest request)

getStore

public com.google.common.util.concurrent.ListenableFuture<Pdpb.GetStoreResponse> getStore(Pdpb.GetStoreRequest request)

putStore

public com.google.common.util.concurrent.ListenableFuture<Pdpb.PutStoreResponse> putStore(Pdpb.PutStoreRequest request)

getAllStores

public com.google.common.util.concurrent.ListenableFuture<Pdpb.GetAllStoresResponse> getAllStores(Pdpb.GetAllStoresRequest request)

storeHeartbeat

public com.google.common.util.concurrent.ListenableFuture<Pdpb.StoreHeartbeatResponse> storeHeartbeat(Pdpb.StoreHeartbeatRequest request)

getRegion

public com.google.common.util.concurrent.ListenableFuture<Pdpb.GetRegionResponse> getRegion(Pdpb.GetRegionRequest request)

getPrevRegion

public com.google.common.util.concurrent.ListenableFuture<Pdpb.GetRegionResponse> getPrevRegion(Pdpb.GetRegionRequest request)

getRegionByID

public com.google.common.util.concurrent.ListenableFuture<Pdpb.GetRegionResponse> getRegionByID(Pdpb.GetRegionByIDRequest request)

scanRegions

public com.google.common.util.concurrent.ListenableFuture<Pdpb.ScanRegionsResponse> scanRegions(Pdpb.ScanRegionsRequest request)

askSplit

@Deprecated
public com.google.common.util.concurrent.ListenableFuture<Pdpb.AskSplitResponse> askSplit(Pdpb.AskSplitRequest request)

Deprecated.

reportSplit

@Deprecated
public com.google.common.util.concurrent.ListenableFuture<Pdpb.ReportSplitResponse> reportSplit(Pdpb.ReportSplitRequest request)

Deprecated.

askBatchSplit

public com.google.common.util.concurrent.ListenableFuture<Pdpb.AskBatchSplitResponse> askBatchSplit(Pdpb.AskBatchSplitRequest request)

reportBatchSplit

public com.google.common.util.concurrent.ListenableFuture<Pdpb.ReportBatchSplitResponse> reportBatchSplit(Pdpb.ReportBatchSplitRequest request)

getClusterConfig

public com.google.common.util.concurrent.ListenableFuture<Pdpb.GetClusterConfigResponse> getClusterConfig(Pdpb.GetClusterConfigRequest request)

putClusterConfig

public com.google.common.util.concurrent.ListenableFuture<Pdpb.PutClusterConfigResponse> putClusterConfig(Pdpb.PutClusterConfigRequest request)

scatterRegion

public com.google.common.util.concurrent.ListenableFuture<Pdpb.ScatterRegionResponse> scatterRegion(Pdpb.ScatterRegionRequest request)

getGCSafePoint

public com.google.common.util.concurrent.ListenableFuture<Pdpb.GetGCSafePointResponse> getGCSafePoint(Pdpb.GetGCSafePointRequest request)

updateGCSafePoint

public com.google.common.util.concurrent.ListenableFuture<Pdpb.UpdateGCSafePointResponse> updateGCSafePoint(Pdpb.UpdateGCSafePointRequest request)

updateServiceGCSafePoint

public com.google.common.util.concurrent.ListenableFuture<Pdpb.UpdateServiceGCSafePointResponse> updateServiceGCSafePoint(Pdpb.UpdateServiceGCSafePointRequest request)

getOperator

public com.google.common.util.concurrent.ListenableFuture<Pdpb.GetOperatorResponse> getOperator(Pdpb.GetOperatorRequest request)

syncMaxTS

public com.google.common.util.concurrent.ListenableFuture<Pdpb.SyncMaxTSResponse> syncMaxTS(Pdpb.SyncMaxTSRequest request)

splitRegions

public com.google.common.util.concurrent.ListenableFuture<Pdpb.SplitRegionsResponse> splitRegions(Pdpb.SplitRegionsRequest request)

splitAndScatterRegions

public com.google.common.util.concurrent.ListenableFuture<Pdpb.SplitAndScatterRegionsResponse> splitAndScatterRegions(Pdpb.SplitAndScatterRegionsRequest request)

getDCLocationInfo

public com.google.common.util.concurrent.ListenableFuture<Pdpb.GetDCLocationInfoResponse> getDCLocationInfo(Pdpb.GetDCLocationInfoRequest request)

storeGlobalConfig

public com.google.common.util.concurrent.ListenableFuture<Pdpb.StoreGlobalConfigResponse> storeGlobalConfig(Pdpb.StoreGlobalConfigRequest request)

loadGlobalConfig

public com.google.common.util.concurrent.ListenableFuture<Pdpb.LoadGlobalConfigResponse> loadGlobalConfig(Pdpb.LoadGlobalConfigRequest request)

reportMinResolvedTS

public com.google.common.util.concurrent.ListenableFuture<Pdpb.ReportMinResolvedTsResponse> reportMinResolvedTS(Pdpb.ReportMinResolvedTsRequest request)