gap

type IMsgCreator interface {
	// Declare 注册消息指针的具体类型；重复 ID 会 panic。
	Declare(msg Msg)
	// New 创建指定消息 ID 对应的新消息指针。
	New(msgId MsgId) (Msg, error)
}

type Msg interface {
	ReadableMsg
	io.Writer
}

type MsgForward struct {
	Src       Origin // 原始消息来源。
	Dst       string // 目标通信地址。
	CorrId    int64  // 请求关联 ID；无需关联时为零。
	TransId   MsgId  // 被转发消息的类型 ID。
	TransData []byte // 被转发消息的已编码内容；解码时引用输入缓冲区。
}

type MsgHead struct {
	Len   uint32 // 完整消息包的字节数。
	MsgId MsgId  // 消息类型 ID。
	Src   Origin // 消息来源。
	Seq   int64  // 发送方分配的序号。
}

type MsgId = uint32

type MsgOnewayRPC struct {
	CallChain variant.CallChain // 调用来源链。
	Path      []byte            // 已编码调用路径；解码时引用输入缓冲区。
	Args      variant.Array     // 调用参数。
}

type MsgPacket struct {
	Head MsgHead     // 消息头。
	Body ReadableMsg // 消息体；nil 表示只有消息头。
}

type MsgRPCReply struct {
	CorrId int64         // 对应请求的关联 ID。
	Rets   variant.Array // 调用返回值。
	Error  variant.Error // 调用错误；OK 为 true 时表示成功。
}

type MsgRPCRequest struct {
	CorrId    int64             // 用于匹配响应与 Future 的关联 ID。
	CallChain variant.CallChain // 调用来源链。
	Path      []byte            // 已编码调用路径；解码时引用输入缓冲区。
	Args      variant.Array     // 调用参数。
}

type Origin struct {
	Svc       string // 来源服务名。
	Addr      string // 来源通信地址。
	Timestamp int64  // 来源 Unix 毫秒时间戳。
}

type ReadableMsg interface {
	io.Reader
	// Size 返回消息编码后的字节数。
	Size() int
	// MsgId 返回消息类型 ID。
	MsgId() MsgId
}

type SerializedMsg struct {
	Id   MsgId  // 消息类型 ID。
	Data []byte // 已编码消息体；由调用方维护其生命周期。
}