org.tikv.kvproto

Class TikvGrpc

java.lang.Object

org.tikv.kvproto.TikvGrpc

@Generated(value="by gRPC proto compiler (version 1.60.0)",
           comments="Source: tikvpb.proto")
public final class TikvGrpc
extends Object

 Key/value store API for TiKV.
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	TikvGrpc.AsyncService Key/value store API for TiKV.
static class	TikvGrpc.TikvBlockingStub A stub to allow clients to do synchronous rpc calls to service Tikv.
static class	TikvGrpc.TikvFutureStub A stub to allow clients to do ListenableFuture-style rpc calls to service Tikv.
static class	TikvGrpc.TikvImplBase Base class for the server implementation of the service Tikv.
static class	TikvGrpc.TikvStub A stub to allow clients to do asynchronous rpc calls to service Tikv.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SERVICE_NAME

Method Summary

Modifier and Type	Method and Description
static io.grpc.ServerServiceDefinition	bindService(TikvGrpc.AsyncService service)
static io.grpc.MethodDescriptor<Tikvpb.BatchCommandsRequest,Tikvpb.BatchCommandsResponse>	getBatchCommandsMethod()
static io.grpc.MethodDescriptor<Coprocessor.BatchRequest,Coprocessor.BatchResponse>	getBatchCoprocessorMethod()
static io.grpc.MethodDescriptor<Tikvpb.BatchRaftMessage,RaftServerpb.Done>	getBatchRaftMethod()
static io.grpc.MethodDescriptor<Mpp.CancelTaskRequest,Mpp.CancelTaskResponse>	getCancelMPPTaskMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.CheckLeaderRequest,Kvrpcpb.CheckLeaderResponse>	getCheckLeaderMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.CheckLockObserverRequest,Kvrpcpb.CheckLockObserverResponse>	getCheckLockObserverMethod()
static io.grpc.MethodDescriptor<Coprocessor.Request,Coprocessor.Response>	getCoprocessorMethod()
static io.grpc.MethodDescriptor<Coprocessor.Request,Coprocessor.Response>	getCoprocessorStreamMethod()
static io.grpc.MethodDescriptor<Mpp.DispatchTaskRequest,Mpp.DispatchTaskResponse>	getDispatchMPPTaskMethod()
static io.grpc.MethodDescriptor<Mpp.EstablishMPPConnectionRequest,Mpp.MPPDataPacket>	getEstablishMPPConnectionMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.GetLockWaitInfoRequest,Kvrpcpb.GetLockWaitInfoResponse>	getGetLockWaitInfoMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.StoreSafeTSRequest,Kvrpcpb.StoreSafeTSResponse>	getGetStoreSafeTSMethod()
static io.grpc.MethodDescriptor<Mpp.IsAliveRequest,Mpp.IsAliveResponse>	getIsAliveMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.BatchGetRequest,Kvrpcpb.BatchGetResponse>	getKvBatchGetMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.BatchRollbackRequest,Kvrpcpb.BatchRollbackResponse>	getKvBatchRollbackMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.CheckSecondaryLocksRequest,Kvrpcpb.CheckSecondaryLocksResponse>	getKvCheckSecondaryLocksMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.CheckTxnStatusRequest,Kvrpcpb.CheckTxnStatusResponse>	getKvCheckTxnStatusMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.CleanupRequest,Kvrpcpb.CleanupResponse>	getKvCleanupMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.CommitRequest,Kvrpcpb.CommitResponse>	getKvCommitMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.DeleteRangeRequest,Kvrpcpb.DeleteRangeResponse>	getKvDeleteRangeMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.GCRequest,Kvrpcpb.GCResponse>	getKvGCMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.GetRequest,Kvrpcpb.GetResponse>	getKvGetMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.ImportRequest,Kvrpcpb.ImportResponse>	getKvImportMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.PessimisticLockRequest,Kvrpcpb.PessimisticLockResponse>	getKvPessimisticLockMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.PessimisticRollbackRequest,Kvrpcpb.PessimisticRollbackResponse>	getKVPessimisticRollbackMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.PrewriteRequest,Kvrpcpb.PrewriteResponse>	getKvPrewriteMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.ResolveLockRequest,Kvrpcpb.ResolveLockResponse>	getKvResolveLockMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.ScanLockRequest,Kvrpcpb.ScanLockResponse>	getKvScanLockMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.ScanRequest,Kvrpcpb.ScanResponse>	getKvScanMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.TxnHeartBeatRequest,Kvrpcpb.TxnHeartBeatResponse>	getKvTxnHeartBeatMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.MvccGetByKeyRequest,Kvrpcpb.MvccGetByKeyResponse>	getMvccGetByKeyMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.MvccGetByStartTsRequest,Kvrpcpb.MvccGetByStartTsResponse>	getMvccGetByStartTsMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.PhysicalScanLockRequest,Kvrpcpb.PhysicalScanLockResponse>	getPhysicalScanLockMethod()
static io.grpc.MethodDescriptor<RaftServerpb.RaftMessage,RaftServerpb.Done>	getRaftMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawBatchDeleteRequest,Kvrpcpb.RawBatchDeleteResponse>	getRawBatchDeleteMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawBatchGetRequest,Kvrpcpb.RawBatchGetResponse>	getRawBatchGetMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawBatchPutRequest,Kvrpcpb.RawBatchPutResponse>	getRawBatchPutMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawBatchScanRequest,Kvrpcpb.RawBatchScanResponse>	getRawBatchScanMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawChecksumRequest,Kvrpcpb.RawChecksumResponse>	getRawChecksumMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawCASRequest,Kvrpcpb.RawCASResponse>	getRawCompareAndSwapMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawCoprocessorRequest,Kvrpcpb.RawCoprocessorResponse>	getRawCoprocessorMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawDeleteRequest,Kvrpcpb.RawDeleteResponse>	getRawDeleteMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawDeleteRangeRequest,Kvrpcpb.RawDeleteRangeResponse>	getRawDeleteRangeMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawGetKeyTTLRequest,Kvrpcpb.RawGetKeyTTLResponse>	getRawGetKeyTTLMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawGetRequest,Kvrpcpb.RawGetResponse>	getRawGetMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawPutRequest,Kvrpcpb.RawPutResponse>	getRawPutMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RawScanRequest,Kvrpcpb.RawScanResponse>	getRawScanMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.ReadIndexRequest,Kvrpcpb.ReadIndexResponse>	getReadIndexMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RegisterLockObserverRequest,Kvrpcpb.RegisterLockObserverResponse>	getRegisterLockObserverMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.RemoveLockObserverRequest,Kvrpcpb.RemoveLockObserverResponse>	getRemoveLockObserverMethod()
static io.grpc.ServiceDescriptor	getServiceDescriptor()
static io.grpc.MethodDescriptor<RaftServerpb.SnapshotChunk,RaftServerpb.Done>	getSnapshotMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.SplitRegionRequest,Kvrpcpb.SplitRegionResponse>	getSplitRegionMethod()
static io.grpc.MethodDescriptor<Kvrpcpb.UnsafeDestroyRangeRequest,Kvrpcpb.UnsafeDestroyRangeResponse>	getUnsafeDestroyRangeMethod()
static TikvGrpc.TikvBlockingStub	newBlockingStub(io.grpc.Channel channel) Creates a new blocking-style stub that supports unary and streaming output calls on the service
static TikvGrpc.TikvFutureStub	newFutureStub(io.grpc.Channel channel) Creates a new ListenableFuture-style stub that supports unary calls on the service
static TikvGrpc.TikvStub	newStub(io.grpc.Channel channel) Creates a new async stub that supports all call types for the service

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_NAME

public static final String SERVICE_NAME

See Also:

Constant Field Values

Method Detail

getKvGetMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.GetRequest,Kvrpcpb.GetResponse> getKvGetMethod()

getKvScanMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.ScanRequest,Kvrpcpb.ScanResponse> getKvScanMethod()

getKvPrewriteMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.PrewriteRequest,Kvrpcpb.PrewriteResponse> getKvPrewriteMethod()

getKvPessimisticLockMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.PessimisticLockRequest,Kvrpcpb.PessimisticLockResponse> getKvPessimisticLockMethod()

getKVPessimisticRollbackMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.PessimisticRollbackRequest,Kvrpcpb.PessimisticRollbackResponse> getKVPessimisticRollbackMethod()

getKvTxnHeartBeatMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.TxnHeartBeatRequest,Kvrpcpb.TxnHeartBeatResponse> getKvTxnHeartBeatMethod()

getKvCheckTxnStatusMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.CheckTxnStatusRequest,Kvrpcpb.CheckTxnStatusResponse> getKvCheckTxnStatusMethod()

getKvCheckSecondaryLocksMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.CheckSecondaryLocksRequest,Kvrpcpb.CheckSecondaryLocksResponse> getKvCheckSecondaryLocksMethod()

getKvCommitMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.CommitRequest,Kvrpcpb.CommitResponse> getKvCommitMethod()

getKvImportMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.ImportRequest,Kvrpcpb.ImportResponse> getKvImportMethod()

getKvCleanupMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.CleanupRequest,Kvrpcpb.CleanupResponse> getKvCleanupMethod()

getKvBatchGetMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.BatchGetRequest,Kvrpcpb.BatchGetResponse> getKvBatchGetMethod()

getKvBatchRollbackMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.BatchRollbackRequest,Kvrpcpb.BatchRollbackResponse> getKvBatchRollbackMethod()

getKvScanLockMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.ScanLockRequest,Kvrpcpb.ScanLockResponse> getKvScanLockMethod()

getKvResolveLockMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.ResolveLockRequest,Kvrpcpb.ResolveLockResponse> getKvResolveLockMethod()

getKvGCMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.GCRequest,Kvrpcpb.GCResponse> getKvGCMethod()

getKvDeleteRangeMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.DeleteRangeRequest,Kvrpcpb.DeleteRangeResponse> getKvDeleteRangeMethod()

getRawGetMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawGetRequest,Kvrpcpb.RawGetResponse> getRawGetMethod()

getRawBatchGetMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawBatchGetRequest,Kvrpcpb.RawBatchGetResponse> getRawBatchGetMethod()

getRawPutMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawPutRequest,Kvrpcpb.RawPutResponse> getRawPutMethod()

getRawBatchPutMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawBatchPutRequest,Kvrpcpb.RawBatchPutResponse> getRawBatchPutMethod()

getRawDeleteMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawDeleteRequest,Kvrpcpb.RawDeleteResponse> getRawDeleteMethod()

getRawBatchDeleteMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawBatchDeleteRequest,Kvrpcpb.RawBatchDeleteResponse> getRawBatchDeleteMethod()

getRawScanMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawScanRequest,Kvrpcpb.RawScanResponse> getRawScanMethod()

getRawDeleteRangeMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawDeleteRangeRequest,Kvrpcpb.RawDeleteRangeResponse> getRawDeleteRangeMethod()

getRawBatchScanMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawBatchScanRequest,Kvrpcpb.RawBatchScanResponse> getRawBatchScanMethod()

getRawGetKeyTTLMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawGetKeyTTLRequest,Kvrpcpb.RawGetKeyTTLResponse> getRawGetKeyTTLMethod()

getRawCompareAndSwapMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawCASRequest,Kvrpcpb.RawCASResponse> getRawCompareAndSwapMethod()

getRawChecksumMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawChecksumRequest,Kvrpcpb.RawChecksumResponse> getRawChecksumMethod()

getUnsafeDestroyRangeMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.UnsafeDestroyRangeRequest,Kvrpcpb.UnsafeDestroyRangeResponse> getUnsafeDestroyRangeMethod()

getRegisterLockObserverMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RegisterLockObserverRequest,Kvrpcpb.RegisterLockObserverResponse> getRegisterLockObserverMethod()

getCheckLockObserverMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.CheckLockObserverRequest,Kvrpcpb.CheckLockObserverResponse> getCheckLockObserverMethod()

getRemoveLockObserverMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RemoveLockObserverRequest,Kvrpcpb.RemoveLockObserverResponse> getRemoveLockObserverMethod()

getPhysicalScanLockMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.PhysicalScanLockRequest,Kvrpcpb.PhysicalScanLockResponse> getPhysicalScanLockMethod()

getCoprocessorMethod

public static io.grpc.MethodDescriptor<Coprocessor.Request,Coprocessor.Response> getCoprocessorMethod()

getCoprocessorStreamMethod

public static io.grpc.MethodDescriptor<Coprocessor.Request,Coprocessor.Response> getCoprocessorStreamMethod()

getBatchCoprocessorMethod

public static io.grpc.MethodDescriptor<Coprocessor.BatchRequest,Coprocessor.BatchResponse> getBatchCoprocessorMethod()

getRawCoprocessorMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.RawCoprocessorRequest,Kvrpcpb.RawCoprocessorResponse> getRawCoprocessorMethod()

getRaftMethod

public static io.grpc.MethodDescriptor<RaftServerpb.RaftMessage,RaftServerpb.Done> getRaftMethod()

getBatchRaftMethod

public static io.grpc.MethodDescriptor<Tikvpb.BatchRaftMessage,RaftServerpb.Done> getBatchRaftMethod()

getSnapshotMethod

public static io.grpc.MethodDescriptor<RaftServerpb.SnapshotChunk,RaftServerpb.Done> getSnapshotMethod()

getSplitRegionMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.SplitRegionRequest,Kvrpcpb.SplitRegionResponse> getSplitRegionMethod()

getReadIndexMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.ReadIndexRequest,Kvrpcpb.ReadIndexResponse> getReadIndexMethod()

getMvccGetByKeyMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.MvccGetByKeyRequest,Kvrpcpb.MvccGetByKeyResponse> getMvccGetByKeyMethod()

getMvccGetByStartTsMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.MvccGetByStartTsRequest,Kvrpcpb.MvccGetByStartTsResponse> getMvccGetByStartTsMethod()

getBatchCommandsMethod

public static io.grpc.MethodDescriptor<Tikvpb.BatchCommandsRequest,Tikvpb.BatchCommandsResponse> getBatchCommandsMethod()

getDispatchMPPTaskMethod

public static io.grpc.MethodDescriptor<Mpp.DispatchTaskRequest,Mpp.DispatchTaskResponse> getDispatchMPPTaskMethod()

getCancelMPPTaskMethod

public static io.grpc.MethodDescriptor<Mpp.CancelTaskRequest,Mpp.CancelTaskResponse> getCancelMPPTaskMethod()

getEstablishMPPConnectionMethod

public static io.grpc.MethodDescriptor<Mpp.EstablishMPPConnectionRequest,Mpp.MPPDataPacket> getEstablishMPPConnectionMethod()

getIsAliveMethod

public static io.grpc.MethodDescriptor<Mpp.IsAliveRequest,Mpp.IsAliveResponse> getIsAliveMethod()

getCheckLeaderMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.CheckLeaderRequest,Kvrpcpb.CheckLeaderResponse> getCheckLeaderMethod()

getGetStoreSafeTSMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.StoreSafeTSRequest,Kvrpcpb.StoreSafeTSResponse> getGetStoreSafeTSMethod()

getGetLockWaitInfoMethod

public static io.grpc.MethodDescriptor<Kvrpcpb.GetLockWaitInfoRequest,Kvrpcpb.GetLockWaitInfoResponse> getGetLockWaitInfoMethod()

newStub

public static TikvGrpc.TikvStub newStub(io.grpc.Channel channel)

Creates a new async stub that supports all call types for the service

newBlockingStub

public static TikvGrpc.TikvBlockingStub newBlockingStub(io.grpc.Channel channel)

Creates a new blocking-style stub that supports unary and streaming output calls on the service

newFutureStub

public static TikvGrpc.TikvFutureStub newFutureStub(io.grpc.Channel channel)

Creates a new ListenableFuture-style stub that supports unary calls on the service

bindService

public static final io.grpc.ServerServiceDefinition bindService(TikvGrpc.AsyncService service)

getServiceDescriptor

public static io.grpc.ServiceDescriptor getServiceDescriptor()