message

Documentation

Overview

Package message is a generated protocol buffer package.

It is generated from these files:

common.proto
rpc.proto

It has these top-level messages:

Message
RpcMessage

Index

• Variables
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (m *Message) GetBody() []byte
  • func (m *Message) GetMessageId() string
  • func (m *Message) GetOptions() map[string]string
  • func (m *Message) GetPriority() MsgPriority
  • func (*Message) ProtoMessage()
  • func (m *Message) Reset()
  • func (m *Message) String() string
• type Meta
  • func (m *Meta) FormMessage(msg *Message)
• type MsgPriority
  • func (MsgPriority) EnumDescriptor() ([]byte, []int)
  • func (x MsgPriority) String() string
• type RpcMessage
  • func (*RpcMessage) Descriptor() ([]byte, []int)
  • func (m *RpcMessage) GetBody() []byte
  • func (m *RpcMessage) GetCode() uint32
  • func (m *RpcMessage) GetMessageId() string
  • func (m *RpcMessage) GetOptions() map[string]string
  • func (*RpcMessage) ProtoMessage()
  • func (m *RpcMessage) Reset()
  • func (m *RpcMessage) String() string

Variables

var MsgPriority_name = map[int32]string{
	0: "PRIORITY0",
	1: "PRIORITY1",
	2: "PRIORITY2",
	3: "PRIORITY3",
	4: "PRIORITY4",
	5: "PRIORITY5",
	6: "PRIORITY6",
	7: "PRIORITY7",
	8: "PRIORITY8",
	9: "PRIORITY9",
}

var MsgPriority_value = map[string]int32{
	"PRIORITY0": 0,
	"PRIORITY1": 1,
	"PRIORITY2": 2,
	"PRIORITY3": 3,
	"PRIORITY4": 4,
	"PRIORITY5": 5,
	"PRIORITY6": 6,
	"PRIORITY7": 7,
	"PRIORITY8": 8,
	"PRIORITY9": 9,
}

Types

type Message

type Message struct {
	MessageId string            `protobuf:"bytes,1,opt,name=MessageId" json:"MessageId,omitempty"`
	Priority  MsgPriority       `protobuf:"varint,2,opt,name=priority,enum=message.MsgPriority" json:"priority,omitempty"`
	Options   map[string]string `` /* 136-byte string literal not displayed */
	Body      []byte            `protobuf:"bytes,3,opt,name=Body,proto3" json:"Body,omitempty"`
}

func (*Message) Descriptor

func (*Message) Descriptor() ([]byte, []int)

func (*Message) GetBody

func (m *Message) GetBody() []byte

func (*Message) GetMessageId

func (m *Message) GetMessageId() string

func (*Message) GetOptions

func (m *Message) GetOptions() map[string]string

func (*Message) GetPriority

func (m *Message) GetPriority() MsgPriority

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) String

func (m *Message) String() string

type Meta

type Meta struct {
	MessageId string
	Src       string
	Priority  MsgPriority
	Options   map[string]string
}

func (*Meta) FormMessage

func (m *Meta) FormMessage(msg *Message)

type MsgPriority

type MsgPriority int32

const (
	MsgPriority_PRIORITY0 MsgPriority = 0
	MsgPriority_PRIORITY1 MsgPriority = 1
	MsgPriority_PRIORITY2 MsgPriority = 2
	MsgPriority_PRIORITY3 MsgPriority = 3
	MsgPriority_PRIORITY4 MsgPriority = 4
	MsgPriority_PRIORITY5 MsgPriority = 5
	MsgPriority_PRIORITY6 MsgPriority = 6
	MsgPriority_PRIORITY7 MsgPriority = 7
	MsgPriority_PRIORITY8 MsgPriority = 8
	MsgPriority_PRIORITY9 MsgPriority = 9
)

func (MsgPriority) EnumDescriptor

func (MsgPriority) EnumDescriptor() ([]byte, []int)

func (MsgPriority) String

func (x MsgPriority) String() string

type RpcMessage

type RpcMessage struct {
	MessageId string            `protobuf:"bytes,1,opt,name=MessageId" json:"MessageId,omitempty"`
	Code      uint32            `protobuf:"varint,2,opt,name=Code" json:"Code,omitempty"`
	Options   map[string]string `` /* 136-byte string literal not displayed */
	Body      []byte            `protobuf:"bytes,3,opt,name=Body,proto3" json:"Body,omitempty"`
}

func (*RpcMessage) Descriptor

func (*RpcMessage) Descriptor() ([]byte, []int)

func (*RpcMessage) GetBody

func (m *RpcMessage) GetBody() []byte

func (*RpcMessage) GetCode

func (m *RpcMessage) GetCode() uint32

func (*RpcMessage) GetMessageId

func (m *RpcMessage) GetMessageId() string

func (*RpcMessage) GetOptions

func (m *RpcMessage) GetOptions() map[string]string

func (*RpcMessage) ProtoMessage

func (*RpcMessage) ProtoMessage()

func (*RpcMessage) Reset

func (m *RpcMessage) Reset()

func (*RpcMessage) String

func (m *RpcMessage) String() string