msg

Documentation

Index

• Constants
• func NewLessMsgPayloadCodec(c codec.PayloadCodec) codec.PayloadCodec
• type LessMessage
  • func NewMessage(msgType uint16, body string) *LessMessage
• type LessMessagePayloadCodec
  • func (lc *LessMessagePayloadCodec) Marshal(message interface{}, writer io.Writer) (err error)
  • func (*LessMessagePayloadCodec) Name() string
  • func (lc *LessMessagePayloadCodec) UnMarshal(reader io.Reader) (message interface{}, err error)

Constants

const (
	MAGICLength = 4
	TypeLength  = 2
)

const (
	Call = iota + 1
	Reply
	Oneway
)

const (
	MAGIC = 76698383
)

Functions

func NewLessMsgPayloadCodec

func NewLessMsgPayloadCodec(c codec.PayloadCodec) codec.PayloadCodec

Types

type LessMessage

type LessMessage struct {
	Magic   uint32 `json:"magic"`
	MsgType uint16 `json:"msg_type"`
	Body    []byte `json:"body"`
}

func NewMessage

func NewMessage(msgType uint16, body string) *LessMessage

type LessMessagePayloadCodec

type LessMessagePayloadCodec struct {
	// contains filtered or unexported fields
}

func (*LessMessagePayloadCodec) Marshal

func (lc *LessMessagePayloadCodec) Marshal(message interface{}, writer io.Writer) (err error)

func (*LessMessagePayloadCodec) Name

func (*LessMessagePayloadCodec) Name() string

func (*LessMessagePayloadCodec) UnMarshal

func (lc *LessMessagePayloadCodec) UnMarshal(reader io.Reader) (message interface{}, err error)