org.tikv.common

Class PDMockServer

java.lang.Object

org.tikv.kvproto.PDGrpc.PDImplBase

org.tikv.common.PDMockServer

All Implemented Interfaces:

io.grpc.BindableService, PDGrpc.AsyncService

public class PDMockServer
extends PDGrpc.PDImplBase

Constructor Summary

Constructors

Constructor and Description
PDMockServer()

Method Summary

Modifier and Type	Method and Description
void	addGetAllStoresListener(Function<Pdpb.GetAllStoresRequest,Pdpb.GetAllStoresResponse> func)
void	addGetMembersListener(Function<Pdpb.GetMembersRequest,Pdpb.GetMembersResponse> func)
void	addGetRegionByIDListener(Function<Pdpb.GetRegionByIDRequest,Pdpb.GetRegionResponse> func)
void	addGetRegionListener(Function<Pdpb.GetRegionRequest,Pdpb.GetRegionResponse> func)
void	addGetStoreListener(Function<Pdpb.GetStoreRequest,Pdpb.GetStoreResponse> func)
void	addScanRegionsListener(Function<Pdpb.ScanRegionsRequest,Pdpb.ScanRegionsResponse> func)
void	getAllStores(Pdpb.GetAllStoresRequest request, io.grpc.stub.StreamObserver<Pdpb.GetAllStoresResponse> resp)
long	getClusterId()
void	getMembers(Pdpb.GetMembersRequest request, io.grpc.stub.StreamObserver<Pdpb.GetMembersResponse> resp)
long	getPort()
void	getRegion(Pdpb.GetRegionRequest request, io.grpc.stub.StreamObserver<Pdpb.GetRegionResponse> resp)
void	getRegionByID(Pdpb.GetRegionByIDRequest request, io.grpc.stub.StreamObserver<Pdpb.GetRegionResponse> resp)
void	getStore(Pdpb.GetStoreRequest request, io.grpc.stub.StreamObserver<Pdpb.GetStoreResponse> resp)
void	scanRegions(Pdpb.ScanRegionsRequest request, io.grpc.stub.StreamObserver<Pdpb.ScanRegionsResponse> resp)
void	start(long clusterId)
void	start(long clusterId, int port)
void	stop()
io.grpc.stub.StreamObserver<Pdpb.TsoRequest>	tso(io.grpc.stub.StreamObserver<Pdpb.TsoResponse> resp)

Methods inherited from class org.tikv.kvproto.PDGrpc.PDImplBase

bindService

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.tikv.kvproto.PDGrpc.AsyncService

allocID, askBatchSplit, askSplit, bootstrap, getClusterConfig, getDCLocationInfo, getGCSafePoint, getOperator, getPrevRegion, isBootstrapped, loadGlobalConfig, putClusterConfig, putStore, regionHeartbeat, reportBatchSplit, reportBuckets, reportMinResolvedTS, reportSplit, scatterRegion, splitAndScatterRegions, splitRegions, storeGlobalConfig, storeHeartbeat, syncMaxTS, syncRegions, updateGCSafePoint, updateServiceGCSafePoint, watchGlobalConfig

Constructor Detail

PDMockServer

public PDMockServer()

Method Detail

addGetMembersListener

public void addGetMembersListener(Function<Pdpb.GetMembersRequest,Pdpb.GetMembersResponse> func)

getMembers

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

tso

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

addGetRegionListener

public void addGetRegionListener(Function<Pdpb.GetRegionRequest,Pdpb.GetRegionResponse> func)

getRegion

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

addGetRegionByIDListener

public void addGetRegionByIDListener(Function<Pdpb.GetRegionByIDRequest,Pdpb.GetRegionResponse> func)

getRegionByID

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

addGetStoreListener

public void addGetStoreListener(Function<Pdpb.GetStoreRequest,Pdpb.GetStoreResponse> func)

getStore

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

addScanRegionsListener

public void addScanRegionsListener(Function<Pdpb.ScanRegionsRequest,Pdpb.ScanRegionsResponse> func)

scanRegions

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

addGetAllStoresListener

public void addGetAllStoresListener(Function<Pdpb.GetAllStoresRequest,Pdpb.GetAllStoresResponse> func)

getAllStores

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

start

public void start(long clusterId)
           throws IOException

Throws:

IOException

start

public void start(long clusterId,
                  int port)
           throws IOException

Throws:

IOException

stop

public void stop()

getClusterId

public long getClusterId()

getPort

public long getPort()