message

Documentation

Index

• type Codec
  • func JsonCodec() Codec
• type ID
• type Message
• type Meta
  • func Json(msg interface{}) (Meta, error)
  • func MetaByID(id ID) (Meta, bool)
  • func MetaByMsg(msg interface{}) (Meta, bool)
  • func MetaByName(name string) (Meta, bool)
  • func MetaByType(typo reflect.Type) (Meta, bool)
  • func Register(msg interface{}, codec Codec) (Meta, error)
  • func RegisterEx(id ID, name string, msg interface{}, codec Codec) (Meta, error)

Types

type Codec

type Codec interface {
	Encode(msg interface{}) (raw []byte, err error)
	Decode(raw []byte, msg interface{}) (err error)
}

func JsonCodec

func JsonCodec() Codec

type ID

type ID uint32

type Message

type Message struct {
	Meta   Meta        // 消息元数据
	Msg    interface{} // 消息体
	Raw    []byte      // 消息体流
	Stream []byte      // 消息流
}

type Meta

type Meta interface {
	ID() ID
	Name() string
	Codec() Codec
	Encode(msg interface{}) (raw []byte, err error)
	Decode(raw []byte) (msg interface{}, err error)
}

func Json

func Json(msg interface{}) (Meta, error)

func MetaByID

func MetaByID(id ID) (Meta, bool)

func MetaByMsg

func MetaByMsg(msg interface{}) (Meta, bool)

func MetaByName

func MetaByName(name string) (Meta, bool)

func MetaByType

func MetaByType(typo reflect.Type) (Meta, bool)

func Register

func Register(msg interface{}, codec Codec) (Meta, error)

func RegisterEx

func RegisterEx(id ID, name string, msg interface{}, codec Codec) (Meta, error)