org.tikv.kvproto

Class PDGrpc.PDBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<PDGrpc.PDBlockingStub>

org.tikv.kvproto.PDGrpc.PDBlockingStub

Enclosing class:

PDGrpc

public static final class PDGrpc.PDBlockingStub
extends io.grpc.stub.AbstractBlockingStub<PDGrpc.PDBlockingStub>

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

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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

Specified by:

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

getMembers

public 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 Pdpb.BootstrapResponse bootstrap(Pdpb.BootstrapRequest request)

isBootstrapped

public Pdpb.IsBootstrappedResponse isBootstrapped(Pdpb.IsBootstrappedRequest request)

allocID

public Pdpb.AllocIDResponse allocID(Pdpb.AllocIDRequest request)

getStore

public Pdpb.GetStoreResponse getStore(Pdpb.GetStoreRequest request)

putStore

public Pdpb.PutStoreResponse putStore(Pdpb.PutStoreRequest request)

getAllStores

public Pdpb.GetAllStoresResponse getAllStores(Pdpb.GetAllStoresRequest request)

storeHeartbeat

public Pdpb.StoreHeartbeatResponse storeHeartbeat(Pdpb.StoreHeartbeatRequest request)

getRegion

public Pdpb.GetRegionResponse getRegion(Pdpb.GetRegionRequest request)

getPrevRegion

public Pdpb.GetRegionResponse getPrevRegion(Pdpb.GetRegionRequest request)

getRegionByID

public Pdpb.GetRegionResponse getRegionByID(Pdpb.GetRegionByIDRequest request)

scanRegions

public Pdpb.ScanRegionsResponse scanRegions(Pdpb.ScanRegionsRequest request)

askSplit

@Deprecated
public Pdpb.AskSplitResponse askSplit(Pdpb.AskSplitRequest request)

Deprecated.

reportSplit

@Deprecated
public Pdpb.ReportSplitResponse reportSplit(Pdpb.ReportSplitRequest request)

Deprecated.

askBatchSplit

public Pdpb.AskBatchSplitResponse askBatchSplit(Pdpb.AskBatchSplitRequest request)

reportBatchSplit

public Pdpb.ReportBatchSplitResponse reportBatchSplit(Pdpb.ReportBatchSplitRequest request)

getClusterConfig

public Pdpb.GetClusterConfigResponse getClusterConfig(Pdpb.GetClusterConfigRequest request)

putClusterConfig

public Pdpb.PutClusterConfigResponse putClusterConfig(Pdpb.PutClusterConfigRequest request)

scatterRegion

public Pdpb.ScatterRegionResponse scatterRegion(Pdpb.ScatterRegionRequest request)

getGCSafePoint

public Pdpb.GetGCSafePointResponse getGCSafePoint(Pdpb.GetGCSafePointRequest request)

updateGCSafePoint

public Pdpb.UpdateGCSafePointResponse updateGCSafePoint(Pdpb.UpdateGCSafePointRequest request)

updateServiceGCSafePoint

public Pdpb.UpdateServiceGCSafePointResponse updateServiceGCSafePoint(Pdpb.UpdateServiceGCSafePointRequest request)

getOperator

public Pdpb.GetOperatorResponse getOperator(Pdpb.GetOperatorRequest request)

syncMaxTS

public Pdpb.SyncMaxTSResponse syncMaxTS(Pdpb.SyncMaxTSRequest request)

splitRegions

public Pdpb.SplitRegionsResponse splitRegions(Pdpb.SplitRegionsRequest request)

splitAndScatterRegions

public Pdpb.SplitAndScatterRegionsResponse splitAndScatterRegions(Pdpb.SplitAndScatterRegionsRequest request)

getDCLocationInfo

public Pdpb.GetDCLocationInfoResponse getDCLocationInfo(Pdpb.GetDCLocationInfoRequest request)

storeGlobalConfig

public Pdpb.StoreGlobalConfigResponse storeGlobalConfig(Pdpb.StoreGlobalConfigRequest request)

loadGlobalConfig

public Pdpb.LoadGlobalConfigResponse loadGlobalConfig(Pdpb.LoadGlobalConfigRequest request)

watchGlobalConfig

public Iterator<Pdpb.WatchGlobalConfigResponse> watchGlobalConfig(Pdpb.WatchGlobalConfigRequest request)

reportMinResolvedTS

public Pdpb.ReportMinResolvedTsResponse reportMinResolvedTS(Pdpb.ReportMinResolvedTsRequest request)