From 105fda166e5baadd0d94bce827dc8d25671b3daa Mon Sep 17 00:00:00 2001 From: youjiali1995 Date: Fri, 1 Nov 2019 11:32:53 +0800 Subject: [PATCH] add comment Signed-off-by: youjiali1995 --- pkg/kvrpcpb/kvrpcpb.pb.go | 173 +++++++++++++++++++------------------- proto/kvrpcpb.proto | 3 +- 2 files changed, 89 insertions(+), 87 deletions(-) diff --git a/pkg/kvrpcpb/kvrpcpb.pb.go b/pkg/kvrpcpb/kvrpcpb.pb.go index 3adfe4d7b..3e51fec4c 100644 --- a/pkg/kvrpcpb/kvrpcpb.pb.go +++ b/pkg/kvrpcpb/kvrpcpb.pb.go @@ -51,7 +51,7 @@ func (x CommandPri) String() string { return proto.EnumName(CommandPri_name, int32(x)) } func (CommandPri) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{0} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{0} } type IsolationLevel int32 @@ -74,7 +74,7 @@ func (x IsolationLevel) String() string { return proto.EnumName(IsolationLevel_name, int32(x)) } func (IsolationLevel) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{1} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{1} } type Op int32 @@ -110,7 +110,7 @@ func (x Op) String() string { return proto.EnumName(Op_name, int32(x)) } func (Op) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{2} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{2} } type Assertion int32 @@ -136,7 +136,7 @@ func (x Assertion) String() string { return proto.EnumName(Assertion_name, int32(x)) } func (Assertion) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{3} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{3} } type LockInfo struct { @@ -156,7 +156,7 @@ func (m *LockInfo) Reset() { *m = LockInfo{} } func (m *LockInfo) String() string { return proto.CompactTextString(m) } func (*LockInfo) ProtoMessage() {} func (*LockInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{0} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{0} } func (m *LockInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -238,7 +238,7 @@ func (m *AlreadyExist) Reset() { *m = AlreadyExist{} } func (m *AlreadyExist) String() string { return proto.CompactTextString(m) } func (*AlreadyExist) ProtoMessage() {} func (*AlreadyExist) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{1} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{1} } func (m *AlreadyExist) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -291,7 +291,7 @@ func (m *KeyError) Reset() { *m = KeyError{} } func (m *KeyError) String() string { return proto.CompactTextString(m) } func (*KeyError) ProtoMessage() {} func (*KeyError) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{2} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{2} } func (m *KeyError) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -384,7 +384,7 @@ func (m *WriteConflict) Reset() { *m = WriteConflict{} } func (m *WriteConflict) String() string { return proto.CompactTextString(m) } func (*WriteConflict) ProtoMessage() {} func (*WriteConflict) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{3} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{3} } func (m *WriteConflict) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -461,7 +461,7 @@ func (m *Deadlock) Reset() { *m = Deadlock{} } func (m *Deadlock) String() string { return proto.CompactTextString(m) } func (*Deadlock) ProtoMessage() {} func (*Deadlock) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{4} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{4} } func (m *Deadlock) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -525,7 +525,7 @@ func (m *CommitTsExpired) Reset() { *m = CommitTsExpired{} } func (m *CommitTsExpired) String() string { return proto.CompactTextString(m) } func (*CommitTsExpired) ProtoMessage() {} func (*CommitTsExpired) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{5} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{5} } func (m *CommitTsExpired) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -605,7 +605,7 @@ func (m *Context) Reset() { *m = Context{} } func (m *Context) String() string { return proto.CompactTextString(m) } func (*Context) ProtoMessage() {} func (*Context) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{6} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{6} } func (m *Context) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -737,7 +737,7 @@ func (m *HandleTime) Reset() { *m = HandleTime{} } func (m *HandleTime) String() string { return proto.CompactTextString(m) } func (*HandleTime) ProtoMessage() {} func (*HandleTime) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{7} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{7} } func (m *HandleTime) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -792,7 +792,7 @@ func (m *ScanInfo) Reset() { *m = ScanInfo{} } func (m *ScanInfo) String() string { return proto.CompactTextString(m) } func (*ScanInfo) ProtoMessage() {} func (*ScanInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{8} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{8} } func (m *ScanInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -848,7 +848,7 @@ func (m *ScanDetail) Reset() { *m = ScanDetail{} } func (m *ScanDetail) String() string { return proto.CompactTextString(m) } func (*ScanDetail) ProtoMessage() {} func (*ScanDetail) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{9} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{9} } func (m *ScanDetail) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -910,7 +910,7 @@ func (m *ExecDetails) Reset() { *m = ExecDetails{} } func (m *ExecDetails) String() string { return proto.CompactTextString(m) } func (*ExecDetails) ProtoMessage() {} func (*ExecDetails) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{10} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{10} } func (m *ExecDetails) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -966,7 +966,7 @@ func (m *GetRequest) Reset() { *m = GetRequest{} } func (m *GetRequest) String() string { return proto.CompactTextString(m) } func (*GetRequest) ProtoMessage() {} func (*GetRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{11} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{11} } func (m *GetRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1030,7 +1030,7 @@ func (m *GetResponse) Reset() { *m = GetResponse{} } func (m *GetResponse) String() string { return proto.CompactTextString(m) } func (*GetResponse) ProtoMessage() {} func (*GetResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{12} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{12} } func (m *GetResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1106,7 +1106,7 @@ func (m *ScanRequest) Reset() { *m = ScanRequest{} } func (m *ScanRequest) String() string { return proto.CompactTextString(m) } func (*ScanRequest) ProtoMessage() {} func (*ScanRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{13} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{13} } func (m *ScanRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1197,7 +1197,7 @@ func (m *KvPair) Reset() { *m = KvPair{} } func (m *KvPair) String() string { return proto.CompactTextString(m) } func (*KvPair) ProtoMessage() {} func (*KvPair) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{14} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{14} } func (m *KvPair) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1259,7 +1259,7 @@ func (m *ScanResponse) Reset() { *m = ScanResponse{} } func (m *ScanResponse) String() string { return proto.CompactTextString(m) } func (*ScanResponse) ProtoMessage() {} func (*ScanResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{15} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{15} } func (m *ScanResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1316,7 +1316,7 @@ func (m *Mutation) Reset() { *m = Mutation{} } func (m *Mutation) String() string { return proto.CompactTextString(m) } func (*Mutation) ProtoMessage() {} func (*Mutation) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{16} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{16} } func (m *Mutation) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1399,7 +1399,7 @@ func (m *PrewriteRequest) Reset() { *m = PrewriteRequest{} } func (m *PrewriteRequest) String() string { return proto.CompactTextString(m) } func (*PrewriteRequest) ProtoMessage() {} func (*PrewriteRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{17} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{17} } func (m *PrewriteRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1510,7 +1510,7 @@ func (m *PrewriteResponse) Reset() { *m = PrewriteResponse{} } func (m *PrewriteResponse) String() string { return proto.CompactTextString(m) } func (*PrewriteResponse) ProtoMessage() {} func (*PrewriteResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{18} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{18} } func (m *PrewriteResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1568,7 +1568,7 @@ func (m *TxnHeartBeatRequest) Reset() { *m = TxnHeartBeatRequest{} } func (m *TxnHeartBeatRequest) String() string { return proto.CompactTextString(m) } func (*TxnHeartBeatRequest) ProtoMessage() {} func (*TxnHeartBeatRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{19} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{19} } func (m *TxnHeartBeatRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1638,7 +1638,7 @@ func (m *TxnHeartBeatResponse) Reset() { *m = TxnHeartBeatResponse{} } func (m *TxnHeartBeatResponse) String() string { return proto.CompactTextString(m) } func (*TxnHeartBeatResponse) ProtoMessage() {} func (*TxnHeartBeatResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{20} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{20} } func (m *TxnHeartBeatResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1698,7 +1698,8 @@ type PessimisticLockRequest struct { ForUpdateTs uint64 `protobuf:"varint,6,opt,name=for_update_ts,json=forUpdateTs,proto3" json:"for_update_ts,omitempty"` // If the request is the first lock request, we don't need to detect deadlock. IsFirstLock bool `protobuf:"varint,7,opt,name=is_first_lock,json=isFirstLock,proto3" json:"is_first_lock,omitempty"` - // Time to wait for lock released in milliseconds when encountering locks + // Time to wait for lock released in milliseconds when encountering locks. + // 0 means using default timeout in TiKV. Negative means no wait. WaitTimeout int64 `protobuf:"varint,8,opt,name=wait_timeout,json=waitTimeout,proto3" json:"wait_timeout,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -1709,7 +1710,7 @@ func (m *PessimisticLockRequest) Reset() { *m = PessimisticLockRequest{} func (m *PessimisticLockRequest) String() string { return proto.CompactTextString(m) } func (*PessimisticLockRequest) ProtoMessage() {} func (*PessimisticLockRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{21} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{21} } func (m *PessimisticLockRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1806,7 +1807,7 @@ func (m *PessimisticLockResponse) Reset() { *m = PessimisticLockResponse func (m *PessimisticLockResponse) String() string { return proto.CompactTextString(m) } func (*PessimisticLockResponse) ProtoMessage() {} func (*PessimisticLockResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{22} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{22} } func (m *PessimisticLockResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1863,7 +1864,7 @@ func (m *PessimisticRollbackRequest) Reset() { *m = PessimisticRollbackR func (m *PessimisticRollbackRequest) String() string { return proto.CompactTextString(m) } func (*PessimisticRollbackRequest) ProtoMessage() {} func (*PessimisticRollbackRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{23} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{23} } func (m *PessimisticRollbackRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1932,7 +1933,7 @@ func (m *PessimisticRollbackResponse) Reset() { *m = PessimisticRollback func (m *PessimisticRollbackResponse) String() string { return proto.CompactTextString(m) } func (*PessimisticRollbackResponse) ProtoMessage() {} func (*PessimisticRollbackResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{24} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{24} } func (m *PessimisticRollbackResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1989,7 +1990,7 @@ func (m *CommitRequest) Reset() { *m = CommitRequest{} } func (m *CommitRequest) String() string { return proto.CompactTextString(m) } func (*CommitRequest) ProtoMessage() {} func (*CommitRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{25} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{25} } func (m *CommitRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2059,7 +2060,7 @@ func (m *CommitResponse) Reset() { *m = CommitResponse{} } func (m *CommitResponse) String() string { return proto.CompactTextString(m) } func (*CommitResponse) ProtoMessage() {} func (*CommitResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{26} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{26} } func (m *CommitResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2121,7 +2122,7 @@ func (m *ImportRequest) Reset() { *m = ImportRequest{} } func (m *ImportRequest) String() string { return proto.CompactTextString(m) } func (*ImportRequest) ProtoMessage() {} func (*ImportRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{27} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{27} } func (m *ImportRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2176,7 +2177,7 @@ func (m *ImportResponse) Reset() { *m = ImportResponse{} } func (m *ImportResponse) String() string { return proto.CompactTextString(m) } func (*ImportResponse) ProtoMessage() {} func (*ImportResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{28} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{28} } func (m *ImportResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2232,7 +2233,7 @@ func (m *BatchRollbackRequest) Reset() { *m = BatchRollbackRequest{} } func (m *BatchRollbackRequest) String() string { return proto.CompactTextString(m) } func (*BatchRollbackRequest) ProtoMessage() {} func (*BatchRollbackRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{29} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{29} } func (m *BatchRollbackRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2294,7 +2295,7 @@ func (m *BatchRollbackResponse) Reset() { *m = BatchRollbackResponse{} } func (m *BatchRollbackResponse) String() string { return proto.CompactTextString(m) } func (*BatchRollbackResponse) ProtoMessage() {} func (*BatchRollbackResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{30} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{30} } func (m *BatchRollbackResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2358,7 +2359,7 @@ func (m *CheckTxnStatusRequest) Reset() { *m = CheckTxnStatusRequest{} } func (m *CheckTxnStatusRequest) String() string { return proto.CompactTextString(m) } func (*CheckTxnStatusRequest) ProtoMessage() {} func (*CheckTxnStatusRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{31} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{31} } func (m *CheckTxnStatusRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2440,7 +2441,7 @@ func (m *CheckTxnStatusResponse) Reset() { *m = CheckTxnStatusResponse{} func (m *CheckTxnStatusResponse) String() string { return proto.CompactTextString(m) } func (*CheckTxnStatusResponse) ProtoMessage() {} func (*CheckTxnStatusResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{32} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{32} } func (m *CheckTxnStatusResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2511,7 +2512,7 @@ func (m *CleanupRequest) Reset() { *m = CleanupRequest{} } func (m *CleanupRequest) String() string { return proto.CompactTextString(m) } func (*CleanupRequest) ProtoMessage() {} func (*CleanupRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{33} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{33} } func (m *CleanupRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2581,7 +2582,7 @@ func (m *CleanupResponse) Reset() { *m = CleanupResponse{} } func (m *CleanupResponse) String() string { return proto.CompactTextString(m) } func (*CleanupResponse) ProtoMessage() {} func (*CleanupResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{34} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{34} } func (m *CleanupResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2644,7 +2645,7 @@ func (m *BatchGetRequest) Reset() { *m = BatchGetRequest{} } func (m *BatchGetRequest) String() string { return proto.CompactTextString(m) } func (*BatchGetRequest) ProtoMessage() {} func (*BatchGetRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{35} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{35} } func (m *BatchGetRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2706,7 +2707,7 @@ func (m *BatchGetResponse) Reset() { *m = BatchGetResponse{} } func (m *BatchGetResponse) String() string { return proto.CompactTextString(m) } func (*BatchGetResponse) ProtoMessage() {} func (*BatchGetResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{36} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{36} } func (m *BatchGetResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2763,7 +2764,7 @@ func (m *ScanLockRequest) Reset() { *m = ScanLockRequest{} } func (m *ScanLockRequest) String() string { return proto.CompactTextString(m) } func (*ScanLockRequest) ProtoMessage() {} func (*ScanLockRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{37} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{37} } func (m *ScanLockRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2833,7 +2834,7 @@ func (m *ScanLockResponse) Reset() { *m = ScanLockResponse{} } func (m *ScanLockResponse) String() string { return proto.CompactTextString(m) } func (*ScanLockResponse) ProtoMessage() {} func (*ScanLockResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{38} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{38} } func (m *ScanLockResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2895,7 +2896,7 @@ func (m *TxnInfo) Reset() { *m = TxnInfo{} } func (m *TxnInfo) String() string { return proto.CompactTextString(m) } func (*TxnInfo) ProtoMessage() {} func (*TxnInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{39} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{39} } func (m *TxnInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2955,7 +2956,7 @@ func (m *ResolveLockRequest) Reset() { *m = ResolveLockRequest{} } func (m *ResolveLockRequest) String() string { return proto.CompactTextString(m) } func (*ResolveLockRequest) ProtoMessage() {} func (*ResolveLockRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{40} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{40} } func (m *ResolveLockRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3031,7 +3032,7 @@ func (m *ResolveLockResponse) Reset() { *m = ResolveLockResponse{} } func (m *ResolveLockResponse) String() string { return proto.CompactTextString(m) } func (*ResolveLockResponse) ProtoMessage() {} func (*ResolveLockResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{41} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{41} } func (m *ResolveLockResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3086,7 +3087,7 @@ func (m *GCRequest) Reset() { *m = GCRequest{} } func (m *GCRequest) String() string { return proto.CompactTextString(m) } func (*GCRequest) ProtoMessage() {} func (*GCRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{42} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{42} } func (m *GCRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3141,7 +3142,7 @@ func (m *GCResponse) Reset() { *m = GCResponse{} } func (m *GCResponse) String() string { return proto.CompactTextString(m) } func (*GCResponse) ProtoMessage() {} func (*GCResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{43} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{43} } func (m *GCResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3197,7 +3198,7 @@ func (m *RawGetRequest) Reset() { *m = RawGetRequest{} } func (m *RawGetRequest) String() string { return proto.CompactTextString(m) } func (*RawGetRequest) ProtoMessage() {} func (*RawGetRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{44} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{44} } func (m *RawGetRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3261,7 +3262,7 @@ func (m *RawGetResponse) Reset() { *m = RawGetResponse{} } func (m *RawGetResponse) String() string { return proto.CompactTextString(m) } func (*RawGetResponse) ProtoMessage() {} func (*RawGetResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{45} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{45} } func (m *RawGetResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3332,7 +3333,7 @@ func (m *RawPutRequest) Reset() { *m = RawPutRequest{} } func (m *RawPutRequest) String() string { return proto.CompactTextString(m) } func (*RawPutRequest) ProtoMessage() {} func (*RawPutRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{46} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{46} } func (m *RawPutRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3401,7 +3402,7 @@ func (m *RawPutResponse) Reset() { *m = RawPutResponse{} } func (m *RawPutResponse) String() string { return proto.CompactTextString(m) } func (*RawPutResponse) ProtoMessage() {} func (*RawPutResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{47} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{47} } func (m *RawPutResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3457,7 +3458,7 @@ func (m *RawBatchPutRequest) Reset() { *m = RawBatchPutRequest{} } func (m *RawBatchPutRequest) String() string { return proto.CompactTextString(m) } func (*RawBatchPutRequest) ProtoMessage() {} func (*RawBatchPutRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{48} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{48} } func (m *RawBatchPutRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3519,7 +3520,7 @@ func (m *RawBatchPutResponse) Reset() { *m = RawBatchPutResponse{} } func (m *RawBatchPutResponse) String() string { return proto.CompactTextString(m) } func (*RawBatchPutResponse) ProtoMessage() {} func (*RawBatchPutResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{49} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{49} } func (m *RawBatchPutResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3575,7 +3576,7 @@ func (m *RawBatchGetRequest) Reset() { *m = RawBatchGetRequest{} } func (m *RawBatchGetRequest) String() string { return proto.CompactTextString(m) } func (*RawBatchGetRequest) ProtoMessage() {} func (*RawBatchGetRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{50} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{50} } func (m *RawBatchGetRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3637,7 +3638,7 @@ func (m *RawBatchGetResponse) Reset() { *m = RawBatchGetResponse{} } func (m *RawBatchGetResponse) String() string { return proto.CompactTextString(m) } func (*RawBatchGetResponse) ProtoMessage() {} func (*RawBatchGetResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{51} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{51} } func (m *RawBatchGetResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3693,7 +3694,7 @@ func (m *RawDeleteRequest) Reset() { *m = RawDeleteRequest{} } func (m *RawDeleteRequest) String() string { return proto.CompactTextString(m) } func (*RawDeleteRequest) ProtoMessage() {} func (*RawDeleteRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{52} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{52} } func (m *RawDeleteRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3755,7 +3756,7 @@ func (m *RawDeleteResponse) Reset() { *m = RawDeleteResponse{} } func (m *RawDeleteResponse) String() string { return proto.CompactTextString(m) } func (*RawDeleteResponse) ProtoMessage() {} func (*RawDeleteResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{53} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{53} } func (m *RawDeleteResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3811,7 +3812,7 @@ func (m *RawBatchDeleteRequest) Reset() { *m = RawBatchDeleteRequest{} } func (m *RawBatchDeleteRequest) String() string { return proto.CompactTextString(m) } func (*RawBatchDeleteRequest) ProtoMessage() {} func (*RawBatchDeleteRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{54} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{54} } func (m *RawBatchDeleteRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3873,7 +3874,7 @@ func (m *RawBatchDeleteResponse) Reset() { *m = RawBatchDeleteResponse{} func (m *RawBatchDeleteResponse) String() string { return proto.CompactTextString(m) } func (*RawBatchDeleteResponse) ProtoMessage() {} func (*RawBatchDeleteResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{55} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{55} } func (m *RawBatchDeleteResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3930,7 +3931,7 @@ func (m *DeleteRangeRequest) Reset() { *m = DeleteRangeRequest{} } func (m *DeleteRangeRequest) String() string { return proto.CompactTextString(m) } func (*DeleteRangeRequest) ProtoMessage() {} func (*DeleteRangeRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{56} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{56} } func (m *DeleteRangeRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -3999,7 +4000,7 @@ func (m *DeleteRangeResponse) Reset() { *m = DeleteRangeResponse{} } func (m *DeleteRangeResponse) String() string { return proto.CompactTextString(m) } func (*DeleteRangeResponse) ProtoMessage() {} func (*DeleteRangeResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{57} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{57} } func (m *DeleteRangeResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4056,7 +4057,7 @@ func (m *RawDeleteRangeRequest) Reset() { *m = RawDeleteRangeRequest{} } func (m *RawDeleteRangeRequest) String() string { return proto.CompactTextString(m) } func (*RawDeleteRangeRequest) ProtoMessage() {} func (*RawDeleteRangeRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{58} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{58} } func (m *RawDeleteRangeRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4125,7 +4126,7 @@ func (m *RawDeleteRangeResponse) Reset() { *m = RawDeleteRangeResponse{} func (m *RawDeleteRangeResponse) String() string { return proto.CompactTextString(m) } func (*RawDeleteRangeResponse) ProtoMessage() {} func (*RawDeleteRangeResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{59} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{59} } func (m *RawDeleteRangeResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4187,7 +4188,7 @@ func (m *RawScanRequest) Reset() { *m = RawScanRequest{} } func (m *RawScanRequest) String() string { return proto.CompactTextString(m) } func (*RawScanRequest) ProtoMessage() {} func (*RawScanRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{60} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{60} } func (m *RawScanRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4277,7 +4278,7 @@ func (m *RawScanResponse) Reset() { *m = RawScanResponse{} } func (m *RawScanResponse) String() string { return proto.CompactTextString(m) } func (*RawScanResponse) ProtoMessage() {} func (*RawScanResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{61} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{61} } func (m *RawScanResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4332,7 +4333,7 @@ func (m *KeyRange) Reset() { *m = KeyRange{} } func (m *KeyRange) String() string { return proto.CompactTextString(m) } func (*KeyRange) ProtoMessage() {} func (*KeyRange) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{62} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{62} } func (m *KeyRange) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4391,7 +4392,7 @@ func (m *RawBatchScanRequest) Reset() { *m = RawBatchScanRequest{} } func (m *RawBatchScanRequest) String() string { return proto.CompactTextString(m) } func (*RawBatchScanRequest) ProtoMessage() {} func (*RawBatchScanRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{63} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{63} } func (m *RawBatchScanRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4474,7 +4475,7 @@ func (m *RawBatchScanResponse) Reset() { *m = RawBatchScanResponse{} } func (m *RawBatchScanResponse) String() string { return proto.CompactTextString(m) } func (*RawBatchScanResponse) ProtoMessage() {} func (*RawBatchScanResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{64} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{64} } func (m *RawBatchScanResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4531,7 +4532,7 @@ func (m *MvccWrite) Reset() { *m = MvccWrite{} } func (m *MvccWrite) String() string { return proto.CompactTextString(m) } func (*MvccWrite) ProtoMessage() {} func (*MvccWrite) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{65} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{65} } func (m *MvccWrite) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4600,7 +4601,7 @@ func (m *MvccValue) Reset() { *m = MvccValue{} } func (m *MvccValue) String() string { return proto.CompactTextString(m) } func (*MvccValue) ProtoMessage() {} func (*MvccValue) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{66} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{66} } func (m *MvccValue) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4657,7 +4658,7 @@ func (m *MvccLock) Reset() { *m = MvccLock{} } func (m *MvccLock) String() string { return proto.CompactTextString(m) } func (*MvccLock) ProtoMessage() {} func (*MvccLock) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{67} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{67} } func (m *MvccLock) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4727,7 +4728,7 @@ func (m *MvccInfo) Reset() { *m = MvccInfo{} } func (m *MvccInfo) String() string { return proto.CompactTextString(m) } func (*MvccInfo) ProtoMessage() {} func (*MvccInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{68} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{68} } func (m *MvccInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4789,7 +4790,7 @@ func (m *MvccGetByKeyRequest) Reset() { *m = MvccGetByKeyRequest{} } func (m *MvccGetByKeyRequest) String() string { return proto.CompactTextString(m) } func (*MvccGetByKeyRequest) ProtoMessage() {} func (*MvccGetByKeyRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{69} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{69} } func (m *MvccGetByKeyRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4845,7 +4846,7 @@ func (m *MvccGetByKeyResponse) Reset() { *m = MvccGetByKeyResponse{} } func (m *MvccGetByKeyResponse) String() string { return proto.CompactTextString(m) } func (*MvccGetByKeyResponse) ProtoMessage() {} func (*MvccGetByKeyResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{70} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{70} } func (m *MvccGetByKeyResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4907,7 +4908,7 @@ func (m *MvccGetByStartTsRequest) Reset() { *m = MvccGetByStartTsRequest func (m *MvccGetByStartTsRequest) String() string { return proto.CompactTextString(m) } func (*MvccGetByStartTsRequest) ProtoMessage() {} func (*MvccGetByStartTsRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{71} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{71} } func (m *MvccGetByStartTsRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -4964,7 +4965,7 @@ func (m *MvccGetByStartTsResponse) Reset() { *m = MvccGetByStartTsRespon func (m *MvccGetByStartTsResponse) String() string { return proto.CompactTextString(m) } func (*MvccGetByStartTsResponse) ProtoMessage() {} func (*MvccGetByStartTsResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{72} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{72} } func (m *MvccGetByStartTsResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -5034,7 +5035,7 @@ func (m *SplitRegionRequest) Reset() { *m = SplitRegionRequest{} } func (m *SplitRegionRequest) String() string { return proto.CompactTextString(m) } func (*SplitRegionRequest) ProtoMessage() {} func (*SplitRegionRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{73} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{73} } func (m *SplitRegionRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -5099,7 +5100,7 @@ func (m *SplitRegionResponse) Reset() { *m = SplitRegionResponse{} } func (m *SplitRegionResponse) String() string { return proto.CompactTextString(m) } func (*SplitRegionResponse) ProtoMessage() {} func (*SplitRegionResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{74} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{74} } func (m *SplitRegionResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -5171,7 +5172,7 @@ func (m *UnsafeDestroyRangeRequest) Reset() { *m = UnsafeDestroyRangeReq func (m *UnsafeDestroyRangeRequest) String() string { return proto.CompactTextString(m) } func (*UnsafeDestroyRangeRequest) ProtoMessage() {} func (*UnsafeDestroyRangeRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{75} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{75} } func (m *UnsafeDestroyRangeRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -5233,7 +5234,7 @@ func (m *UnsafeDestroyRangeResponse) Reset() { *m = UnsafeDestroyRangeRe func (m *UnsafeDestroyRangeResponse) String() string { return proto.CompactTextString(m) } func (*UnsafeDestroyRangeResponse) ProtoMessage() {} func (*UnsafeDestroyRangeResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{76} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{76} } func (m *UnsafeDestroyRangeResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -5287,7 +5288,7 @@ func (m *ReadIndexRequest) Reset() { *m = ReadIndexRequest{} } func (m *ReadIndexRequest) String() string { return proto.CompactTextString(m) } func (*ReadIndexRequest) ProtoMessage() {} func (*ReadIndexRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{77} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{77} } func (m *ReadIndexRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -5335,7 +5336,7 @@ func (m *ReadIndexResponse) Reset() { *m = ReadIndexResponse{} } func (m *ReadIndexResponse) String() string { return proto.CompactTextString(m) } func (*ReadIndexResponse) ProtoMessage() {} func (*ReadIndexResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_kvrpcpb_cf4331eb73d7af5f, []int{78} + return fileDescriptor_kvrpcpb_7b479ecd31827c02, []int{78} } func (m *ReadIndexResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -22487,9 +22488,9 @@ var ( ErrIntOverflowKvrpcpb = fmt.Errorf("proto: integer overflow") ) -func init() { proto.RegisterFile("kvrpcpb.proto", fileDescriptor_kvrpcpb_cf4331eb73d7af5f) } +func init() { proto.RegisterFile("kvrpcpb.proto", fileDescriptor_kvrpcpb_7b479ecd31827c02) } -var fileDescriptor_kvrpcpb_cf4331eb73d7af5f = []byte{ +var fileDescriptor_kvrpcpb_7b479ecd31827c02 = []byte{ // 2826 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xdc, 0x5a, 0xcf, 0x8f, 0x1c, 0x47, 0xf5, 0x77, 0xcf, 0xef, 0x79, 0xf3, 0x73, 0x6b, 0xd7, 0xf6, 0xc4, 0xfe, 0xda, 0xde, 0xf4, 0x17, diff --git a/proto/kvrpcpb.proto b/proto/kvrpcpb.proto index d85ea313b..70d123457 100644 --- a/proto/kvrpcpb.proto +++ b/proto/kvrpcpb.proto @@ -215,7 +215,8 @@ message PessimisticLockRequest { uint64 for_update_ts = 6; // If the request is the first lock request, we don't need to detect deadlock. bool is_first_lock = 7; - // Time to wait for lock released in milliseconds when encountering locks + // Time to wait for lock released in milliseconds when encountering locks. + // 0 means using default timeout in TiKV. Negative means no wait. int64 wait_timeout = 8; }