gap

type IMsgCreator interface {
	// Register 注册消息
	Register(msg Msg)
	// Deregister 取消注册消息
	Deregister(msgId MsgId)
	// New 创建消息指针
	New(msgId MsgId) (Msg, error)
}

type Msg interface {
	MsgReader
	MsgWriter
}

type MsgHead struct {
	Len   uint32 // 消息长度
	MsgId MsgId  // 消息Id
	Src   string // 来源地址
	Seq   int64  // 序号
}

type MsgId = uint32

type MsgOneWayRPC struct {
	Path string        // 调用路径
	Args variant.Array // 参数列表
}

type MsgPacket struct {
	Head MsgHead // 消息头
	Msg  Msg     // 消息
}

type MsgRPCReply struct {
	CorrId int64         // 关联Id，用于支持Future等异步模型
	Rets   variant.Array // 调用结果
	Error  variant.Error // 调用错误
}

type MsgRPCRequest struct {
	CorrId int64         // 关联Id，用于支持Future等异步模型
	Path   string        // 调用路径
	Args   variant.Array // 参数列表
}

type MsgReader interface {
	io.Reader
	// Size 大小
	Size() int
	// MsgId 消息Id
	MsgId() MsgId
}

type MsgWriter interface {
	io.Writer
	// Size 大小
	Size() int
	// MsgId 消息Id
	MsgId() MsgId
}