Documentation ¶
Overview ¶
Package raft_cmdpb is a generated protocol buffer package.
It is generated from these files:
raft_cmdpb.proto
It has these top-level messages:
GetRequest GetResponse PutRequest PutResponse DeleteRequest DeleteResponse SnapRequest SnapResponse Request Response ChangePeerRequest ChangePeerResponse SplitRequest SplitResponse CompactLogRequest CompactLogResponse TransferLeaderRequest TransferLeaderResponse VerifyHashRequest VerifyHashResponse AdminRequest AdminResponse RegionLeaderRequest RegionLeaderResponse RegionDetailRequest RegionDetailResponse StatusRequest StatusResponse RaftRequestHeader RaftResponseHeader RaftCmdRequest RaftCmdResponse
Index ¶
- Variables
- type AdminCmdType
- type AdminRequest
- func (*AdminRequest) Descriptor() ([]byte, []int)
- func (m *AdminRequest) GetChangePeer() *ChangePeerRequest
- func (m *AdminRequest) GetCmdType() AdminCmdType
- func (m *AdminRequest) GetCompactLog() *CompactLogRequest
- func (m *AdminRequest) GetSplit() *SplitRequest
- func (m *AdminRequest) GetTransferLeader() *TransferLeaderRequest
- func (m *AdminRequest) GetVerifyHash() *VerifyHashRequest
- func (m *AdminRequest) Marshal() (dAtA []byte, err error)
- func (m *AdminRequest) MarshalTo(dAtA []byte) (int, error)
- func (*AdminRequest) ProtoMessage()
- func (m *AdminRequest) Reset()
- func (m *AdminRequest) Size() (n int)
- func (m *AdminRequest) String() string
- func (m *AdminRequest) Unmarshal(dAtA []byte) error
- type AdminResponse
- func (*AdminResponse) Descriptor() ([]byte, []int)
- func (m *AdminResponse) GetChangePeer() *ChangePeerResponse
- func (m *AdminResponse) GetCmdType() AdminCmdType
- func (m *AdminResponse) GetCompactLog() *CompactLogResponse
- func (m *AdminResponse) GetSplit() *SplitResponse
- 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 (*AdminResponse) ProtoMessage()
- func (m *AdminResponse) Reset()
- func (m *AdminResponse) Size() (n int)
- func (m *AdminResponse) String() string
- func (m *AdminResponse) Unmarshal(dAtA []byte) error
- type ChangePeerRequest
- func (*ChangePeerRequest) Descriptor() ([]byte, []int)
- 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 (*ChangePeerRequest) ProtoMessage()
- func (m *ChangePeerRequest) Reset()
- func (m *ChangePeerRequest) Size() (n int)
- func (m *ChangePeerRequest) String() string
- func (m *ChangePeerRequest) Unmarshal(dAtA []byte) error
- type ChangePeerResponse
- func (*ChangePeerResponse) Descriptor() ([]byte, []int)
- func (m *ChangePeerResponse) GetRegion() *metapb.Region
- func (m *ChangePeerResponse) Marshal() (dAtA []byte, err error)
- func (m *ChangePeerResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ChangePeerResponse) ProtoMessage()
- func (m *ChangePeerResponse) Reset()
- func (m *ChangePeerResponse) Size() (n int)
- func (m *ChangePeerResponse) String() string
- func (m *ChangePeerResponse) Unmarshal(dAtA []byte) error
- type CmdType
- type CompactLogRequest
- func (*CompactLogRequest) Descriptor() ([]byte, []int)
- func (m *CompactLogRequest) GetCompactIndex() uint64
- func (m *CompactLogRequest) GetCompactTerm() uint64
- func (m *CompactLogRequest) Marshal() (dAtA []byte, err error)
- func (m *CompactLogRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CompactLogRequest) ProtoMessage()
- func (m *CompactLogRequest) Reset()
- func (m *CompactLogRequest) Size() (n int)
- func (m *CompactLogRequest) String() string
- func (m *CompactLogRequest) Unmarshal(dAtA []byte) error
- type CompactLogResponse
- func (*CompactLogResponse) Descriptor() ([]byte, []int)
- func (m *CompactLogResponse) Marshal() (dAtA []byte, err error)
- func (m *CompactLogResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CompactLogResponse) ProtoMessage()
- func (m *CompactLogResponse) Reset()
- func (m *CompactLogResponse) Size() (n int)
- func (m *CompactLogResponse) String() string
- func (m *CompactLogResponse) Unmarshal(dAtA []byte) error
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)
- 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 (*DeleteRequest) ProtoMessage()
- func (m *DeleteRequest) Reset()
- func (m *DeleteRequest) Size() (n int)
- func (m *DeleteRequest) String() string
- func (m *DeleteRequest) Unmarshal(dAtA []byte) error
- type DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)
- func (m *DeleteResponse) Marshal() (dAtA []byte, err error)
- func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteResponse) ProtoMessage()
- func (m *DeleteResponse) Reset()
- func (m *DeleteResponse) Size() (n int)
- func (m *DeleteResponse) String() string
- func (m *DeleteResponse) Unmarshal(dAtA []byte) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- 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 (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) Size() (n int)
- func (m *GetRequest) String() string
- func (m *GetRequest) Unmarshal(dAtA []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) GetValue() []byte
- func (m *GetResponse) Marshal() (dAtA []byte, err error)
- func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) Size() (n int)
- func (m *GetResponse) String() string
- func (m *GetResponse) Unmarshal(dAtA []byte) error
- type PutRequest
- func (*PutRequest) Descriptor() ([]byte, []int)
- 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 (*PutRequest) ProtoMessage()
- func (m *PutRequest) Reset()
- func (m *PutRequest) Size() (n int)
- func (m *PutRequest) String() string
- func (m *PutRequest) Unmarshal(dAtA []byte) error
- type PutResponse
- func (*PutResponse) Descriptor() ([]byte, []int)
- func (m *PutResponse) Marshal() (dAtA []byte, err error)
- func (m *PutResponse) MarshalTo(dAtA []byte) (int, error)
- func (*PutResponse) ProtoMessage()
- func (m *PutResponse) Reset()
- func (m *PutResponse) Size() (n int)
- func (m *PutResponse) String() string
- func (m *PutResponse) Unmarshal(dAtA []byte) error
- type RaftCmdRequest
- func (*RaftCmdRequest) Descriptor() ([]byte, []int)
- 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 (*RaftCmdRequest) ProtoMessage()
- func (m *RaftCmdRequest) Reset()
- func (m *RaftCmdRequest) Size() (n int)
- func (m *RaftCmdRequest) String() string
- func (m *RaftCmdRequest) Unmarshal(dAtA []byte) error
- type RaftCmdResponse
- func (*RaftCmdResponse) Descriptor() ([]byte, []int)
- 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 (*RaftCmdResponse) ProtoMessage()
- func (m *RaftCmdResponse) Reset()
- func (m *RaftCmdResponse) Size() (n int)
- func (m *RaftCmdResponse) String() string
- func (m *RaftCmdResponse) Unmarshal(dAtA []byte) error
- type RaftRequestHeader
- func (*RaftRequestHeader) Descriptor() ([]byte, []int)
- func (m *RaftRequestHeader) GetPeer() *metapb.Peer
- func (m *RaftRequestHeader) GetReadQuorum() bool
- func (m *RaftRequestHeader) GetRegionEpoch() *metapb.RegionEpoch
- func (m *RaftRequestHeader) GetRegionId() uint64
- 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 (*RaftRequestHeader) ProtoMessage()
- func (m *RaftRequestHeader) Reset()
- func (m *RaftRequestHeader) Size() (n int)
- func (m *RaftRequestHeader) String() string
- func (m *RaftRequestHeader) Unmarshal(dAtA []byte) error
- type RaftResponseHeader
- func (*RaftResponseHeader) Descriptor() ([]byte, []int)
- 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 (*RaftResponseHeader) ProtoMessage()
- func (m *RaftResponseHeader) Reset()
- func (m *RaftResponseHeader) Size() (n int)
- func (m *RaftResponseHeader) String() string
- func (m *RaftResponseHeader) Unmarshal(dAtA []byte) error
- type RegionDetailRequest
- func (*RegionDetailRequest) Descriptor() ([]byte, []int)
- func (m *RegionDetailRequest) Marshal() (dAtA []byte, err error)
- func (m *RegionDetailRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RegionDetailRequest) ProtoMessage()
- func (m *RegionDetailRequest) Reset()
- func (m *RegionDetailRequest) Size() (n int)
- func (m *RegionDetailRequest) String() string
- func (m *RegionDetailRequest) Unmarshal(dAtA []byte) error
- type RegionDetailResponse
- func (*RegionDetailResponse) Descriptor() ([]byte, []int)
- 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 (*RegionDetailResponse) ProtoMessage()
- func (m *RegionDetailResponse) Reset()
- func (m *RegionDetailResponse) Size() (n int)
- func (m *RegionDetailResponse) String() string
- func (m *RegionDetailResponse) Unmarshal(dAtA []byte) error
- type RegionLeaderRequest
- func (*RegionLeaderRequest) Descriptor() ([]byte, []int)
- func (m *RegionLeaderRequest) Marshal() (dAtA []byte, err error)
- func (m *RegionLeaderRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RegionLeaderRequest) ProtoMessage()
- func (m *RegionLeaderRequest) Reset()
- func (m *RegionLeaderRequest) Size() (n int)
- func (m *RegionLeaderRequest) String() string
- func (m *RegionLeaderRequest) Unmarshal(dAtA []byte) error
- type RegionLeaderResponse
- func (*RegionLeaderResponse) Descriptor() ([]byte, []int)
- func (m *RegionLeaderResponse) GetLeader() *metapb.Peer
- func (m *RegionLeaderResponse) Marshal() (dAtA []byte, err error)
- func (m *RegionLeaderResponse) MarshalTo(dAtA []byte) (int, error)
- func (*RegionLeaderResponse) ProtoMessage()
- func (m *RegionLeaderResponse) Reset()
- func (m *RegionLeaderResponse) Size() (n int)
- func (m *RegionLeaderResponse) String() string
- func (m *RegionLeaderResponse) Unmarshal(dAtA []byte) error
- type Request
- func (*Request) Descriptor() ([]byte, []int)
- func (m *Request) GetCmdType() CmdType
- func (m *Request) GetDelete() *DeleteRequest
- func (m *Request) GetGet() *GetRequest
- func (m *Request) GetPut() *PutRequest
- func (m *Request) GetSnap() *SnapRequest
- func (m *Request) Marshal() (dAtA []byte, err error)
- func (m *Request) MarshalTo(dAtA []byte) (int, error)
- func (*Request) ProtoMessage()
- func (m *Request) Reset()
- func (m *Request) Size() (n int)
- func (m *Request) String() string
- func (m *Request) Unmarshal(dAtA []byte) error
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetCmdType() CmdType
- func (m *Response) GetDelete() *DeleteResponse
- func (m *Response) GetGet() *GetResponse
- func (m *Response) GetPut() *PutResponse
- func (m *Response) GetSnap() *SnapResponse
- func (m *Response) Marshal() (dAtA []byte, err error)
- func (m *Response) MarshalTo(dAtA []byte) (int, error)
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) Size() (n int)
- func (m *Response) String() string
- func (m *Response) Unmarshal(dAtA []byte) error
- type SnapRequest
- func (*SnapRequest) Descriptor() ([]byte, []int)
- func (m *SnapRequest) Marshal() (dAtA []byte, err error)
- func (m *SnapRequest) MarshalTo(dAtA []byte) (int, error)
- func (*SnapRequest) ProtoMessage()
- func (m *SnapRequest) Reset()
- func (m *SnapRequest) Size() (n int)
- func (m *SnapRequest) String() string
- func (m *SnapRequest) Unmarshal(dAtA []byte) error
- type SnapResponse
- func (*SnapResponse) Descriptor() ([]byte, []int)
- func (m *SnapResponse) GetRegion() *metapb.Region
- func (m *SnapResponse) Marshal() (dAtA []byte, err error)
- func (m *SnapResponse) MarshalTo(dAtA []byte) (int, error)
- func (*SnapResponse) ProtoMessage()
- func (m *SnapResponse) Reset()
- func (m *SnapResponse) Size() (n int)
- func (m *SnapResponse) String() string
- func (m *SnapResponse) Unmarshal(dAtA []byte) error
- type SplitRequest
- func (*SplitRequest) Descriptor() ([]byte, []int)
- 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 (*SplitRequest) ProtoMessage()
- func (m *SplitRequest) Reset()
- func (m *SplitRequest) Size() (n int)
- func (m *SplitRequest) String() string
- func (m *SplitRequest) Unmarshal(dAtA []byte) error
- type SplitResponse
- func (*SplitResponse) Descriptor() ([]byte, []int)
- 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 (*SplitResponse) ProtoMessage()
- func (m *SplitResponse) Reset()
- func (m *SplitResponse) Size() (n int)
- func (m *SplitResponse) String() string
- func (m *SplitResponse) Unmarshal(dAtA []byte) error
- type StatusCmdType
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)
- 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 (*StatusRequest) ProtoMessage()
- func (m *StatusRequest) Reset()
- func (m *StatusRequest) Size() (n int)
- func (m *StatusRequest) String() string
- func (m *StatusRequest) Unmarshal(dAtA []byte) error
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)
- 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 (*StatusResponse) ProtoMessage()
- func (m *StatusResponse) Reset()
- func (m *StatusResponse) Size() (n int)
- func (m *StatusResponse) String() string
- func (m *StatusResponse) Unmarshal(dAtA []byte) error
- type TransferLeaderRequest
- func (*TransferLeaderRequest) Descriptor() ([]byte, []int)
- func (m *TransferLeaderRequest) GetPeer() *metapb.Peer
- func (m *TransferLeaderRequest) Marshal() (dAtA []byte, err error)
- func (m *TransferLeaderRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TransferLeaderRequest) ProtoMessage()
- func (m *TransferLeaderRequest) Reset()
- func (m *TransferLeaderRequest) Size() (n int)
- func (m *TransferLeaderRequest) String() string
- func (m *TransferLeaderRequest) Unmarshal(dAtA []byte) error
- type TransferLeaderResponse
- func (*TransferLeaderResponse) Descriptor() ([]byte, []int)
- func (m *TransferLeaderResponse) Marshal() (dAtA []byte, err error)
- func (m *TransferLeaderResponse) MarshalTo(dAtA []byte) (int, error)
- func (*TransferLeaderResponse) ProtoMessage()
- func (m *TransferLeaderResponse) Reset()
- func (m *TransferLeaderResponse) Size() (n int)
- func (m *TransferLeaderResponse) String() string
- func (m *TransferLeaderResponse) Unmarshal(dAtA []byte) error
- type VerifyHashRequest
- func (*VerifyHashRequest) Descriptor() ([]byte, []int)
- 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 (*VerifyHashRequest) ProtoMessage()
- func (m *VerifyHashRequest) Reset()
- func (m *VerifyHashRequest) Size() (n int)
- func (m *VerifyHashRequest) String() string
- func (m *VerifyHashRequest) Unmarshal(dAtA []byte) error
- type VerifyHashResponse
- func (*VerifyHashResponse) Descriptor() ([]byte, []int)
- func (m *VerifyHashResponse) Marshal() (dAtA []byte, err error)
- func (m *VerifyHashResponse) MarshalTo(dAtA []byte) (int, error)
- func (*VerifyHashResponse) ProtoMessage()
- func (m *VerifyHashResponse) Reset()
- func (m *VerifyHashResponse) Size() (n int)
- func (m *VerifyHashResponse) String() string
- func (m *VerifyHashResponse) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthRaftCmdpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRaftCmdpb = fmt.Errorf("proto: integer overflow") )
var AdminCmdType_name = map[int32]string{
0: "InvalidAdmin",
1: "ChangePeer",
2: "Split",
3: "CompactLog",
4: "TransferLeader",
5: "ComputeHash",
6: "VerifyHash",
}
var AdminCmdType_value = map[string]int32{
"InvalidAdmin": 0,
"ChangePeer": 1,
"Split": 2,
"CompactLog": 3,
"TransferLeader": 4,
"ComputeHash": 5,
"VerifyHash": 6,
}
var CmdType_name = map[int32]string{
0: "Invalid",
1: "Get",
3: "Put",
4: "Delete",
5: "Snap",
}
var CmdType_value = map[string]int32{
"Invalid": 0,
"Get": 1,
"Put": 3,
"Delete": 4,
"Snap": 5,
}
var StatusCmdType_name = map[int32]string{
0: "InvalidStatus",
1: "RegionLeader",
2: "RegionDetail",
}
var StatusCmdType_value = map[string]int32{
"InvalidStatus": 0,
"RegionLeader": 1,
"RegionDetail": 2,
}
Functions ¶
This section is empty.
Types ¶
type AdminCmdType ¶
type AdminCmdType int32
const ( AdminCmdType_InvalidAdmin AdminCmdType = 0 AdminCmdType_ChangePeer AdminCmdType = 1 AdminCmdType_Split AdminCmdType = 2 AdminCmdType_CompactLog AdminCmdType = 3 AdminCmdType_TransferLeader AdminCmdType = 4 AdminCmdType_ComputeHash AdminCmdType = 5 AdminCmdType_VerifyHash AdminCmdType = 6 )
func (AdminCmdType) Enum ¶
func (x AdminCmdType) Enum() *AdminCmdType
func (AdminCmdType) EnumDescriptor ¶
func (AdminCmdType) EnumDescriptor() ([]byte, []int)
func (AdminCmdType) String ¶
func (x AdminCmdType) String() string
func (*AdminCmdType) UnmarshalJSON ¶
func (x *AdminCmdType) UnmarshalJSON(data []byte) error
type AdminRequest ¶
type AdminRequest struct { CmdType *AdminCmdType `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,enum=raft_cmdpb.AdminCmdType" json:"cmd_type,omitempty"` ChangePeer *ChangePeerRequest `protobuf:"bytes,2,opt,name=change_peer,json=changePeer" json:"change_peer,omitempty"` Split *SplitRequest `protobuf:"bytes,3,opt,name=split" json:"split,omitempty"` CompactLog *CompactLogRequest `protobuf:"bytes,4,opt,name=compact_log,json=compactLog" json:"compact_log,omitempty"` TransferLeader *TransferLeaderRequest `protobuf:"bytes,5,opt,name=transfer_leader,json=transferLeader" json:"transfer_leader,omitempty"` VerifyHash *VerifyHashRequest `protobuf:"bytes,6,opt,name=verify_hash,json=verifyHash" json:"verify_hash,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AdminRequest) Descriptor ¶
func (*AdminRequest) Descriptor() ([]byte, []int)
func (*AdminRequest) GetChangePeer ¶
func (m *AdminRequest) GetChangePeer() *ChangePeerRequest
func (*AdminRequest) GetCmdType ¶
func (m *AdminRequest) GetCmdType() AdminCmdType
func (*AdminRequest) GetCompactLog ¶
func (m *AdminRequest) GetCompactLog() *CompactLogRequest
func (*AdminRequest) GetSplit ¶
func (m *AdminRequest) GetSplit() *SplitRequest
func (*AdminRequest) GetTransferLeader ¶
func (m *AdminRequest) GetTransferLeader() *TransferLeaderRequest
func (*AdminRequest) GetVerifyHash ¶
func (m *AdminRequest) GetVerifyHash() *VerifyHashRequest
func (*AdminRequest) Marshal ¶
func (m *AdminRequest) Marshal() (dAtA []byte, err error)
func (*AdminRequest) ProtoMessage ¶
func (*AdminRequest) ProtoMessage()
func (*AdminRequest) Reset ¶
func (m *AdminRequest) Reset()
func (*AdminRequest) Size ¶
func (m *AdminRequest) Size() (n int)
func (*AdminRequest) String ¶
func (m *AdminRequest) String() string
func (*AdminRequest) Unmarshal ¶
func (m *AdminRequest) Unmarshal(dAtA []byte) error
type AdminResponse ¶
type AdminResponse struct { CmdType *AdminCmdType `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,enum=raft_cmdpb.AdminCmdType" json:"cmd_type,omitempty"` ChangePeer *ChangePeerResponse `protobuf:"bytes,2,opt,name=change_peer,json=changePeer" json:"change_peer,omitempty"` Split *SplitResponse `protobuf:"bytes,3,opt,name=split" json:"split,omitempty"` CompactLog *CompactLogResponse `protobuf:"bytes,4,opt,name=compact_log,json=compactLog" json:"compact_log,omitempty"` TransferLeader *TransferLeaderResponse `protobuf:"bytes,5,opt,name=transfer_leader,json=transferLeader" json:"transfer_leader,omitempty"` VerifyHash *VerifyHashResponse `protobuf:"bytes,6,opt,name=verify_hash,json=verifyHash" json:"verify_hash,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AdminResponse) Descriptor ¶
func (*AdminResponse) Descriptor() ([]byte, []int)
func (*AdminResponse) GetChangePeer ¶
func (m *AdminResponse) GetChangePeer() *ChangePeerResponse
func (*AdminResponse) GetCmdType ¶
func (m *AdminResponse) GetCmdType() AdminCmdType
func (*AdminResponse) GetCompactLog ¶
func (m *AdminResponse) GetCompactLog() *CompactLogResponse
func (*AdminResponse) GetSplit ¶
func (m *AdminResponse) GetSplit() *SplitResponse
func (*AdminResponse) GetTransferLeader ¶
func (m *AdminResponse) GetTransferLeader() *TransferLeaderResponse
func (*AdminResponse) GetVerifyHash ¶
func (m *AdminResponse) GetVerifyHash() *VerifyHashResponse
func (*AdminResponse) Marshal ¶
func (m *AdminResponse) Marshal() (dAtA []byte, err error)
func (*AdminResponse) ProtoMessage ¶
func (*AdminResponse) ProtoMessage()
func (*AdminResponse) Reset ¶
func (m *AdminResponse) Reset()
func (*AdminResponse) Size ¶
func (m *AdminResponse) Size() (n int)
func (*AdminResponse) String ¶
func (m *AdminResponse) String() string
func (*AdminResponse) Unmarshal ¶
func (m *AdminResponse) Unmarshal(dAtA []byte) error
type ChangePeerRequest ¶
type ChangePeerRequest struct { // This can be only called in internal RaftStore now. ChangeType *eraftpb.ConfChangeType `protobuf:"varint,1,opt,name=change_type,json=changeType,enum=eraftpb.ConfChangeType" json:"change_type,omitempty"` Peer *metapb.Peer `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ChangePeerRequest) Descriptor ¶
func (*ChangePeerRequest) Descriptor() ([]byte, []int)
func (*ChangePeerRequest) GetChangeType ¶
func (m *ChangePeerRequest) GetChangeType() eraftpb.ConfChangeType
func (*ChangePeerRequest) GetPeer ¶
func (m *ChangePeerRequest) GetPeer() *metapb.Peer
func (*ChangePeerRequest) Marshal ¶
func (m *ChangePeerRequest) Marshal() (dAtA []byte, err error)
func (*ChangePeerRequest) MarshalTo ¶
func (m *ChangePeerRequest) MarshalTo(dAtA []byte) (int, error)
func (*ChangePeerRequest) ProtoMessage ¶
func (*ChangePeerRequest) ProtoMessage()
func (*ChangePeerRequest) Reset ¶
func (m *ChangePeerRequest) Reset()
func (*ChangePeerRequest) Size ¶
func (m *ChangePeerRequest) Size() (n int)
func (*ChangePeerRequest) String ¶
func (m *ChangePeerRequest) String() string
func (*ChangePeerRequest) Unmarshal ¶
func (m *ChangePeerRequest) Unmarshal(dAtA []byte) error
type ChangePeerResponse ¶
type ChangePeerResponse struct { Region *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ChangePeerResponse) Descriptor ¶
func (*ChangePeerResponse) Descriptor() ([]byte, []int)
func (*ChangePeerResponse) GetRegion ¶
func (m *ChangePeerResponse) GetRegion() *metapb.Region
func (*ChangePeerResponse) Marshal ¶
func (m *ChangePeerResponse) Marshal() (dAtA []byte, err error)
func (*ChangePeerResponse) MarshalTo ¶
func (m *ChangePeerResponse) MarshalTo(dAtA []byte) (int, error)
func (*ChangePeerResponse) ProtoMessage ¶
func (*ChangePeerResponse) ProtoMessage()
func (*ChangePeerResponse) Reset ¶
func (m *ChangePeerResponse) Reset()
func (*ChangePeerResponse) Size ¶
func (m *ChangePeerResponse) Size() (n int)
func (*ChangePeerResponse) String ¶
func (m *ChangePeerResponse) String() string
func (*ChangePeerResponse) Unmarshal ¶
func (m *ChangePeerResponse) Unmarshal(dAtA []byte) error
type CompactLogRequest ¶
type CompactLogRequest struct { CompactIndex *uint64 `protobuf:"varint,1,opt,name=compact_index,json=compactIndex" json:"compact_index,omitempty"` CompactTerm *uint64 `protobuf:"varint,2,opt,name=compact_term,json=compactTerm" json:"compact_term,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CompactLogRequest) Descriptor ¶
func (*CompactLogRequest) Descriptor() ([]byte, []int)
func (*CompactLogRequest) GetCompactIndex ¶
func (m *CompactLogRequest) GetCompactIndex() uint64
func (*CompactLogRequest) GetCompactTerm ¶
func (m *CompactLogRequest) GetCompactTerm() uint64
func (*CompactLogRequest) Marshal ¶
func (m *CompactLogRequest) Marshal() (dAtA []byte, err error)
func (*CompactLogRequest) MarshalTo ¶
func (m *CompactLogRequest) MarshalTo(dAtA []byte) (int, error)
func (*CompactLogRequest) ProtoMessage ¶
func (*CompactLogRequest) ProtoMessage()
func (*CompactLogRequest) Reset ¶
func (m *CompactLogRequest) Reset()
func (*CompactLogRequest) Size ¶
func (m *CompactLogRequest) Size() (n int)
func (*CompactLogRequest) String ¶
func (m *CompactLogRequest) String() string
func (*CompactLogRequest) Unmarshal ¶
func (m *CompactLogRequest) Unmarshal(dAtA []byte) error
type CompactLogResponse ¶
type CompactLogResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*CompactLogResponse) Descriptor ¶
func (*CompactLogResponse) Descriptor() ([]byte, []int)
func (*CompactLogResponse) Marshal ¶
func (m *CompactLogResponse) Marshal() (dAtA []byte, err error)
func (*CompactLogResponse) MarshalTo ¶
func (m *CompactLogResponse) MarshalTo(dAtA []byte) (int, error)
func (*CompactLogResponse) ProtoMessage ¶
func (*CompactLogResponse) ProtoMessage()
func (*CompactLogResponse) Reset ¶
func (m *CompactLogResponse) Reset()
func (*CompactLogResponse) Size ¶
func (m *CompactLogResponse) Size() (n int)
func (*CompactLogResponse) String ¶
func (m *CompactLogResponse) String() string
func (*CompactLogResponse) Unmarshal ¶
func (m *CompactLogResponse) Unmarshal(dAtA []byte) error
type DeleteRequest ¶
type DeleteRequest struct { Cf *string `protobuf:"bytes,1,opt,name=cf" json:"cf,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) GetCf ¶
func (m *DeleteRequest) GetCf() string
func (*DeleteRequest) GetKey ¶
func (m *DeleteRequest) GetKey() []byte
func (*DeleteRequest) Marshal ¶
func (m *DeleteRequest) Marshal() (dAtA []byte, err error)
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) Reset ¶
func (m *DeleteRequest) Reset()
func (*DeleteRequest) Size ¶
func (m *DeleteRequest) Size() (n int)
func (*DeleteRequest) String ¶
func (m *DeleteRequest) String() string
func (*DeleteRequest) Unmarshal ¶
func (m *DeleteRequest) Unmarshal(dAtA []byte) error
type DeleteResponse ¶
type DeleteResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*DeleteResponse) Descriptor ¶
func (*DeleteResponse) Descriptor() ([]byte, []int)
func (*DeleteResponse) Marshal ¶
func (m *DeleteResponse) Marshal() (dAtA []byte, err error)
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) Reset ¶
func (m *DeleteResponse) Reset()
func (*DeleteResponse) Size ¶
func (m *DeleteResponse) Size() (n int)
func (*DeleteResponse) String ¶
func (m *DeleteResponse) String() string
func (*DeleteResponse) Unmarshal ¶
func (m *DeleteResponse) Unmarshal(dAtA []byte) error
type GetRequest ¶
type GetRequest struct { Cf *string `protobuf:"bytes,1,opt,name=cf" json:"cf,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetCf ¶
func (m *GetRequest) GetCf() string
func (*GetRequest) GetKey ¶
func (m *GetRequest) GetKey() []byte
func (*GetRequest) Marshal ¶
func (m *GetRequest) Marshal() (dAtA []byte, err error)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) Size ¶
func (m *GetRequest) Size() (n int)
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) Unmarshal ¶
func (m *GetRequest) Unmarshal(dAtA []byte) error
type GetResponse ¶
type GetResponse struct { Value []byte `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetValue ¶
func (m *GetResponse) GetValue() []byte
func (*GetResponse) Marshal ¶
func (m *GetResponse) Marshal() (dAtA []byte, err error)
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) Size ¶
func (m *GetResponse) Size() (n int)
func (*GetResponse) String ¶
func (m *GetResponse) String() string
func (*GetResponse) Unmarshal ¶
func (m *GetResponse) Unmarshal(dAtA []byte) error
type PutRequest ¶
type PutRequest struct { Cf *string `protobuf:"bytes,1,opt,name=cf" json:"cf,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*PutRequest) Descriptor ¶
func (*PutRequest) Descriptor() ([]byte, []int)
func (*PutRequest) GetCf ¶
func (m *PutRequest) GetCf() string
func (*PutRequest) GetKey ¶
func (m *PutRequest) GetKey() []byte
func (*PutRequest) GetValue ¶
func (m *PutRequest) GetValue() []byte
func (*PutRequest) Marshal ¶
func (m *PutRequest) Marshal() (dAtA []byte, err error)
func (*PutRequest) ProtoMessage ¶
func (*PutRequest) ProtoMessage()
func (*PutRequest) Reset ¶
func (m *PutRequest) Reset()
func (*PutRequest) Size ¶
func (m *PutRequest) Size() (n int)
func (*PutRequest) String ¶
func (m *PutRequest) String() string
func (*PutRequest) Unmarshal ¶
func (m *PutRequest) Unmarshal(dAtA []byte) error
type PutResponse ¶
type PutResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*PutResponse) Descriptor ¶
func (*PutResponse) Descriptor() ([]byte, []int)
func (*PutResponse) Marshal ¶
func (m *PutResponse) Marshal() (dAtA []byte, err error)
func (*PutResponse) ProtoMessage ¶
func (*PutResponse) ProtoMessage()
func (*PutResponse) Reset ¶
func (m *PutResponse) Reset()
func (*PutResponse) Size ¶
func (m *PutResponse) Size() (n int)
func (*PutResponse) String ¶
func (m *PutResponse) String() string
func (*PutResponse) Unmarshal ¶
func (m *PutResponse) Unmarshal(dAtA []byte) error
type RaftCmdRequest ¶
type RaftCmdRequest struct { Header *RaftRequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` // We can't enclose normal requests and administrator request // at same time. Requests []*Request `protobuf:"bytes,2,rep,name=requests" json:"requests,omitempty"` AdminRequest *AdminRequest `protobuf:"bytes,3,opt,name=admin_request,json=adminRequest" json:"admin_request,omitempty"` StatusRequest *StatusRequest `protobuf:"bytes,4,opt,name=status_request,json=statusRequest" json:"status_request,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RaftCmdRequest) Descriptor ¶
func (*RaftCmdRequest) Descriptor() ([]byte, []int)
func (*RaftCmdRequest) GetAdminRequest ¶
func (m *RaftCmdRequest) GetAdminRequest() *AdminRequest
func (*RaftCmdRequest) GetHeader ¶
func (m *RaftCmdRequest) GetHeader() *RaftRequestHeader
func (*RaftCmdRequest) GetRequests ¶
func (m *RaftCmdRequest) GetRequests() []*Request
func (*RaftCmdRequest) GetStatusRequest ¶
func (m *RaftCmdRequest) GetStatusRequest() *StatusRequest
func (*RaftCmdRequest) Marshal ¶
func (m *RaftCmdRequest) Marshal() (dAtA []byte, err error)
func (*RaftCmdRequest) ProtoMessage ¶
func (*RaftCmdRequest) ProtoMessage()
func (*RaftCmdRequest) Reset ¶
func (m *RaftCmdRequest) Reset()
func (*RaftCmdRequest) Size ¶
func (m *RaftCmdRequest) Size() (n int)
func (*RaftCmdRequest) String ¶
func (m *RaftCmdRequest) String() string
func (*RaftCmdRequest) Unmarshal ¶
func (m *RaftCmdRequest) Unmarshal(dAtA []byte) error
type RaftCmdResponse ¶
type RaftCmdResponse struct { Header *RaftResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` Responses []*Response `protobuf:"bytes,2,rep,name=responses" json:"responses,omitempty"` AdminResponse *AdminResponse `protobuf:"bytes,3,opt,name=admin_response,json=adminResponse" json:"admin_response,omitempty"` StatusResponse *StatusResponse `protobuf:"bytes,4,opt,name=status_response,json=statusResponse" json:"status_response,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RaftCmdResponse) Descriptor ¶
func (*RaftCmdResponse) Descriptor() ([]byte, []int)
func (*RaftCmdResponse) GetAdminResponse ¶
func (m *RaftCmdResponse) GetAdminResponse() *AdminResponse
func (*RaftCmdResponse) GetHeader ¶
func (m *RaftCmdResponse) GetHeader() *RaftResponseHeader
func (*RaftCmdResponse) GetResponses ¶
func (m *RaftCmdResponse) GetResponses() []*Response
func (*RaftCmdResponse) GetStatusResponse ¶
func (m *RaftCmdResponse) GetStatusResponse() *StatusResponse
func (*RaftCmdResponse) Marshal ¶
func (m *RaftCmdResponse) Marshal() (dAtA []byte, err error)
func (*RaftCmdResponse) ProtoMessage ¶
func (*RaftCmdResponse) ProtoMessage()
func (*RaftCmdResponse) Reset ¶
func (m *RaftCmdResponse) Reset()
func (*RaftCmdResponse) Size ¶
func (m *RaftCmdResponse) Size() (n int)
func (*RaftCmdResponse) String ¶
func (m *RaftCmdResponse) String() string
func (*RaftCmdResponse) Unmarshal ¶
func (m *RaftCmdResponse) Unmarshal(dAtA []byte) error
type RaftRequestHeader ¶
type RaftRequestHeader struct { RegionId *uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId" json:"region_id,omitempty"` Peer *metapb.Peer `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"` // true for read linearization ReadQuorum *bool `protobuf:"varint,3,opt,name=read_quorum,json=readQuorum" json:"read_quorum,omitempty"` // 16 bytes, to distinguish request. Uuid []byte `protobuf:"bytes,4,opt,name=uuid" json:"uuid,omitempty"` RegionEpoch *metapb.RegionEpoch `protobuf:"bytes,5,opt,name=region_epoch,json=regionEpoch" json:"region_epoch,omitempty"` Term *uint64 `protobuf:"varint,6,opt,name=term" json:"term,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RaftRequestHeader) Descriptor ¶
func (*RaftRequestHeader) Descriptor() ([]byte, []int)
func (*RaftRequestHeader) GetPeer ¶
func (m *RaftRequestHeader) GetPeer() *metapb.Peer
func (*RaftRequestHeader) GetReadQuorum ¶
func (m *RaftRequestHeader) GetReadQuorum() bool
func (*RaftRequestHeader) GetRegionEpoch ¶
func (m *RaftRequestHeader) GetRegionEpoch() *metapb.RegionEpoch
func (*RaftRequestHeader) GetRegionId ¶
func (m *RaftRequestHeader) GetRegionId() uint64
func (*RaftRequestHeader) GetTerm ¶
func (m *RaftRequestHeader) GetTerm() uint64
func (*RaftRequestHeader) GetUuid ¶
func (m *RaftRequestHeader) GetUuid() []byte
func (*RaftRequestHeader) Marshal ¶
func (m *RaftRequestHeader) Marshal() (dAtA []byte, err error)
func (*RaftRequestHeader) MarshalTo ¶
func (m *RaftRequestHeader) MarshalTo(dAtA []byte) (int, error)
func (*RaftRequestHeader) ProtoMessage ¶
func (*RaftRequestHeader) ProtoMessage()
func (*RaftRequestHeader) Reset ¶
func (m *RaftRequestHeader) Reset()
func (*RaftRequestHeader) Size ¶
func (m *RaftRequestHeader) Size() (n int)
func (*RaftRequestHeader) String ¶
func (m *RaftRequestHeader) String() string
func (*RaftRequestHeader) Unmarshal ¶
func (m *RaftRequestHeader) Unmarshal(dAtA []byte) error
type RaftResponseHeader ¶
type RaftResponseHeader struct { Error *errorpb.Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Uuid []byte `protobuf:"bytes,2,opt,name=uuid" json:"uuid,omitempty"` CurrentTerm *uint64 `protobuf:"varint,3,opt,name=current_term,json=currentTerm" json:"current_term,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RaftResponseHeader) Descriptor ¶
func (*RaftResponseHeader) Descriptor() ([]byte, []int)
func (*RaftResponseHeader) GetCurrentTerm ¶
func (m *RaftResponseHeader) GetCurrentTerm() uint64
func (*RaftResponseHeader) GetError ¶
func (m *RaftResponseHeader) GetError() *errorpb.Error
func (*RaftResponseHeader) GetUuid ¶
func (m *RaftResponseHeader) GetUuid() []byte
func (*RaftResponseHeader) Marshal ¶
func (m *RaftResponseHeader) Marshal() (dAtA []byte, err error)
func (*RaftResponseHeader) MarshalTo ¶
func (m *RaftResponseHeader) MarshalTo(dAtA []byte) (int, error)
func (*RaftResponseHeader) ProtoMessage ¶
func (*RaftResponseHeader) ProtoMessage()
func (*RaftResponseHeader) Reset ¶
func (m *RaftResponseHeader) Reset()
func (*RaftResponseHeader) Size ¶
func (m *RaftResponseHeader) Size() (n int)
func (*RaftResponseHeader) String ¶
func (m *RaftResponseHeader) String() string
func (*RaftResponseHeader) Unmarshal ¶
func (m *RaftResponseHeader) Unmarshal(dAtA []byte) error
type RegionDetailRequest ¶
type RegionDetailRequest struct {
XXX_unrecognized []byte `json:"-"`
}
For getting more information of the region. We add some admin operations (ChangePeer, Split...) into the pb job list, then pd server will peek the first one, handle it and then pop it from the job lib. But sometimes, the pd server may crash before popping. When another pd server starts and finds the job is running but not finished, it will first check whether the raft server already has handled this job. E,g, for ChangePeer, if we add Peer10 into region1 and find region1 has already had Peer10, we can think this ChangePeer is finished, and can pop this job from job list directly.
func (*RegionDetailRequest) Descriptor ¶
func (*RegionDetailRequest) Descriptor() ([]byte, []int)
func (*RegionDetailRequest) Marshal ¶
func (m *RegionDetailRequest) Marshal() (dAtA []byte, err error)
func (*RegionDetailRequest) MarshalTo ¶
func (m *RegionDetailRequest) MarshalTo(dAtA []byte) (int, error)
func (*RegionDetailRequest) ProtoMessage ¶
func (*RegionDetailRequest) ProtoMessage()
func (*RegionDetailRequest) Reset ¶
func (m *RegionDetailRequest) Reset()
func (*RegionDetailRequest) Size ¶
func (m *RegionDetailRequest) Size() (n int)
func (*RegionDetailRequest) String ¶
func (m *RegionDetailRequest) String() string
func (*RegionDetailRequest) Unmarshal ¶
func (m *RegionDetailRequest) Unmarshal(dAtA []byte) error
type RegionDetailResponse ¶
type RegionDetailResponse struct { Region *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"` Leader *metapb.Peer `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RegionDetailResponse) Descriptor ¶
func (*RegionDetailResponse) Descriptor() ([]byte, []int)
func (*RegionDetailResponse) GetLeader ¶
func (m *RegionDetailResponse) GetLeader() *metapb.Peer
func (*RegionDetailResponse) GetRegion ¶
func (m *RegionDetailResponse) GetRegion() *metapb.Region
func (*RegionDetailResponse) Marshal ¶
func (m *RegionDetailResponse) Marshal() (dAtA []byte, err error)
func (*RegionDetailResponse) MarshalTo ¶
func (m *RegionDetailResponse) MarshalTo(dAtA []byte) (int, error)
func (*RegionDetailResponse) ProtoMessage ¶
func (*RegionDetailResponse) ProtoMessage()
func (*RegionDetailResponse) Reset ¶
func (m *RegionDetailResponse) Reset()
func (*RegionDetailResponse) Size ¶
func (m *RegionDetailResponse) Size() (n int)
func (*RegionDetailResponse) String ¶
func (m *RegionDetailResponse) String() string
func (*RegionDetailResponse) Unmarshal ¶
func (m *RegionDetailResponse) Unmarshal(dAtA []byte) error
type RegionLeaderRequest ¶
type RegionLeaderRequest struct {
XXX_unrecognized []byte `json:"-"`
}
For get the leader of the region.
func (*RegionLeaderRequest) Descriptor ¶
func (*RegionLeaderRequest) Descriptor() ([]byte, []int)
func (*RegionLeaderRequest) Marshal ¶
func (m *RegionLeaderRequest) Marshal() (dAtA []byte, err error)
func (*RegionLeaderRequest) MarshalTo ¶
func (m *RegionLeaderRequest) MarshalTo(dAtA []byte) (int, error)
func (*RegionLeaderRequest) ProtoMessage ¶
func (*RegionLeaderRequest) ProtoMessage()
func (*RegionLeaderRequest) Reset ¶
func (m *RegionLeaderRequest) Reset()
func (*RegionLeaderRequest) Size ¶
func (m *RegionLeaderRequest) Size() (n int)
func (*RegionLeaderRequest) String ¶
func (m *RegionLeaderRequest) String() string
func (*RegionLeaderRequest) Unmarshal ¶
func (m *RegionLeaderRequest) Unmarshal(dAtA []byte) error
type RegionLeaderResponse ¶
type RegionLeaderResponse struct { Leader *metapb.Peer `protobuf:"bytes,1,opt,name=leader" json:"leader,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RegionLeaderResponse) Descriptor ¶
func (*RegionLeaderResponse) Descriptor() ([]byte, []int)
func (*RegionLeaderResponse) GetLeader ¶
func (m *RegionLeaderResponse) GetLeader() *metapb.Peer
func (*RegionLeaderResponse) Marshal ¶
func (m *RegionLeaderResponse) Marshal() (dAtA []byte, err error)
func (*RegionLeaderResponse) MarshalTo ¶
func (m *RegionLeaderResponse) MarshalTo(dAtA []byte) (int, error)
func (*RegionLeaderResponse) ProtoMessage ¶
func (*RegionLeaderResponse) ProtoMessage()
func (*RegionLeaderResponse) Reset ¶
func (m *RegionLeaderResponse) Reset()
func (*RegionLeaderResponse) Size ¶
func (m *RegionLeaderResponse) Size() (n int)
func (*RegionLeaderResponse) String ¶
func (m *RegionLeaderResponse) String() string
func (*RegionLeaderResponse) Unmarshal ¶
func (m *RegionLeaderResponse) Unmarshal(dAtA []byte) error
type Request ¶
type Request struct { CmdType *CmdType `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,enum=raft_cmdpb.CmdType" json:"cmd_type,omitempty"` Get *GetRequest `protobuf:"bytes,2,opt,name=get" json:"get,omitempty"` Put *PutRequest `protobuf:"bytes,4,opt,name=put" json:"put,omitempty"` Delete *DeleteRequest `protobuf:"bytes,5,opt,name=delete" json:"delete,omitempty"` Snap *SnapRequest `protobuf:"bytes,6,opt,name=snap" json:"snap,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Request) Descriptor ¶
func (*Request) GetCmdType ¶
func (*Request) GetDelete ¶
func (m *Request) GetDelete() *DeleteRequest
func (*Request) GetGet ¶
func (m *Request) GetGet() *GetRequest
func (*Request) GetPut ¶
func (m *Request) GetPut() *PutRequest
func (*Request) GetSnap ¶
func (m *Request) GetSnap() *SnapRequest
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
type Response ¶
type Response struct { CmdType *CmdType `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,enum=raft_cmdpb.CmdType" json:"cmd_type,omitempty"` Get *GetResponse `protobuf:"bytes,2,opt,name=get" json:"get,omitempty"` Put *PutResponse `protobuf:"bytes,4,opt,name=put" json:"put,omitempty"` Delete *DeleteResponse `protobuf:"bytes,5,opt,name=delete" json:"delete,omitempty"` Snap *SnapResponse `protobuf:"bytes,6,opt,name=snap" json:"snap,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Response) Descriptor ¶
func (*Response) GetCmdType ¶
func (*Response) GetDelete ¶
func (m *Response) GetDelete() *DeleteResponse
func (*Response) GetGet ¶
func (m *Response) GetGet() *GetResponse
func (*Response) GetPut ¶
func (m *Response) GetPut() *PutResponse
func (*Response) GetSnap ¶
func (m *Response) GetSnap() *SnapResponse
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
type SnapRequest ¶
type SnapRequest struct {
XXX_unrecognized []byte `json:"-"`
}
func (*SnapRequest) Descriptor ¶
func (*SnapRequest) Descriptor() ([]byte, []int)
func (*SnapRequest) Marshal ¶
func (m *SnapRequest) Marshal() (dAtA []byte, err error)
func (*SnapRequest) ProtoMessage ¶
func (*SnapRequest) ProtoMessage()
func (*SnapRequest) Reset ¶
func (m *SnapRequest) Reset()
func (*SnapRequest) Size ¶
func (m *SnapRequest) Size() (n int)
func (*SnapRequest) String ¶
func (m *SnapRequest) String() string
func (*SnapRequest) Unmarshal ¶
func (m *SnapRequest) Unmarshal(dAtA []byte) error
type SnapResponse ¶
type SnapResponse struct { Region *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*SnapResponse) Descriptor ¶
func (*SnapResponse) Descriptor() ([]byte, []int)
func (*SnapResponse) GetRegion ¶
func (m *SnapResponse) GetRegion() *metapb.Region
func (*SnapResponse) Marshal ¶
func (m *SnapResponse) Marshal() (dAtA []byte, err error)
func (*SnapResponse) ProtoMessage ¶
func (*SnapResponse) ProtoMessage()
func (*SnapResponse) Reset ¶
func (m *SnapResponse) Reset()
func (*SnapResponse) Size ¶
func (m *SnapResponse) Size() (n int)
func (*SnapResponse) String ¶
func (m *SnapResponse) String() string
func (*SnapResponse) Unmarshal ¶
func (m *SnapResponse) Unmarshal(dAtA []byte) error
type SplitRequest ¶
type SplitRequest struct { // This can be only called in internal RaftStore now. // The split_key must be in the been splitting region. SplitKey []byte `protobuf:"bytes,1,opt,name=split_key,json=splitKey" json:"split_key,omitempty"` // We split the region into two, first uses the origin // parent region id, and the second uses the new_region_id. // We must guarantee that the new_region_id is global unique. NewRegionId *uint64 `protobuf:"varint,2,opt,name=new_region_id,json=newRegionId" json:"new_region_id,omitempty"` // The peer ids for the new split region. NewPeerIds []uint64 `protobuf:"varint,3,rep,name=new_peer_ids,json=newPeerIds" json:"new_peer_ids,omitempty"` // If true, right region derive the origin region_id, // left region use new_region_id. RightDerive *bool `protobuf:"varint,4,opt,name=right_derive,json=rightDerive" json:"right_derive,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*SplitRequest) Descriptor ¶
func (*SplitRequest) Descriptor() ([]byte, []int)
func (*SplitRequest) GetNewPeerIds ¶
func (m *SplitRequest) GetNewPeerIds() []uint64
func (*SplitRequest) GetNewRegionId ¶
func (m *SplitRequest) GetNewRegionId() uint64
func (*SplitRequest) GetRightDerive ¶
func (m *SplitRequest) GetRightDerive() bool
func (*SplitRequest) GetSplitKey ¶
func (m *SplitRequest) GetSplitKey() []byte
func (*SplitRequest) Marshal ¶
func (m *SplitRequest) Marshal() (dAtA []byte, err error)
func (*SplitRequest) ProtoMessage ¶
func (*SplitRequest) ProtoMessage()
func (*SplitRequest) Reset ¶
func (m *SplitRequest) Reset()
func (*SplitRequest) Size ¶
func (m *SplitRequest) Size() (n int)
func (*SplitRequest) String ¶
func (m *SplitRequest) String() string
func (*SplitRequest) Unmarshal ¶
func (m *SplitRequest) Unmarshal(dAtA []byte) error
type SplitResponse ¶
type SplitResponse struct { Left *metapb.Region `protobuf:"bytes,1,opt,name=left" json:"left,omitempty"` Right *metapb.Region `protobuf:"bytes,2,opt,name=right" json:"right,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*SplitResponse) Descriptor ¶
func (*SplitResponse) Descriptor() ([]byte, []int)
func (*SplitResponse) GetLeft ¶
func (m *SplitResponse) GetLeft() *metapb.Region
func (*SplitResponse) GetRight ¶
func (m *SplitResponse) GetRight() *metapb.Region
func (*SplitResponse) Marshal ¶
func (m *SplitResponse) Marshal() (dAtA []byte, err error)
func (*SplitResponse) ProtoMessage ¶
func (*SplitResponse) ProtoMessage()
func (*SplitResponse) Reset ¶
func (m *SplitResponse) Reset()
func (*SplitResponse) Size ¶
func (m *SplitResponse) Size() (n int)
func (*SplitResponse) String ¶
func (m *SplitResponse) String() string
func (*SplitResponse) Unmarshal ¶
func (m *SplitResponse) Unmarshal(dAtA []byte) error
type StatusCmdType ¶
type StatusCmdType int32
const ( StatusCmdType_InvalidStatus StatusCmdType = 0 StatusCmdType_RegionLeader StatusCmdType = 1 StatusCmdType_RegionDetail StatusCmdType = 2 )
func (StatusCmdType) Enum ¶
func (x StatusCmdType) Enum() *StatusCmdType
func (StatusCmdType) EnumDescriptor ¶
func (StatusCmdType) EnumDescriptor() ([]byte, []int)
func (StatusCmdType) String ¶
func (x StatusCmdType) String() string
func (*StatusCmdType) UnmarshalJSON ¶
func (x *StatusCmdType) UnmarshalJSON(data []byte) error
type StatusRequest ¶
type StatusRequest struct { CmdType *StatusCmdType `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,enum=raft_cmdpb.StatusCmdType" json:"cmd_type,omitempty"` RegionLeader *RegionLeaderRequest `protobuf:"bytes,2,opt,name=region_leader,json=regionLeader" json:"region_leader,omitempty"` RegionDetail *RegionDetailRequest `protobuf:"bytes,3,opt,name=region_detail,json=regionDetail" json:"region_detail,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*StatusRequest) Descriptor ¶
func (*StatusRequest) Descriptor() ([]byte, []int)
func (*StatusRequest) GetCmdType ¶
func (m *StatusRequest) GetCmdType() StatusCmdType
func (*StatusRequest) GetRegionDetail ¶
func (m *StatusRequest) GetRegionDetail() *RegionDetailRequest
func (*StatusRequest) GetRegionLeader ¶
func (m *StatusRequest) GetRegionLeader() *RegionLeaderRequest
func (*StatusRequest) Marshal ¶
func (m *StatusRequest) Marshal() (dAtA []byte, err error)
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) Reset ¶
func (m *StatusRequest) Reset()
func (*StatusRequest) Size ¶
func (m *StatusRequest) Size() (n int)
func (*StatusRequest) String ¶
func (m *StatusRequest) String() string
func (*StatusRequest) Unmarshal ¶
func (m *StatusRequest) Unmarshal(dAtA []byte) error
type StatusResponse ¶
type StatusResponse struct { CmdType *StatusCmdType `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,enum=raft_cmdpb.StatusCmdType" json:"cmd_type,omitempty"` RegionLeader *RegionLeaderResponse `protobuf:"bytes,2,opt,name=region_leader,json=regionLeader" json:"region_leader,omitempty"` RegionDetail *RegionDetailResponse `protobuf:"bytes,3,opt,name=region_detail,json=regionDetail" json:"region_detail,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*StatusResponse) Descriptor ¶
func (*StatusResponse) Descriptor() ([]byte, []int)
func (*StatusResponse) GetCmdType ¶
func (m *StatusResponse) GetCmdType() StatusCmdType
func (*StatusResponse) GetRegionDetail ¶
func (m *StatusResponse) GetRegionDetail() *RegionDetailResponse
func (*StatusResponse) GetRegionLeader ¶
func (m *StatusResponse) GetRegionLeader() *RegionLeaderResponse
func (*StatusResponse) Marshal ¶
func (m *StatusResponse) Marshal() (dAtA []byte, err error)
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) Reset ¶
func (m *StatusResponse) Reset()
func (*StatusResponse) Size ¶
func (m *StatusResponse) Size() (n int)
func (*StatusResponse) String ¶
func (m *StatusResponse) String() string
func (*StatusResponse) Unmarshal ¶
func (m *StatusResponse) Unmarshal(dAtA []byte) error
type TransferLeaderRequest ¶
type TransferLeaderRequest struct { Peer *metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*TransferLeaderRequest) Descriptor ¶
func (*TransferLeaderRequest) Descriptor() ([]byte, []int)
func (*TransferLeaderRequest) GetPeer ¶
func (m *TransferLeaderRequest) GetPeer() *metapb.Peer
func (*TransferLeaderRequest) Marshal ¶
func (m *TransferLeaderRequest) Marshal() (dAtA []byte, err error)
func (*TransferLeaderRequest) MarshalTo ¶
func (m *TransferLeaderRequest) MarshalTo(dAtA []byte) (int, error)
func (*TransferLeaderRequest) ProtoMessage ¶
func (*TransferLeaderRequest) ProtoMessage()
func (*TransferLeaderRequest) Reset ¶
func (m *TransferLeaderRequest) Reset()
func (*TransferLeaderRequest) Size ¶
func (m *TransferLeaderRequest) Size() (n int)
func (*TransferLeaderRequest) String ¶
func (m *TransferLeaderRequest) String() string
func (*TransferLeaderRequest) Unmarshal ¶
func (m *TransferLeaderRequest) Unmarshal(dAtA []byte) error
type TransferLeaderResponse ¶
type TransferLeaderResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*TransferLeaderResponse) Descriptor ¶
func (*TransferLeaderResponse) Descriptor() ([]byte, []int)
func (*TransferLeaderResponse) Marshal ¶
func (m *TransferLeaderResponse) Marshal() (dAtA []byte, err error)
func (*TransferLeaderResponse) MarshalTo ¶
func (m *TransferLeaderResponse) MarshalTo(dAtA []byte) (int, error)
func (*TransferLeaderResponse) ProtoMessage ¶
func (*TransferLeaderResponse) ProtoMessage()
func (*TransferLeaderResponse) Reset ¶
func (m *TransferLeaderResponse) Reset()
func (*TransferLeaderResponse) Size ¶
func (m *TransferLeaderResponse) Size() (n int)
func (*TransferLeaderResponse) String ¶
func (m *TransferLeaderResponse) String() string
func (*TransferLeaderResponse) Unmarshal ¶
func (m *TransferLeaderResponse) Unmarshal(dAtA []byte) error
type VerifyHashRequest ¶
type VerifyHashRequest struct { Index *uint64 `protobuf:"varint,1,opt,name=index" json:"index,omitempty"` Hash []byte `protobuf:"bytes,2,opt,name=hash" json:"hash,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*VerifyHashRequest) Descriptor ¶
func (*VerifyHashRequest) Descriptor() ([]byte, []int)
func (*VerifyHashRequest) GetHash ¶
func (m *VerifyHashRequest) GetHash() []byte
func (*VerifyHashRequest) GetIndex ¶
func (m *VerifyHashRequest) GetIndex() uint64
func (*VerifyHashRequest) Marshal ¶
func (m *VerifyHashRequest) Marshal() (dAtA []byte, err error)
func (*VerifyHashRequest) MarshalTo ¶
func (m *VerifyHashRequest) MarshalTo(dAtA []byte) (int, error)
func (*VerifyHashRequest) ProtoMessage ¶
func (*VerifyHashRequest) ProtoMessage()
func (*VerifyHashRequest) Reset ¶
func (m *VerifyHashRequest) Reset()
func (*VerifyHashRequest) Size ¶
func (m *VerifyHashRequest) Size() (n int)
func (*VerifyHashRequest) String ¶
func (m *VerifyHashRequest) String() string
func (*VerifyHashRequest) Unmarshal ¶
func (m *VerifyHashRequest) Unmarshal(dAtA []byte) error
type VerifyHashResponse ¶
type VerifyHashResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*VerifyHashResponse) Descriptor ¶
func (*VerifyHashResponse) Descriptor() ([]byte, []int)
func (*VerifyHashResponse) Marshal ¶
func (m *VerifyHashResponse) Marshal() (dAtA []byte, err error)
func (*VerifyHashResponse) MarshalTo ¶
func (m *VerifyHashResponse) MarshalTo(dAtA []byte) (int, error)
func (*VerifyHashResponse) ProtoMessage ¶
func (*VerifyHashResponse) ProtoMessage()
func (*VerifyHashResponse) Reset ¶
func (m *VerifyHashResponse) Reset()
func (*VerifyHashResponse) Size ¶
func (m *VerifyHashResponse) Size() (n int)
func (*VerifyHashResponse) String ¶
func (m *VerifyHashResponse) String() string
func (*VerifyHashResponse) Unmarshal ¶
func (m *VerifyHashResponse) Unmarshal(dAtA []byte) error