Documentation ¶
Overview ¶
Package msgpb is a generated protocol buffer package.
It is generated from these files:
msgpb.proto
It has these top-level messages:
Message
Index ¶
- Variables
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetCmdReq() *raft_cmdpb.RaftCmdRequest
- func (m *Message) GetCmdResp() *raft_cmdpb.RaftCmdResponse
- func (m *Message) GetCopReq() *coprocessor.Request
- func (m *Message) GetCopResp() *coprocessor.Response
- func (m *Message) GetKvReq() *kvrpcpb.Request
- func (m *Message) GetKvResp() *kvrpcpb.Response
- func (m *Message) GetMsgType() MessageType
- func (m *Message) GetRaft() *raft_serverpb.RaftMessage
- func (m *Message) Marshal() (dAtA []byte, err error)
- func (m *Message) MarshalTo(dAtA []byte) (int, error)
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) Size() (n int)
- func (m *Message) String() string
- func (m *Message) Unmarshal(dAtA []byte) error
- type MessageType
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthMsgpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMsgpb = fmt.Errorf("proto: integer overflow") )
View Source
var MessageType_name = map[int32]string{
0: "None",
1: "Cmd",
2: "CmdResp",
3: "Raft",
4: "KvReq",
5: "KvResp",
6: "CopReq",
7: "CopResp",
}
View Source
var MessageType_value = map[string]int32{
"None": 0,
"Cmd": 1,
"CmdResp": 2,
"Raft": 3,
"KvReq": 4,
"KvResp": 5,
"CopReq": 6,
"CopResp": 7,
}
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message struct { MsgType MessageType `protobuf:"varint,1,opt,name=msg_type,json=msgType,enum=msgpb.MessageType" json:"msg_type"` CmdReq *raft_cmdpb.RaftCmdRequest `protobuf:"bytes,2,opt,name=cmd_req,json=cmdReq" json:"cmd_req,omitempty"` CmdResp *raft_cmdpb.RaftCmdResponse `protobuf:"bytes,3,opt,name=cmd_resp,json=cmdResp" json:"cmd_resp,omitempty"` Raft *raft_serverpb.RaftMessage `protobuf:"bytes,4,opt,name=raft" json:"raft,omitempty"` KvReq *kvrpcpb.Request `protobuf:"bytes,5,opt,name=kv_req,json=kvReq" json:"kv_req,omitempty"` KvResp *kvrpcpb.Response `protobuf:"bytes,6,opt,name=kv_resp,json=kvResp" json:"kv_resp,omitempty"` CopReq *coprocessor.Request `protobuf:"bytes,7,opt,name=cop_req,json=copReq" json:"cop_req,omitempty"` CopResp *coprocessor.Response `protobuf:"bytes,8,opt,name=cop_resp,json=copResp" json:"cop_resp,omitempty"` XXX_unrecognized []byte `json:"-"` }
Message holds all messages communicating with TiKV.
func (*Message) Descriptor ¶
func (*Message) GetCmdReq ¶
func (m *Message) GetCmdReq() *raft_cmdpb.RaftCmdRequest
func (*Message) GetCmdResp ¶
func (m *Message) GetCmdResp() *raft_cmdpb.RaftCmdResponse
func (*Message) GetCopReq ¶
func (m *Message) GetCopReq() *coprocessor.Request
func (*Message) GetCopResp ¶
func (m *Message) GetCopResp() *coprocessor.Response
func (*Message) GetMsgType ¶
func (m *Message) GetMsgType() MessageType
func (*Message) GetRaft ¶
func (m *Message) GetRaft() *raft_serverpb.RaftMessage
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
type MessageType ¶
type MessageType int32
const ( MessageType_None MessageType = 0 MessageType_Cmd MessageType = 1 MessageType_CmdResp MessageType = 2 MessageType_Raft MessageType = 3 MessageType_KvReq MessageType = 4 MessageType_KvResp MessageType = 5 MessageType_CopReq MessageType = 6 MessageType_CopResp MessageType = 7 )
func (MessageType) Enum ¶
func (x MessageType) Enum() *MessageType
func (MessageType) EnumDescriptor ¶
func (MessageType) EnumDescriptor() ([]byte, []int)
func (MessageType) String ¶
func (x MessageType) String() string
func (*MessageType) UnmarshalJSON ¶
func (x *MessageType) UnmarshalJSON(data []byte) error
Click to show internal directories.
Click to hide internal directories.