Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var AdminCmdType_name = map[int32]string + var AdminCmdType_value = map[string]int32 + var CmdType_name = map[int32]string + var CmdType_value = map[string]int32 + var ErrIntOverflowRaftCmdpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRaftCmdpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupRaftCmdpb = fmt.Errorf("proto: unexpected end of group") + var StatusCmdType_name = map[int32]string + var StatusCmdType_value = map[string]int32 + type AdminCmdType int32 + const AdminCmdType_BatchSplit + const AdminCmdType_BatchSwitchWitness + const AdminCmdType_ChangePeer + const AdminCmdType_ChangePeerV2 + const AdminCmdType_CommitMerge + const AdminCmdType_CompactLog + const AdminCmdType_ComputeHash + const AdminCmdType_FinishFlashback + const AdminCmdType_InvalidAdmin + const AdminCmdType_PrepareFlashback + const AdminCmdType_PrepareMerge + const AdminCmdType_RollbackMerge + const AdminCmdType_Split + const AdminCmdType_TransferLeader + const AdminCmdType_UpdateGcPeer + const AdminCmdType_VerifyHash + func (AdminCmdType) EnumDescriptor() ([]byte, []int) + func (x AdminCmdType) String() string + type AdminRequest struct + ChangePeer *ChangePeerRequest + ChangePeerV2 *ChangePeerV2Request + CmdType AdminCmdType + CommitMerge *CommitMergeRequest + CompactLog *CompactLogRequest + ComputeHash *ComputeHashRequest + FinishFlashback *FinishFlashbackRequest + PrepareFlashback *PrepareFlashbackRequest + PrepareMerge *PrepareMergeRequest + RollbackMerge *RollbackMergeRequest + Split *SplitRequest + Splits *BatchSplitRequest + SwitchWitnesses *BatchSwitchWitnessRequest + TransferLeader *TransferLeaderRequest + UpdateGcPeers *UpdateGcPeerRequest + VerifyHash *VerifyHashRequest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AdminRequest) Descriptor() ([]byte, []int) + func (*AdminRequest) ProtoMessage() + func (m *AdminRequest) GetChangePeer() *ChangePeerRequest + func (m *AdminRequest) GetChangePeerV2() *ChangePeerV2Request + func (m *AdminRequest) GetCmdType() AdminCmdType + func (m *AdminRequest) GetCommitMerge() *CommitMergeRequest + func (m *AdminRequest) GetCompactLog() *CompactLogRequest + func (m *AdminRequest) GetComputeHash() *ComputeHashRequest + func (m *AdminRequest) GetFinishFlashback() *FinishFlashbackRequest + func (m *AdminRequest) GetPrepareFlashback() *PrepareFlashbackRequest + func (m *AdminRequest) GetPrepareMerge() *PrepareMergeRequest + func (m *AdminRequest) GetRollbackMerge() *RollbackMergeRequest + func (m *AdminRequest) GetSplit() *SplitRequest + func (m *AdminRequest) GetSplits() *BatchSplitRequest + func (m *AdminRequest) GetSwitchWitnesses() *BatchSwitchWitnessRequest + func (m *AdminRequest) GetTransferLeader() *TransferLeaderRequest + func (m *AdminRequest) GetUpdateGcPeers() *UpdateGcPeerRequest + func (m *AdminRequest) GetVerifyHash() *VerifyHashRequest + func (m *AdminRequest) Marshal() (dAtA []byte, err error) + func (m *AdminRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AdminRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AdminRequest) Reset() + func (m *AdminRequest) Size() (n int) + func (m *AdminRequest) String() string + func (m *AdminRequest) Unmarshal(dAtA []byte) error + func (m *AdminRequest) XXX_DiscardUnknown() + func (m *AdminRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AdminRequest) XXX_Merge(src proto.Message) + func (m *AdminRequest) XXX_Size() int + func (m *AdminRequest) XXX_Unmarshal(b []byte) error + type AdminResponse struct + ChangePeer *ChangePeerResponse + ChangePeerV2 *ChangePeerV2Response + CmdType AdminCmdType + CommitMerge *CommitMergeResponse + CompactLog *CompactLogResponse + FinishFlashback *FinishFlashbackResponse + PrepareFlashback *PrepareFlashbackResponse + PrepareMerge *PrepareMergeResponse + RollbackMerge *RollbackMergeResponse + Split *SplitResponse + Splits *BatchSplitResponse + SwitchWitnesses *BatchSwitchWitnessResponse + TransferLeader *TransferLeaderResponse + VerifyHash *VerifyHashResponse + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AdminResponse) Descriptor() ([]byte, []int) + func (*AdminResponse) ProtoMessage() + func (m *AdminResponse) GetChangePeer() *ChangePeerResponse + func (m *AdminResponse) GetChangePeerV2() *ChangePeerV2Response + func (m *AdminResponse) GetCmdType() AdminCmdType + func (m *AdminResponse) GetCommitMerge() *CommitMergeResponse + func (m *AdminResponse) GetCompactLog() *CompactLogResponse + func (m *AdminResponse) GetFinishFlashback() *FinishFlashbackResponse + func (m *AdminResponse) GetPrepareFlashback() *PrepareFlashbackResponse + func (m *AdminResponse) GetPrepareMerge() *PrepareMergeResponse + func (m *AdminResponse) GetRollbackMerge() *RollbackMergeResponse + func (m *AdminResponse) GetSplit() *SplitResponse + func (m *AdminResponse) GetSplits() *BatchSplitResponse + func (m *AdminResponse) GetSwitchWitnesses() *BatchSwitchWitnessResponse + func (m *AdminResponse) GetTransferLeader() *TransferLeaderResponse + func (m *AdminResponse) GetVerifyHash() *VerifyHashResponse + func (m *AdminResponse) Marshal() (dAtA []byte, err error) + func (m *AdminResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AdminResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AdminResponse) Reset() + func (m *AdminResponse) Size() (n int) + func (m *AdminResponse) String() string + func (m *AdminResponse) Unmarshal(dAtA []byte) error + func (m *AdminResponse) XXX_DiscardUnknown() + func (m *AdminResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AdminResponse) XXX_Merge(src proto.Message) + func (m *AdminResponse) XXX_Size() int + func (m *AdminResponse) XXX_Unmarshal(b []byte) error + type BatchSplitRequest struct + Requests []*SplitRequest + RightDerive bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchSplitRequest) Descriptor() ([]byte, []int) + func (*BatchSplitRequest) ProtoMessage() + func (m *BatchSplitRequest) GetRequests() []*SplitRequest + func (m *BatchSplitRequest) GetRightDerive() bool + func (m *BatchSplitRequest) Marshal() (dAtA []byte, err error) + func (m *BatchSplitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BatchSplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchSplitRequest) Reset() + func (m *BatchSplitRequest) Size() (n int) + func (m *BatchSplitRequest) String() string + func (m *BatchSplitRequest) Unmarshal(dAtA []byte) error + func (m *BatchSplitRequest) XXX_DiscardUnknown() + func (m *BatchSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchSplitRequest) XXX_Merge(src proto.Message) + func (m *BatchSplitRequest) XXX_Size() int + func (m *BatchSplitRequest) XXX_Unmarshal(b []byte) error + type BatchSplitResponse struct + Regions []*metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchSplitResponse) Descriptor() ([]byte, []int) + func (*BatchSplitResponse) ProtoMessage() + func (m *BatchSplitResponse) GetRegions() []*metapb.Region + func (m *BatchSplitResponse) Marshal() (dAtA []byte, err error) + func (m *BatchSplitResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BatchSplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchSplitResponse) Reset() + func (m *BatchSplitResponse) Size() (n int) + func (m *BatchSplitResponse) String() string + func (m *BatchSplitResponse) Unmarshal(dAtA []byte) error + func (m *BatchSplitResponse) XXX_DiscardUnknown() + func (m *BatchSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchSplitResponse) XXX_Merge(src proto.Message) + func (m *BatchSplitResponse) XXX_Size() int + func (m *BatchSplitResponse) XXX_Unmarshal(b []byte) error + type BatchSwitchWitnessRequest struct + SwitchWitnesses []*SwitchWitnessRequest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchSwitchWitnessRequest) Descriptor() ([]byte, []int) + func (*BatchSwitchWitnessRequest) ProtoMessage() + func (m *BatchSwitchWitnessRequest) GetSwitchWitnesses() []*SwitchWitnessRequest + func (m *BatchSwitchWitnessRequest) Marshal() (dAtA []byte, err error) + func (m *BatchSwitchWitnessRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BatchSwitchWitnessRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchSwitchWitnessRequest) Reset() + func (m *BatchSwitchWitnessRequest) Size() (n int) + func (m *BatchSwitchWitnessRequest) String() string + func (m *BatchSwitchWitnessRequest) Unmarshal(dAtA []byte) error + func (m *BatchSwitchWitnessRequest) XXX_DiscardUnknown() + func (m *BatchSwitchWitnessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchSwitchWitnessRequest) XXX_Merge(src proto.Message) + func (m *BatchSwitchWitnessRequest) XXX_Size() int + func (m *BatchSwitchWitnessRequest) XXX_Unmarshal(b []byte) error + type BatchSwitchWitnessResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchSwitchWitnessResponse) Descriptor() ([]byte, []int) + func (*BatchSwitchWitnessResponse) ProtoMessage() + func (m *BatchSwitchWitnessResponse) Marshal() (dAtA []byte, err error) + func (m *BatchSwitchWitnessResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BatchSwitchWitnessResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchSwitchWitnessResponse) Reset() + func (m *BatchSwitchWitnessResponse) Size() (n int) + func (m *BatchSwitchWitnessResponse) String() string + func (m *BatchSwitchWitnessResponse) Unmarshal(dAtA []byte) error + func (m *BatchSwitchWitnessResponse) XXX_DiscardUnknown() + func (m *BatchSwitchWitnessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchSwitchWitnessResponse) XXX_Merge(src proto.Message) + func (m *BatchSwitchWitnessResponse) XXX_Size() int + func (m *BatchSwitchWitnessResponse) XXX_Unmarshal(b []byte) error + type ChangePeerRequest struct + ChangeType eraftpb.ConfChangeType + Peer *metapb.Peer + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangePeerRequest) Descriptor() ([]byte, []int) + func (*ChangePeerRequest) ProtoMessage() + func (m *ChangePeerRequest) GetChangeType() eraftpb.ConfChangeType + func (m *ChangePeerRequest) GetPeer() *metapb.Peer + func (m *ChangePeerRequest) Marshal() (dAtA []byte, err error) + func (m *ChangePeerRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ChangePeerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangePeerRequest) Reset() + func (m *ChangePeerRequest) Size() (n int) + func (m *ChangePeerRequest) String() string + func (m *ChangePeerRequest) Unmarshal(dAtA []byte) error + func (m *ChangePeerRequest) XXX_DiscardUnknown() + func (m *ChangePeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangePeerRequest) XXX_Merge(src proto.Message) + func (m *ChangePeerRequest) XXX_Size() int + func (m *ChangePeerRequest) XXX_Unmarshal(b []byte) error + type ChangePeerResponse struct + Region *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangePeerResponse) Descriptor() ([]byte, []int) + func (*ChangePeerResponse) ProtoMessage() + func (m *ChangePeerResponse) GetRegion() *metapb.Region + func (m *ChangePeerResponse) Marshal() (dAtA []byte, err error) + func (m *ChangePeerResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ChangePeerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangePeerResponse) Reset() + func (m *ChangePeerResponse) Size() (n int) + func (m *ChangePeerResponse) String() string + func (m *ChangePeerResponse) Unmarshal(dAtA []byte) error + func (m *ChangePeerResponse) XXX_DiscardUnknown() + func (m *ChangePeerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangePeerResponse) XXX_Merge(src proto.Message) + func (m *ChangePeerResponse) XXX_Size() int + func (m *ChangePeerResponse) XXX_Unmarshal(b []byte) error + type ChangePeerV2Request struct + Changes []*ChangePeerRequest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangePeerV2Request) Descriptor() ([]byte, []int) + func (*ChangePeerV2Request) ProtoMessage() + func (m *ChangePeerV2Request) GetChanges() []*ChangePeerRequest + func (m *ChangePeerV2Request) Marshal() (dAtA []byte, err error) + func (m *ChangePeerV2Request) MarshalTo(dAtA []byte) (int, error) + func (m *ChangePeerV2Request) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangePeerV2Request) Reset() + func (m *ChangePeerV2Request) Size() (n int) + func (m *ChangePeerV2Request) String() string + func (m *ChangePeerV2Request) Unmarshal(dAtA []byte) error + func (m *ChangePeerV2Request) XXX_DiscardUnknown() + func (m *ChangePeerV2Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangePeerV2Request) XXX_Merge(src proto.Message) + func (m *ChangePeerV2Request) XXX_Size() int + func (m *ChangePeerV2Request) XXX_Unmarshal(b []byte) error + type ChangePeerV2Response struct + Region *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangePeerV2Response) Descriptor() ([]byte, []int) + func (*ChangePeerV2Response) ProtoMessage() + func (m *ChangePeerV2Response) GetRegion() *metapb.Region + func (m *ChangePeerV2Response) Marshal() (dAtA []byte, err error) + func (m *ChangePeerV2Response) MarshalTo(dAtA []byte) (int, error) + func (m *ChangePeerV2Response) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangePeerV2Response) Reset() + func (m *ChangePeerV2Response) Size() (n int) + func (m *ChangePeerV2Response) String() string + func (m *ChangePeerV2Response) Unmarshal(dAtA []byte) error + func (m *ChangePeerV2Response) XXX_DiscardUnknown() + func (m *ChangePeerV2Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangePeerV2Response) XXX_Merge(src proto.Message) + func (m *ChangePeerV2Response) XXX_Size() int + func (m *ChangePeerV2Response) XXX_Unmarshal(b []byte) error + type CmdType int32 + const CmdType_Delete + const CmdType_DeleteRange + const CmdType_Get + const CmdType_IngestSST + const CmdType_Invalid + const CmdType_Prewrite + const CmdType_Put + const CmdType_ReadIndex + const CmdType_Snap + func (CmdType) EnumDescriptor() ([]byte, []int) + func (x CmdType) String() string + type CommitMergeRequest struct + Commit uint64 + Entries []*eraftpb.Entry + Source *metapb.Region + SourceState *raft_serverpb.RegionLocalState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommitMergeRequest) Descriptor() ([]byte, []int) + func (*CommitMergeRequest) ProtoMessage() + func (m *CommitMergeRequest) GetCommit() uint64 + func (m *CommitMergeRequest) GetEntries() []*eraftpb.Entry + func (m *CommitMergeRequest) GetSource() *metapb.Region + func (m *CommitMergeRequest) GetSourceState() *raft_serverpb.RegionLocalState + func (m *CommitMergeRequest) Marshal() (dAtA []byte, err error) + func (m *CommitMergeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CommitMergeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommitMergeRequest) Reset() + func (m *CommitMergeRequest) Size() (n int) + func (m *CommitMergeRequest) String() string + func (m *CommitMergeRequest) Unmarshal(dAtA []byte) error + func (m *CommitMergeRequest) XXX_DiscardUnknown() + func (m *CommitMergeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommitMergeRequest) XXX_Merge(src proto.Message) + func (m *CommitMergeRequest) XXX_Size() int + func (m *CommitMergeRequest) XXX_Unmarshal(b []byte) error + type CommitMergeResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommitMergeResponse) Descriptor() ([]byte, []int) + func (*CommitMergeResponse) ProtoMessage() + func (m *CommitMergeResponse) Marshal() (dAtA []byte, err error) + func (m *CommitMergeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommitMergeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommitMergeResponse) Reset() + func (m *CommitMergeResponse) Size() (n int) + func (m *CommitMergeResponse) String() string + func (m *CommitMergeResponse) Unmarshal(dAtA []byte) error + func (m *CommitMergeResponse) XXX_DiscardUnknown() + func (m *CommitMergeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommitMergeResponse) XXX_Merge(src proto.Message) + func (m *CommitMergeResponse) XXX_Size() int + func (m *CommitMergeResponse) XXX_Unmarshal(b []byte) error + type CompactLogRequest struct + CompactIndex uint64 + CompactTerm uint64 + VoterReplicatedIndex uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CompactLogRequest) Descriptor() ([]byte, []int) + func (*CompactLogRequest) ProtoMessage() + func (m *CompactLogRequest) GetCompactIndex() uint64 + func (m *CompactLogRequest) GetCompactTerm() uint64 + func (m *CompactLogRequest) GetVoterReplicatedIndex() uint64 + func (m *CompactLogRequest) Marshal() (dAtA []byte, err error) + func (m *CompactLogRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CompactLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CompactLogRequest) Reset() + func (m *CompactLogRequest) Size() (n int) + func (m *CompactLogRequest) String() string + func (m *CompactLogRequest) Unmarshal(dAtA []byte) error + func (m *CompactLogRequest) XXX_DiscardUnknown() + func (m *CompactLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CompactLogRequest) XXX_Merge(src proto.Message) + func (m *CompactLogRequest) XXX_Size() int + func (m *CompactLogRequest) XXX_Unmarshal(b []byte) error + type CompactLogResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CompactLogResponse) Descriptor() ([]byte, []int) + func (*CompactLogResponse) ProtoMessage() + func (m *CompactLogResponse) Marshal() (dAtA []byte, err error) + func (m *CompactLogResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CompactLogResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CompactLogResponse) Reset() + func (m *CompactLogResponse) Size() (n int) + func (m *CompactLogResponse) String() string + func (m *CompactLogResponse) Unmarshal(dAtA []byte) error + func (m *CompactLogResponse) XXX_DiscardUnknown() + func (m *CompactLogResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CompactLogResponse) XXX_Merge(src proto.Message) + func (m *CompactLogResponse) XXX_Size() int + func (m *CompactLogResponse) XXX_Unmarshal(b []byte) error + type ComputeHashRequest struct + Context []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ComputeHashRequest) Descriptor() ([]byte, []int) + func (*ComputeHashRequest) ProtoMessage() + func (m *ComputeHashRequest) GetContext() []byte + func (m *ComputeHashRequest) Marshal() (dAtA []byte, err error) + func (m *ComputeHashRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ComputeHashRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ComputeHashRequest) Reset() + func (m *ComputeHashRequest) Size() (n int) + func (m *ComputeHashRequest) String() string + func (m *ComputeHashRequest) Unmarshal(dAtA []byte) error + func (m *ComputeHashRequest) XXX_DiscardUnknown() + func (m *ComputeHashRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ComputeHashRequest) XXX_Merge(src proto.Message) + func (m *ComputeHashRequest) XXX_Size() int + func (m *ComputeHashRequest) XXX_Unmarshal(b []byte) error + type DeleteRangeRequest struct + Cf string + EndKey []byte + NotifyOnly bool + StartKey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteRangeRequest) Descriptor() ([]byte, []int) + func (*DeleteRangeRequest) ProtoMessage() + func (m *DeleteRangeRequest) GetCf() string + func (m *DeleteRangeRequest) GetEndKey() []byte + func (m *DeleteRangeRequest) GetNotifyOnly() bool + func (m *DeleteRangeRequest) GetStartKey() []byte + func (m *DeleteRangeRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteRangeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteRangeRequest) Reset() + func (m *DeleteRangeRequest) Size() (n int) + func (m *DeleteRangeRequest) String() string + func (m *DeleteRangeRequest) Unmarshal(dAtA []byte) error + func (m *DeleteRangeRequest) XXX_DiscardUnknown() + func (m *DeleteRangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteRangeRequest) XXX_Merge(src proto.Message) + func (m *DeleteRangeRequest) XXX_Size() int + func (m *DeleteRangeRequest) XXX_Unmarshal(b []byte) error + type DeleteRangeResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteRangeResponse) Descriptor() ([]byte, []int) + func (*DeleteRangeResponse) ProtoMessage() + func (m *DeleteRangeResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteRangeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRangeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteRangeResponse) Reset() + func (m *DeleteRangeResponse) Size() (n int) + func (m *DeleteRangeResponse) String() string + func (m *DeleteRangeResponse) Unmarshal(dAtA []byte) error + func (m *DeleteRangeResponse) XXX_DiscardUnknown() + func (m *DeleteRangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteRangeResponse) XXX_Merge(src proto.Message) + func (m *DeleteRangeResponse) XXX_Size() int + func (m *DeleteRangeResponse) XXX_Unmarshal(b []byte) error + type DeleteRequest struct + Cf string + Key []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (m *DeleteRequest) GetCf() string + func (m *DeleteRequest) GetKey() []byte + func (m *DeleteRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteRequest) Reset() + func (m *DeleteRequest) Size() (n int) + func (m *DeleteRequest) String() string + func (m *DeleteRequest) Unmarshal(dAtA []byte) error + func (m *DeleteRequest) XXX_DiscardUnknown() + func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteRequest) XXX_Merge(src proto.Message) + func (m *DeleteRequest) XXX_Size() int + func (m *DeleteRequest) XXX_Unmarshal(b []byte) error + type DeleteResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (m *DeleteResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteResponse) Reset() + func (m *DeleteResponse) Size() (n int) + func (m *DeleteResponse) String() string + func (m *DeleteResponse) Unmarshal(dAtA []byte) error + func (m *DeleteResponse) XXX_DiscardUnknown() + func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteResponse) XXX_Merge(src proto.Message) + func (m *DeleteResponse) XXX_Size() int + func (m *DeleteResponse) XXX_Unmarshal(b []byte) error + type FinishFlashbackRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FinishFlashbackRequest) Descriptor() ([]byte, []int) + func (*FinishFlashbackRequest) ProtoMessage() + func (m *FinishFlashbackRequest) Marshal() (dAtA []byte, err error) + func (m *FinishFlashbackRequest) MarshalTo(dAtA []byte) (int, error) + func (m *FinishFlashbackRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FinishFlashbackRequest) Reset() + func (m *FinishFlashbackRequest) Size() (n int) + func (m *FinishFlashbackRequest) String() string + func (m *FinishFlashbackRequest) Unmarshal(dAtA []byte) error + func (m *FinishFlashbackRequest) XXX_DiscardUnknown() + func (m *FinishFlashbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FinishFlashbackRequest) XXX_Merge(src proto.Message) + func (m *FinishFlashbackRequest) XXX_Size() int + func (m *FinishFlashbackRequest) XXX_Unmarshal(b []byte) error + type FinishFlashbackResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FinishFlashbackResponse) Descriptor() ([]byte, []int) + func (*FinishFlashbackResponse) ProtoMessage() + func (m *FinishFlashbackResponse) Marshal() (dAtA []byte, err error) + func (m *FinishFlashbackResponse) MarshalTo(dAtA []byte) (int, error) + func (m *FinishFlashbackResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FinishFlashbackResponse) Reset() + func (m *FinishFlashbackResponse) Size() (n int) + func (m *FinishFlashbackResponse) String() string + func (m *FinishFlashbackResponse) Unmarshal(dAtA []byte) error + func (m *FinishFlashbackResponse) XXX_DiscardUnknown() + func (m *FinishFlashbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FinishFlashbackResponse) XXX_Merge(src proto.Message) + func (m *FinishFlashbackResponse) XXX_Size() int + func (m *FinishFlashbackResponse) XXX_Unmarshal(b []byte) error + type GetRequest struct + Cf string + Key []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (m *GetRequest) GetCf() string + func (m *GetRequest) GetKey() []byte + func (m *GetRequest) Marshal() (dAtA []byte, err error) + func (m *GetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetRequest) Reset() + func (m *GetRequest) Size() (n int) + func (m *GetRequest) String() string + func (m *GetRequest) Unmarshal(dAtA []byte) error + func (m *GetRequest) XXX_DiscardUnknown() + func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetRequest) XXX_Merge(src proto.Message) + func (m *GetRequest) XXX_Size() int + func (m *GetRequest) XXX_Unmarshal(b []byte) error + type GetResponse struct + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (m *GetResponse) GetValue() []byte + func (m *GetResponse) Marshal() (dAtA []byte, err error) + func (m *GetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetResponse) Reset() + func (m *GetResponse) Size() (n int) + func (m *GetResponse) String() string + func (m *GetResponse) Unmarshal(dAtA []byte) error + func (m *GetResponse) XXX_DiscardUnknown() + func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetResponse) XXX_Merge(src proto.Message) + func (m *GetResponse) XXX_Size() int + func (m *GetResponse) XXX_Unmarshal(b []byte) error + type IngestSSTRequest struct + Sst *import_sstpb.SSTMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IngestSSTRequest) Descriptor() ([]byte, []int) + func (*IngestSSTRequest) ProtoMessage() + func (m *IngestSSTRequest) GetSst() *import_sstpb.SSTMeta + func (m *IngestSSTRequest) Marshal() (dAtA []byte, err error) + func (m *IngestSSTRequest) MarshalTo(dAtA []byte) (int, error) + func (m *IngestSSTRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IngestSSTRequest) Reset() + func (m *IngestSSTRequest) Size() (n int) + func (m *IngestSSTRequest) String() string + func (m *IngestSSTRequest) Unmarshal(dAtA []byte) error + func (m *IngestSSTRequest) XXX_DiscardUnknown() + func (m *IngestSSTRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IngestSSTRequest) XXX_Merge(src proto.Message) + func (m *IngestSSTRequest) XXX_Size() int + func (m *IngestSSTRequest) XXX_Unmarshal(b []byte) error + type IngestSSTResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IngestSSTResponse) Descriptor() ([]byte, []int) + func (*IngestSSTResponse) ProtoMessage() + func (m *IngestSSTResponse) Marshal() (dAtA []byte, err error) + func (m *IngestSSTResponse) MarshalTo(dAtA []byte) (int, error) + func (m *IngestSSTResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IngestSSTResponse) Reset() + func (m *IngestSSTResponse) Size() (n int) + func (m *IngestSSTResponse) String() string + func (m *IngestSSTResponse) Unmarshal(dAtA []byte) error + func (m *IngestSSTResponse) XXX_DiscardUnknown() + func (m *IngestSSTResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IngestSSTResponse) XXX_Merge(src proto.Message) + func (m *IngestSSTResponse) XXX_Size() int + func (m *IngestSSTResponse) XXX_Unmarshal(b []byte) error + type PrepareFlashbackRequest struct + StartTs uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PrepareFlashbackRequest) Descriptor() ([]byte, []int) + func (*PrepareFlashbackRequest) ProtoMessage() + func (m *PrepareFlashbackRequest) GetStartTs() uint64 + func (m *PrepareFlashbackRequest) Marshal() (dAtA []byte, err error) + func (m *PrepareFlashbackRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PrepareFlashbackRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PrepareFlashbackRequest) Reset() + func (m *PrepareFlashbackRequest) Size() (n int) + func (m *PrepareFlashbackRequest) String() string + func (m *PrepareFlashbackRequest) Unmarshal(dAtA []byte) error + func (m *PrepareFlashbackRequest) XXX_DiscardUnknown() + func (m *PrepareFlashbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrepareFlashbackRequest) XXX_Merge(src proto.Message) + func (m *PrepareFlashbackRequest) XXX_Size() int + func (m *PrepareFlashbackRequest) XXX_Unmarshal(b []byte) error + type PrepareFlashbackResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PrepareFlashbackResponse) Descriptor() ([]byte, []int) + func (*PrepareFlashbackResponse) ProtoMessage() + func (m *PrepareFlashbackResponse) Marshal() (dAtA []byte, err error) + func (m *PrepareFlashbackResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PrepareFlashbackResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PrepareFlashbackResponse) Reset() + func (m *PrepareFlashbackResponse) Size() (n int) + func (m *PrepareFlashbackResponse) String() string + func (m *PrepareFlashbackResponse) Unmarshal(dAtA []byte) error + func (m *PrepareFlashbackResponse) XXX_DiscardUnknown() + func (m *PrepareFlashbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrepareFlashbackResponse) XXX_Merge(src proto.Message) + func (m *PrepareFlashbackResponse) XXX_Size() int + func (m *PrepareFlashbackResponse) XXX_Unmarshal(b []byte) error + type PrepareMergeRequest struct + MinIndex uint64 + Target *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PrepareMergeRequest) Descriptor() ([]byte, []int) + func (*PrepareMergeRequest) ProtoMessage() + func (m *PrepareMergeRequest) GetMinIndex() uint64 + func (m *PrepareMergeRequest) GetTarget() *metapb.Region + func (m *PrepareMergeRequest) Marshal() (dAtA []byte, err error) + func (m *PrepareMergeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PrepareMergeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PrepareMergeRequest) Reset() + func (m *PrepareMergeRequest) Size() (n int) + func (m *PrepareMergeRequest) String() string + func (m *PrepareMergeRequest) Unmarshal(dAtA []byte) error + func (m *PrepareMergeRequest) XXX_DiscardUnknown() + func (m *PrepareMergeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrepareMergeRequest) XXX_Merge(src proto.Message) + func (m *PrepareMergeRequest) XXX_Size() int + func (m *PrepareMergeRequest) XXX_Unmarshal(b []byte) error + type PrepareMergeResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PrepareMergeResponse) Descriptor() ([]byte, []int) + func (*PrepareMergeResponse) ProtoMessage() + func (m *PrepareMergeResponse) Marshal() (dAtA []byte, err error) + func (m *PrepareMergeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PrepareMergeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PrepareMergeResponse) Reset() + func (m *PrepareMergeResponse) Size() (n int) + func (m *PrepareMergeResponse) String() string + func (m *PrepareMergeResponse) Unmarshal(dAtA []byte) error + func (m *PrepareMergeResponse) XXX_DiscardUnknown() + func (m *PrepareMergeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrepareMergeResponse) XXX_Merge(src proto.Message) + func (m *PrepareMergeResponse) XXX_Size() int + func (m *PrepareMergeResponse) XXX_Unmarshal(b []byte) error + type PrewriteRequest struct + Key []byte + Lock []byte + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PrewriteRequest) Descriptor() ([]byte, []int) + func (*PrewriteRequest) ProtoMessage() + func (m *PrewriteRequest) GetKey() []byte + func (m *PrewriteRequest) GetLock() []byte + func (m *PrewriteRequest) GetValue() []byte + func (m *PrewriteRequest) Marshal() (dAtA []byte, err error) + func (m *PrewriteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PrewriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PrewriteRequest) Reset() + func (m *PrewriteRequest) Size() (n int) + func (m *PrewriteRequest) String() string + func (m *PrewriteRequest) Unmarshal(dAtA []byte) error + func (m *PrewriteRequest) XXX_DiscardUnknown() + func (m *PrewriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrewriteRequest) XXX_Merge(src proto.Message) + func (m *PrewriteRequest) XXX_Size() int + func (m *PrewriteRequest) XXX_Unmarshal(b []byte) error + type PrewriteResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PrewriteResponse) Descriptor() ([]byte, []int) + func (*PrewriteResponse) ProtoMessage() + func (m *PrewriteResponse) Marshal() (dAtA []byte, err error) + func (m *PrewriteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PrewriteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PrewriteResponse) Reset() + func (m *PrewriteResponse) Size() (n int) + func (m *PrewriteResponse) String() string + func (m *PrewriteResponse) Unmarshal(dAtA []byte) error + func (m *PrewriteResponse) XXX_DiscardUnknown() + func (m *PrewriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrewriteResponse) XXX_Merge(src proto.Message) + func (m *PrewriteResponse) XXX_Size() int + func (m *PrewriteResponse) XXX_Unmarshal(b []byte) error + type PutRequest struct + Cf string + Key []byte + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) ProtoMessage() + func (m *PutRequest) GetCf() string + func (m *PutRequest) GetKey() []byte + func (m *PutRequest) GetValue() []byte + func (m *PutRequest) Marshal() (dAtA []byte, err error) + func (m *PutRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PutRequest) Reset() + func (m *PutRequest) Size() (n int) + func (m *PutRequest) String() string + func (m *PutRequest) Unmarshal(dAtA []byte) error + func (m *PutRequest) XXX_DiscardUnknown() + func (m *PutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PutRequest) XXX_Merge(src proto.Message) + func (m *PutRequest) XXX_Size() int + func (m *PutRequest) XXX_Unmarshal(b []byte) error + type PutResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (m *PutResponse) Marshal() (dAtA []byte, err error) + func (m *PutResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PutResponse) Reset() + func (m *PutResponse) Size() (n int) + func (m *PutResponse) String() string + func (m *PutResponse) Unmarshal(dAtA []byte) error + func (m *PutResponse) XXX_DiscardUnknown() + func (m *PutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PutResponse) XXX_Merge(src proto.Message) + func (m *PutResponse) XXX_Size() int + func (m *PutResponse) XXX_Unmarshal(b []byte) error + type RaftCmdRequest struct + AdminRequest *AdminRequest + Header *RaftRequestHeader + Requests []*Request + StatusRequest *StatusRequest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RaftCmdRequest) Descriptor() ([]byte, []int) + func (*RaftCmdRequest) ProtoMessage() + func (m *RaftCmdRequest) GetAdminRequest() *AdminRequest + func (m *RaftCmdRequest) GetHeader() *RaftRequestHeader + func (m *RaftCmdRequest) GetRequests() []*Request + func (m *RaftCmdRequest) GetStatusRequest() *StatusRequest + func (m *RaftCmdRequest) Marshal() (dAtA []byte, err error) + func (m *RaftCmdRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RaftCmdRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RaftCmdRequest) Reset() + func (m *RaftCmdRequest) Size() (n int) + func (m *RaftCmdRequest) String() string + func (m *RaftCmdRequest) Unmarshal(dAtA []byte) error + func (m *RaftCmdRequest) XXX_DiscardUnknown() + func (m *RaftCmdRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RaftCmdRequest) XXX_Merge(src proto.Message) + func (m *RaftCmdRequest) XXX_Size() int + func (m *RaftCmdRequest) XXX_Unmarshal(b []byte) error + type RaftCmdResponse struct + AdminResponse *AdminResponse + Header *RaftResponseHeader + Responses []*Response + StatusResponse *StatusResponse + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RaftCmdResponse) Descriptor() ([]byte, []int) + func (*RaftCmdResponse) ProtoMessage() + func (m *RaftCmdResponse) GetAdminResponse() *AdminResponse + func (m *RaftCmdResponse) GetHeader() *RaftResponseHeader + func (m *RaftCmdResponse) GetResponses() []*Response + func (m *RaftCmdResponse) GetStatusResponse() *StatusResponse + func (m *RaftCmdResponse) Marshal() (dAtA []byte, err error) + func (m *RaftCmdResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RaftCmdResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RaftCmdResponse) Reset() + func (m *RaftCmdResponse) Size() (n int) + func (m *RaftCmdResponse) String() string + func (m *RaftCmdResponse) Unmarshal(dAtA []byte) error + func (m *RaftCmdResponse) XXX_DiscardUnknown() + func (m *RaftCmdResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RaftCmdResponse) XXX_Merge(src proto.Message) + func (m *RaftCmdResponse) XXX_Size() int + func (m *RaftCmdResponse) XXX_Unmarshal(b []byte) error + type RaftRequestHeader struct + AppliedIndex uint64 + FlagData []byte + Flags uint64 + Peer *metapb.Peer + Priority kvrpcpb.CommandPri + ReadQuorum bool + RegionEpoch *metapb.RegionEpoch + RegionId uint64 + ReplicaRead bool + ResourceGroupName string + SyncLog bool + Term uint64 + Uuid []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RaftRequestHeader) Descriptor() ([]byte, []int) + func (*RaftRequestHeader) ProtoMessage() + func (m *RaftRequestHeader) GetAppliedIndex() uint64 + func (m *RaftRequestHeader) GetFlagData() []byte + func (m *RaftRequestHeader) GetFlags() uint64 + func (m *RaftRequestHeader) GetPeer() *metapb.Peer + func (m *RaftRequestHeader) GetPriority() kvrpcpb.CommandPri + func (m *RaftRequestHeader) GetReadQuorum() bool + func (m *RaftRequestHeader) GetRegionEpoch() *metapb.RegionEpoch + func (m *RaftRequestHeader) GetRegionId() uint64 + func (m *RaftRequestHeader) GetReplicaRead() bool + func (m *RaftRequestHeader) GetResourceGroupName() string + func (m *RaftRequestHeader) GetSyncLog() bool + func (m *RaftRequestHeader) GetTerm() uint64 + func (m *RaftRequestHeader) GetUuid() []byte + func (m *RaftRequestHeader) Marshal() (dAtA []byte, err error) + func (m *RaftRequestHeader) MarshalTo(dAtA []byte) (int, error) + func (m *RaftRequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RaftRequestHeader) Reset() + func (m *RaftRequestHeader) Size() (n int) + func (m *RaftRequestHeader) String() string + func (m *RaftRequestHeader) Unmarshal(dAtA []byte) error + func (m *RaftRequestHeader) XXX_DiscardUnknown() + func (m *RaftRequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RaftRequestHeader) XXX_Merge(src proto.Message) + func (m *RaftRequestHeader) XXX_Size() int + func (m *RaftRequestHeader) XXX_Unmarshal(b []byte) error + type RaftResponseHeader struct + CurrentTerm uint64 + Error *errorpb.Error + Uuid []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RaftResponseHeader) Descriptor() ([]byte, []int) + func (*RaftResponseHeader) ProtoMessage() + func (m *RaftResponseHeader) GetCurrentTerm() uint64 + func (m *RaftResponseHeader) GetError() *errorpb.Error + func (m *RaftResponseHeader) GetUuid() []byte + func (m *RaftResponseHeader) Marshal() (dAtA []byte, err error) + func (m *RaftResponseHeader) MarshalTo(dAtA []byte) (int, error) + func (m *RaftResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RaftResponseHeader) Reset() + func (m *RaftResponseHeader) Size() (n int) + func (m *RaftResponseHeader) String() string + func (m *RaftResponseHeader) Unmarshal(dAtA []byte) error + func (m *RaftResponseHeader) XXX_DiscardUnknown() + func (m *RaftResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RaftResponseHeader) XXX_Merge(src proto.Message) + func (m *RaftResponseHeader) XXX_Size() int + func (m *RaftResponseHeader) XXX_Unmarshal(b []byte) error + type ReadIndexRequest struct + KeyRanges []*kvrpcpb.KeyRange + StartTs uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadIndexRequest) Descriptor() ([]byte, []int) + func (*ReadIndexRequest) ProtoMessage() + func (m *ReadIndexRequest) GetKeyRanges() []*kvrpcpb.KeyRange + func (m *ReadIndexRequest) GetStartTs() uint64 + func (m *ReadIndexRequest) Marshal() (dAtA []byte, err error) + func (m *ReadIndexRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ReadIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ReadIndexRequest) Reset() + func (m *ReadIndexRequest) Size() (n int) + func (m *ReadIndexRequest) String() string + func (m *ReadIndexRequest) Unmarshal(dAtA []byte) error + func (m *ReadIndexRequest) XXX_DiscardUnknown() + func (m *ReadIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadIndexRequest) XXX_Merge(src proto.Message) + func (m *ReadIndexRequest) XXX_Size() int + func (m *ReadIndexRequest) XXX_Unmarshal(b []byte) error + type ReadIndexResponse struct + Locked *kvrpcpb.LockInfo + ReadIndex uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadIndexResponse) Descriptor() ([]byte, []int) + func (*ReadIndexResponse) ProtoMessage() + func (m *ReadIndexResponse) GetLocked() *kvrpcpb.LockInfo + func (m *ReadIndexResponse) GetReadIndex() uint64 + func (m *ReadIndexResponse) Marshal() (dAtA []byte, err error) + func (m *ReadIndexResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ReadIndexResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ReadIndexResponse) Reset() + func (m *ReadIndexResponse) Size() (n int) + func (m *ReadIndexResponse) String() string + func (m *ReadIndexResponse) Unmarshal(dAtA []byte) error + func (m *ReadIndexResponse) XXX_DiscardUnknown() + func (m *ReadIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadIndexResponse) XXX_Merge(src proto.Message) + func (m *ReadIndexResponse) XXX_Size() int + func (m *ReadIndexResponse) XXX_Unmarshal(b []byte) error + type RegionDetailRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionDetailRequest) Descriptor() ([]byte, []int) + func (*RegionDetailRequest) ProtoMessage() + func (m *RegionDetailRequest) Marshal() (dAtA []byte, err error) + func (m *RegionDetailRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RegionDetailRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RegionDetailRequest) Reset() + func (m *RegionDetailRequest) Size() (n int) + func (m *RegionDetailRequest) String() string + func (m *RegionDetailRequest) Unmarshal(dAtA []byte) error + func (m *RegionDetailRequest) XXX_DiscardUnknown() + func (m *RegionDetailRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegionDetailRequest) XXX_Merge(src proto.Message) + func (m *RegionDetailRequest) XXX_Size() int + func (m *RegionDetailRequest) XXX_Unmarshal(b []byte) error + type RegionDetailResponse struct + Leader *metapb.Peer + Region *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionDetailResponse) Descriptor() ([]byte, []int) + func (*RegionDetailResponse) ProtoMessage() + func (m *RegionDetailResponse) GetLeader() *metapb.Peer + func (m *RegionDetailResponse) GetRegion() *metapb.Region + func (m *RegionDetailResponse) Marshal() (dAtA []byte, err error) + func (m *RegionDetailResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RegionDetailResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RegionDetailResponse) Reset() + func (m *RegionDetailResponse) Size() (n int) + func (m *RegionDetailResponse) String() string + func (m *RegionDetailResponse) Unmarshal(dAtA []byte) error + func (m *RegionDetailResponse) XXX_DiscardUnknown() + func (m *RegionDetailResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegionDetailResponse) XXX_Merge(src proto.Message) + func (m *RegionDetailResponse) XXX_Size() int + func (m *RegionDetailResponse) XXX_Unmarshal(b []byte) error + type RegionLeaderRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionLeaderRequest) Descriptor() ([]byte, []int) + func (*RegionLeaderRequest) ProtoMessage() + func (m *RegionLeaderRequest) Marshal() (dAtA []byte, err error) + func (m *RegionLeaderRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RegionLeaderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RegionLeaderRequest) Reset() + func (m *RegionLeaderRequest) Size() (n int) + func (m *RegionLeaderRequest) String() string + func (m *RegionLeaderRequest) Unmarshal(dAtA []byte) error + func (m *RegionLeaderRequest) XXX_DiscardUnknown() + func (m *RegionLeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegionLeaderRequest) XXX_Merge(src proto.Message) + func (m *RegionLeaderRequest) XXX_Size() int + func (m *RegionLeaderRequest) XXX_Unmarshal(b []byte) error + type RegionLeaderResponse struct + Leader *metapb.Peer + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionLeaderResponse) Descriptor() ([]byte, []int) + func (*RegionLeaderResponse) ProtoMessage() + func (m *RegionLeaderResponse) GetLeader() *metapb.Peer + func (m *RegionLeaderResponse) Marshal() (dAtA []byte, err error) + func (m *RegionLeaderResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RegionLeaderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RegionLeaderResponse) Reset() + func (m *RegionLeaderResponse) Size() (n int) + func (m *RegionLeaderResponse) String() string + func (m *RegionLeaderResponse) Unmarshal(dAtA []byte) error + func (m *RegionLeaderResponse) XXX_DiscardUnknown() + func (m *RegionLeaderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegionLeaderResponse) XXX_Merge(src proto.Message) + func (m *RegionLeaderResponse) XXX_Size() int + func (m *RegionLeaderResponse) XXX_Unmarshal(b []byte) error + type Request struct + CmdType CmdType + Delete *DeleteRequest + DeleteRange *DeleteRangeRequest + Get *GetRequest + IngestSst *IngestSSTRequest + Prewrite *PrewriteRequest + Put *PutRequest + ReadIndex *ReadIndexRequest + Snap *SnapRequest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) GetCmdType() CmdType + func (m *Request) GetDelete() *DeleteRequest + func (m *Request) GetDeleteRange() *DeleteRangeRequest + func (m *Request) GetGet() *GetRequest + func (m *Request) GetIngestSst() *IngestSSTRequest + func (m *Request) GetPrewrite() *PrewriteRequest + func (m *Request) GetPut() *PutRequest + func (m *Request) GetReadIndex() *ReadIndexRequest + func (m *Request) GetSnap() *SnapRequest + func (m *Request) Marshal() (dAtA []byte, err error) + func (m *Request) MarshalTo(dAtA []byte) (int, error) + func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Request) Reset() + func (m *Request) Size() (n int) + func (m *Request) String() string + func (m *Request) Unmarshal(dAtA []byte) error + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Merge(src proto.Message) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + type Response struct + CmdType CmdType + Delete *DeleteResponse + DelteRange *DeleteRangeResponse + Get *GetResponse + IngestSst *IngestSSTResponse + Prewrite *PrewriteResponse + Put *PutResponse + ReadIndex *ReadIndexResponse + Snap *SnapResponse + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) GetCmdType() CmdType + func (m *Response) GetDelete() *DeleteResponse + func (m *Response) GetDelteRange() *DeleteRangeResponse + func (m *Response) GetGet() *GetResponse + func (m *Response) GetIngestSst() *IngestSSTResponse + func (m *Response) GetPrewrite() *PrewriteResponse + func (m *Response) GetPut() *PutResponse + func (m *Response) GetReadIndex() *ReadIndexResponse + func (m *Response) GetSnap() *SnapResponse + func (m *Response) Marshal() (dAtA []byte, err error) + func (m *Response) MarshalTo(dAtA []byte) (int, error) + func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Response) Reset() + func (m *Response) Size() (n int) + func (m *Response) String() string + func (m *Response) Unmarshal(dAtA []byte) error + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type RollbackMergeRequest struct + Commit uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RollbackMergeRequest) Descriptor() ([]byte, []int) + func (*RollbackMergeRequest) ProtoMessage() + func (m *RollbackMergeRequest) GetCommit() uint64 + func (m *RollbackMergeRequest) Marshal() (dAtA []byte, err error) + func (m *RollbackMergeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RollbackMergeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RollbackMergeRequest) Reset() + func (m *RollbackMergeRequest) Size() (n int) + func (m *RollbackMergeRequest) String() string + func (m *RollbackMergeRequest) Unmarshal(dAtA []byte) error + func (m *RollbackMergeRequest) XXX_DiscardUnknown() + func (m *RollbackMergeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RollbackMergeRequest) XXX_Merge(src proto.Message) + func (m *RollbackMergeRequest) XXX_Size() int + func (m *RollbackMergeRequest) XXX_Unmarshal(b []byte) error + type RollbackMergeResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RollbackMergeResponse) Descriptor() ([]byte, []int) + func (*RollbackMergeResponse) ProtoMessage() + func (m *RollbackMergeResponse) Marshal() (dAtA []byte, err error) + func (m *RollbackMergeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RollbackMergeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RollbackMergeResponse) Reset() + func (m *RollbackMergeResponse) Size() (n int) + func (m *RollbackMergeResponse) String() string + func (m *RollbackMergeResponse) Unmarshal(dAtA []byte) error + func (m *RollbackMergeResponse) XXX_DiscardUnknown() + func (m *RollbackMergeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RollbackMergeResponse) XXX_Merge(src proto.Message) + func (m *RollbackMergeResponse) XXX_Size() int + func (m *RollbackMergeResponse) XXX_Unmarshal(b []byte) error + type SnapRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapRequest) Descriptor() ([]byte, []int) + func (*SnapRequest) ProtoMessage() + func (m *SnapRequest) Marshal() (dAtA []byte, err error) + func (m *SnapRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SnapRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapRequest) Reset() + func (m *SnapRequest) Size() (n int) + func (m *SnapRequest) String() string + func (m *SnapRequest) Unmarshal(dAtA []byte) error + func (m *SnapRequest) XXX_DiscardUnknown() + func (m *SnapRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapRequest) XXX_Merge(src proto.Message) + func (m *SnapRequest) XXX_Size() int + func (m *SnapRequest) XXX_Unmarshal(b []byte) error + type SnapResponse struct + Region *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapResponse) Descriptor() ([]byte, []int) + func (*SnapResponse) ProtoMessage() + func (m *SnapResponse) GetRegion() *metapb.Region + func (m *SnapResponse) Marshal() (dAtA []byte, err error) + func (m *SnapResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SnapResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapResponse) Reset() + func (m *SnapResponse) Size() (n int) + func (m *SnapResponse) String() string + func (m *SnapResponse) Unmarshal(dAtA []byte) error + func (m *SnapResponse) XXX_DiscardUnknown() + func (m *SnapResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapResponse) XXX_Merge(src proto.Message) + func (m *SnapResponse) XXX_Size() int + func (m *SnapResponse) XXX_Unmarshal(b []byte) error + type SplitRequest struct + NewPeerIds []uint64 + NewRegionId uint64 + RightDerive bool + SplitKey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SplitRequest) Descriptor() ([]byte, []int) + func (*SplitRequest) ProtoMessage() + func (m *SplitRequest) GetNewPeerIds() []uint64 + func (m *SplitRequest) GetNewRegionId() uint64 + func (m *SplitRequest) GetRightDerive() bool + func (m *SplitRequest) GetSplitKey() []byte + func (m *SplitRequest) Marshal() (dAtA []byte, err error) + func (m *SplitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SplitRequest) Reset() + func (m *SplitRequest) Size() (n int) + func (m *SplitRequest) String() string + func (m *SplitRequest) Unmarshal(dAtA []byte) error + func (m *SplitRequest) XXX_DiscardUnknown() + func (m *SplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SplitRequest) XXX_Merge(src proto.Message) + func (m *SplitRequest) XXX_Size() int + func (m *SplitRequest) XXX_Unmarshal(b []byte) error + type SplitResponse struct + Left *metapb.Region + Right *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SplitResponse) Descriptor() ([]byte, []int) + func (*SplitResponse) ProtoMessage() + func (m *SplitResponse) GetLeft() *metapb.Region + func (m *SplitResponse) GetRight() *metapb.Region + func (m *SplitResponse) Marshal() (dAtA []byte, err error) + func (m *SplitResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SplitResponse) Reset() + func (m *SplitResponse) Size() (n int) + func (m *SplitResponse) String() string + func (m *SplitResponse) Unmarshal(dAtA []byte) error + func (m *SplitResponse) XXX_DiscardUnknown() + func (m *SplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SplitResponse) XXX_Merge(src proto.Message) + func (m *SplitResponse) XXX_Size() int + func (m *SplitResponse) XXX_Unmarshal(b []byte) error + type StatusCmdType int32 + const StatusCmdType_InvalidStatus + const StatusCmdType_RegionDetail + const StatusCmdType_RegionLeader + func (StatusCmdType) EnumDescriptor() ([]byte, []int) + func (x StatusCmdType) String() string + type StatusRequest struct + CmdType StatusCmdType + RegionDetail *RegionDetailRequest + RegionLeader *RegionLeaderRequest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatusRequest) Descriptor() ([]byte, []int) + func (*StatusRequest) ProtoMessage() + func (m *StatusRequest) GetCmdType() StatusCmdType + func (m *StatusRequest) GetRegionDetail() *RegionDetailRequest + func (m *StatusRequest) GetRegionLeader() *RegionLeaderRequest + func (m *StatusRequest) Marshal() (dAtA []byte, err error) + func (m *StatusRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StatusRequest) Reset() + func (m *StatusRequest) Size() (n int) + func (m *StatusRequest) String() string + func (m *StatusRequest) Unmarshal(dAtA []byte) error + func (m *StatusRequest) XXX_DiscardUnknown() + func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatusRequest) XXX_Merge(src proto.Message) + func (m *StatusRequest) XXX_Size() int + func (m *StatusRequest) XXX_Unmarshal(b []byte) error + type StatusResponse struct + CmdType StatusCmdType + RegionDetail *RegionDetailResponse + RegionLeader *RegionLeaderResponse + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatusResponse) Descriptor() ([]byte, []int) + func (*StatusResponse) ProtoMessage() + func (m *StatusResponse) GetCmdType() StatusCmdType + func (m *StatusResponse) GetRegionDetail() *RegionDetailResponse + func (m *StatusResponse) GetRegionLeader() *RegionLeaderResponse + func (m *StatusResponse) Marshal() (dAtA []byte, err error) + func (m *StatusResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StatusResponse) Reset() + func (m *StatusResponse) Size() (n int) + func (m *StatusResponse) String() string + func (m *StatusResponse) Unmarshal(dAtA []byte) error + func (m *StatusResponse) XXX_DiscardUnknown() + func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatusResponse) XXX_Merge(src proto.Message) + func (m *StatusResponse) XXX_Size() int + func (m *StatusResponse) XXX_Unmarshal(b []byte) error + type SwitchWitnessRequest struct + IsWitness bool + PeerId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SwitchWitnessRequest) Descriptor() ([]byte, []int) + func (*SwitchWitnessRequest) ProtoMessage() + func (m *SwitchWitnessRequest) GetIsWitness() bool + func (m *SwitchWitnessRequest) GetPeerId() uint64 + func (m *SwitchWitnessRequest) Marshal() (dAtA []byte, err error) + func (m *SwitchWitnessRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SwitchWitnessRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SwitchWitnessRequest) Reset() + func (m *SwitchWitnessRequest) Size() (n int) + func (m *SwitchWitnessRequest) String() string + func (m *SwitchWitnessRequest) Unmarshal(dAtA []byte) error + func (m *SwitchWitnessRequest) XXX_DiscardUnknown() + func (m *SwitchWitnessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SwitchWitnessRequest) XXX_Merge(src proto.Message) + func (m *SwitchWitnessRequest) XXX_Size() int + func (m *SwitchWitnessRequest) XXX_Unmarshal(b []byte) error + type TransferLeaderRequest struct + Peer *metapb.Peer + Peers []*metapb.Peer + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TransferLeaderRequest) Descriptor() ([]byte, []int) + func (*TransferLeaderRequest) ProtoMessage() + func (m *TransferLeaderRequest) GetPeer() *metapb.Peer + func (m *TransferLeaderRequest) GetPeers() []*metapb.Peer + func (m *TransferLeaderRequest) Marshal() (dAtA []byte, err error) + func (m *TransferLeaderRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TransferLeaderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TransferLeaderRequest) Reset() + func (m *TransferLeaderRequest) Size() (n int) + func (m *TransferLeaderRequest) String() string + func (m *TransferLeaderRequest) Unmarshal(dAtA []byte) error + func (m *TransferLeaderRequest) XXX_DiscardUnknown() + func (m *TransferLeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TransferLeaderRequest) XXX_Merge(src proto.Message) + func (m *TransferLeaderRequest) XXX_Size() int + func (m *TransferLeaderRequest) XXX_Unmarshal(b []byte) error + type TransferLeaderResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TransferLeaderResponse) Descriptor() ([]byte, []int) + func (*TransferLeaderResponse) ProtoMessage() + func (m *TransferLeaderResponse) Marshal() (dAtA []byte, err error) + func (m *TransferLeaderResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TransferLeaderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TransferLeaderResponse) Reset() + func (m *TransferLeaderResponse) Size() (n int) + func (m *TransferLeaderResponse) String() string + func (m *TransferLeaderResponse) Unmarshal(dAtA []byte) error + func (m *TransferLeaderResponse) XXX_DiscardUnknown() + func (m *TransferLeaderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TransferLeaderResponse) XXX_Merge(src proto.Message) + func (m *TransferLeaderResponse) XXX_Size() int + func (m *TransferLeaderResponse) XXX_Unmarshal(b []byte) error + type UpdateGcPeerRequest struct + PeerId []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateGcPeerRequest) Descriptor() ([]byte, []int) + func (*UpdateGcPeerRequest) ProtoMessage() + func (m *UpdateGcPeerRequest) GetPeerId() []uint64 + func (m *UpdateGcPeerRequest) Marshal() (dAtA []byte, err error) + func (m *UpdateGcPeerRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateGcPeerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateGcPeerRequest) Reset() + func (m *UpdateGcPeerRequest) Size() (n int) + func (m *UpdateGcPeerRequest) String() string + func (m *UpdateGcPeerRequest) Unmarshal(dAtA []byte) error + func (m *UpdateGcPeerRequest) XXX_DiscardUnknown() + func (m *UpdateGcPeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateGcPeerRequest) XXX_Merge(src proto.Message) + func (m *UpdateGcPeerRequest) XXX_Size() int + func (m *UpdateGcPeerRequest) XXX_Unmarshal(b []byte) error + type VerifyHashRequest struct + Context []byte + Hash []byte + Index uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VerifyHashRequest) Descriptor() ([]byte, []int) + func (*VerifyHashRequest) ProtoMessage() + func (m *VerifyHashRequest) GetContext() []byte + func (m *VerifyHashRequest) GetHash() []byte + func (m *VerifyHashRequest) GetIndex() uint64 + func (m *VerifyHashRequest) Marshal() (dAtA []byte, err error) + func (m *VerifyHashRequest) MarshalTo(dAtA []byte) (int, error) + func (m *VerifyHashRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VerifyHashRequest) Reset() + func (m *VerifyHashRequest) Size() (n int) + func (m *VerifyHashRequest) String() string + func (m *VerifyHashRequest) Unmarshal(dAtA []byte) error + func (m *VerifyHashRequest) XXX_DiscardUnknown() + func (m *VerifyHashRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VerifyHashRequest) XXX_Merge(src proto.Message) + func (m *VerifyHashRequest) XXX_Size() int + func (m *VerifyHashRequest) XXX_Unmarshal(b []byte) error + type VerifyHashResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VerifyHashResponse) Descriptor() ([]byte, []int) + func (*VerifyHashResponse) ProtoMessage() + func (m *VerifyHashResponse) Marshal() (dAtA []byte, err error) + func (m *VerifyHashResponse) MarshalTo(dAtA []byte) (int, error) + func (m *VerifyHashResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VerifyHashResponse) Reset() + func (m *VerifyHashResponse) Size() (n int) + func (m *VerifyHashResponse) String() string + func (m *VerifyHashResponse) Unmarshal(dAtA []byte) error + func (m *VerifyHashResponse) XXX_DiscardUnknown() + func (m *VerifyHashResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VerifyHashResponse) XXX_Merge(src proto.Message) + func (m *VerifyHashResponse) XXX_Size() int + func (m *VerifyHashResponse) XXX_Unmarshal(b []byte) error