msgpb

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
  • func (x MessageType) Enum() *MessageType
  • func (MessageType) EnumDescriptor() ([]byte, []int)
  • func (x MessageType) String() string
  • func (x *MessageType) UnmarshalJSON(data []byte) error

Variables

var (
	ErrInvalidLengthMsgpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsgpb   = fmt.Errorf("proto: integer overflow")
)

var MessageType_name = map[int32]string{
	0: "None",
	1: "Cmd",
	2: "CmdResp",
	3: "Raft",
	4: "KvReq",
	5: "KvResp",
	6: "CopReq",
	7: "CopResp",
}

var MessageType_value = map[string]int32{
	"None":    0,
	"Cmd":     1,
	"CmdResp": 2,
	"Raft":    3,
	"KvReq":   4,
	"KvResp":  5,
	"CopReq":  6,
	"CopResp": 7,
}

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) Descriptor() ([]byte, []int)

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) GetKvReq

func (m *Message) GetKvReq() *kvrpcpb.Request

func (*Message) GetKvResp

func (m *Message) GetKvResp() *kvrpcpb.Response

func (*Message) GetMsgType

func (m *Message) GetMsgType() MessageType

func (*Message) GetRaft

func (m *Message) GetRaft() *raft_serverpb.RaftMessage

func (*Message) Marshal

func (m *Message) Marshal() (dAtA []byte, err error)

func (*Message) MarshalTo

func (m *Message) MarshalTo(dAtA []byte) (int, error)

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) Size

func (m *Message) Size() (n int)

func (*Message) String

func (m *Message) String() string

func (*Message) Unmarshal

func (m *Message) Unmarshal(dAtA []byte) error

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