message

Documentation

Index

• Constants
• type Message
  • func (m *Message) JsonBytes() []byte
  • func (m *Message) JsonLoad(data []byte) error
  • func (z *Message) MarshalMsg(b []byte) (o []byte, err error)
  • func (m *Message) MsgpackBytes() []byte
  • func (m *Message) MsgpackLoad(data []byte) error
  • func (z *Message) Msgsize() (s int)
  • func (z *Message) UnmarshalMsg(bts []byte) (o []byte, err error)

Constants

const (
	// 0~20 corresponds to mqtt control package types
	MqttPublish = 3
	// 21~
	Reserved byte = iota + 21
	RaftJoin
	RaftApply
)

Types

type Message

type Message struct {
	Type            byte   `json:"type" msg:"type"`
	NodeID          string `json:"node-id" msg:"node-id"`
	ClientID        string `json:"client-id" msg:"client-id"`
	ProtocolVersion byte   `json:"protocol-version" msg:"protocol-version"`
	Payload         []byte `json:"payload" msg:"payload"`
}

func (*Message) JsonBytes

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

func (*Message) JsonLoad

func (m *Message) JsonLoad(data []byte) error

func (*Message) MarshalMsg

func (z *Message) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*Message) MsgpackBytes

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

func (*Message) MsgpackLoad

func (m *Message) MsgpackLoad(data []byte) error

func (*Message) Msgsize

func (z *Message) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Message) UnmarshalMsg

func (z *Message) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler