message

type Body interface {
	// BodyCodec 消息体编码格式
	BodyCodec() byte
	// SetBodyCodec 设置消息体编码格式
	SetBodyCodec(bodyCodec byte)
	// Body 返回消息体内容
	Body() interface{}
	// SetBody 设置消息体内容
	SetBody(body interface{})
	// SetNewBody 设置一个函数，该函数根据消息头生成一个新的消息体
	SetNewBody(NewBodyFunc)
	// MarshalBody 编码消息体
	MarshalBody() ([]byte, error)
	// UnmarshalBody 解码消息体
	UnmarshalBody(bodyBytes []byte) error
}

type Header interface {
	// Seq 序列号
	Seq() int32
	// SetSeq 设置序列号
	SetSeq(int32)
	// MType 消息类型 有三种：CALL,REPLY,PUSH
	MType() byte
	// SetMType 设置消息类型 有三种：CALL,REPLY,PUSH
	SetMType(byte)
	// ServiceMethod 请求的服务方法名称 长度必须小于255字节 max <= 255
	ServiceMethod() string
	// SetServiceMethod 设置请求的服务方法名
	SetServiceMethod(string)
	// StatusOK 判断当前消息是否是 OK
	StatusOK() bool
	// Status 返回当前消息的状态，包含code，msg，cause或者stack，
	//如果消息是nil或者autoInit传入了true，则返回一个 code为OK的新对象
	Status(autoInit ...bool) *status.Status
	// SetStatus 设置消息的状态
	SetStatus(*status.Status)
	// Meta 获取消息的元数据，数据在传输的时候是使用了序列化串，最大长度为 max len ≤ 65535
	Meta() *gmap.Map
}

type Message interface {
	Reset(settings ...MsgSetting) Message
	Header
	Body
	// PipeTFilter 针对传入的数据做
	PipeTFilter() *tfilter.PipeTFilter

	// Size 消息长度
	Size() uint32
	// SetSize 设置消息长度，如果长度超长了，则返回错误
	SetSize(size uint32) error
	// Context 返回消息的上下文对象
	Context() context.Context
	// String 把消息转换成可打印的字符串
	String() string
	// AsHeader 把消息转换成header接口
	AsHeader() Header
	// AsBody 把消息转换成body接口
	AsBody() Body
	// contains filtered or unexported methods
}

type MsgSetting func(Message)

type NewBodyFunc func(Header) interface{}