gap

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

type Msg interface {
	MsgReader
	MsgWriter
}

type MsgForward struct {
	Transit   string // 中转地址
	Dst       string // 目标地址
	CorrId    int64  // 关联Id，用于支持Future等异步模型
	TransId   MsgId  // 传输消息Id
	TransData []byte // 传输消息内容（引用）
}

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 MsgRaw struct {
	Id   MsgId  // 消息Id
	Data []byte // 消息内容（引用）
}

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

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