packet

Documentation

Index

• func BodyToBytes(body interface{}) []byte
• func BodyToFloat(body interface{}) float64
• func BodyToInt(body interface{}) int64
• func BodyToString(body interface{}) string
• func Conv2Body(val interface{}) interface{}
• func MessageToString(msg proto.Message) string
• type FakePacket
  • func MakeFake() *FakePacket
  • func (m *FakePacket) Clone() fatchoy.IPacket
  • func (m *FakePacket) Refuse(errno int32) error
  • func (m *FakePacket) Reply(ack proto.Message) error
  • func (m *FakePacket) ReplyAny(body interface{}) error
• type PacketBase
  • func (m *PacketBase) AddRefers(v ...fatchoy.NodeID)
  • func (m *PacketBase) Body() interface{}
  • func (m *PacketBase) BodyToString() string
  • func (m *PacketBase) Command() string
  • func (m *PacketBase) DecodeTo(msg proto.Message) error
  • func (m *PacketBase) EncodeToBytes() []byte
  • func (m *PacketBase) Endpoint() fatchoy.MessageEndpoint
  • func (m *PacketBase) Errno() int32
  • func (m *PacketBase) Flags() fatchoy.PacketFlag
  • func (m *PacketBase) MsgID() int32
  • func (m *PacketBase) Node() fatchoy.NodeID
  • func (m *PacketBase) Refers() []fatchoy.NodeID
  • func (m *PacketBase) Reset()
  • func (m *PacketBase) Seq() uint32
  • func (m *PacketBase) SetBody(val interface{})
  • func (m *PacketBase) SetCommand(v string)
  • func (m *PacketBase) SetEndpoint(endpoint fatchoy.MessageEndpoint)
  • func (m *PacketBase) SetErrno(ec int32)
  • func (m *PacketBase) SetFlags(v fatchoy.PacketFlag)
  • func (m *PacketBase) SetMsgID(v int32)
  • func (m *PacketBase) SetNode(n fatchoy.NodeID)
  • func (m *PacketBase) SetRefers(v []fatchoy.NodeID)
  • func (m *PacketBase) SetSeq(v uint32)
  • func (m PacketBase) String() string

Functions

func BodyToBytes

func BodyToBytes(body interface{}) []byte

将body转为[]byte，用于网络传输

func BodyToFloat

func BodyToFloat(body interface{}) float64

将body转为float4

func BodyToInt

func BodyToInt(body interface{}) int64

将body转为int64

func BodyToString

func BodyToString(body interface{}) string

将body转为string

func Conv2Body

func Conv2Body(val interface{}) interface{}

func MessageToString

func MessageToString(msg proto.Message) string

Types

type FakePacket

type FakePacket struct {
	PacketBase
}

func MakeFake

func MakeFake() *FakePacket

func (*FakePacket) Clone

func (m *FakePacket) Clone() fatchoy.IPacket

func (*FakePacket) Refuse

func (m *FakePacket) Refuse(errno int32) error

返回一个错误码消息

func (*FakePacket) Reply

func (m *FakePacket) Reply(ack proto.Message) error

响应proto消息内容

func (*FakePacket) ReplyAny

func (m *FakePacket) ReplyAny(body interface{}) error

body的类型仅支持int64/float64/string/bytes/proto.Message

type PacketBase

type PacketBase struct {
	MsgId   int32              `json:"msg"`               //
	Seqno   uint32             `json:"seq"`               // 序列号
	Flag    fatchoy.PacketFlag `json:"flg,omitempty"`     // 标志位
	Reserve uint16             `json:"reserve,omitempty"` //
	Node_   fatchoy.NodeID     `json:"node,omitempty"`    // 源/目标节点
	Cmd     string             `json:"cmd"`               // 协议ID
	Refer   []fatchoy.NodeID   `json:"ref,omitempty"`     // 组播session列表
	Body_   interface{}        `json:"body,omitempty"`    // 消息内容，int32/int64/float64/string/bytes/proto.Message
	// contains filtered or unexported fields
}

Packet表示一个应用层消息

func (*PacketBase) AddRefers

func (m *PacketBase) AddRefers(v ...fatchoy.NodeID)

func (*PacketBase) Body

func (m *PacketBase) Body() interface{}

func (*PacketBase) BodyToString

func (m *PacketBase) BodyToString() string

func (*PacketBase) Command

func (m *PacketBase) Command() string

func (*PacketBase) DecodeTo

func (m *PacketBase) DecodeTo(msg proto.Message) error

func (*PacketBase) EncodeToBytes

func (m *PacketBase) EncodeToBytes() []byte

func (*PacketBase) Endpoint

func (m *PacketBase) Endpoint() fatchoy.MessageEndpoint

func (*PacketBase) Errno

func (m *PacketBase) Errno() int32

func (*PacketBase) Flags

func (m *PacketBase) Flags() fatchoy.PacketFlag

func (*PacketBase) MsgID

func (m *PacketBase) MsgID() int32

func (*PacketBase) Node

func (m *PacketBase) Node() fatchoy.NodeID

func (*PacketBase) Refers

func (m *PacketBase) Refers() []fatchoy.NodeID

func (*PacketBase) Reset

func (m *PacketBase) Reset()

func (*PacketBase) Seq

func (m *PacketBase) Seq() uint32

func (*PacketBase) SetBody

func (m *PacketBase) SetBody(val interface{})

func (*PacketBase) SetCommand

func (m *PacketBase) SetCommand(v string)

func (*PacketBase) SetEndpoint

func (m *PacketBase) SetEndpoint(endpoint fatchoy.MessageEndpoint)

func (*PacketBase) SetErrno

func (m *PacketBase) SetErrno(ec int32)

如果消息表示一个错误码，设置PacketFlagError标记

func (*PacketBase) SetFlags

func (m *PacketBase) SetFlags(v fatchoy.PacketFlag)

func (*PacketBase) SetMsgID

func (m *PacketBase) SetMsgID(v int32)

func (*PacketBase) SetNode

func (m *PacketBase) SetNode(n fatchoy.NodeID)

func (*PacketBase) SetRefers

func (m *PacketBase) SetRefers(v []fatchoy.NodeID)

func (*PacketBase) SetSeq

func (m *PacketBase) SetSeq(v uint32)

func (PacketBase) String

func (m PacketBase) String() string