protocol

type GlobalIndexType uint32 //global index type

type NoRpcPackage struct {
	Header *RpcMsgHeader
	Buffer []byte
}

type Protocol interface {
	ReadHeader(pkg []byte, header *RpcMsgHeader) bool
	ParsePlatoHeader(pkg []byte, header interface{}) bool
	ParseReqMsg(pkg []byte, header *RpcCallHeader) bool
	ParseProxyReqMsg([]byte, *RpcProxyCallHeader) bool
	ParseRespMsg(pkg []byte, header *RpcCallRetHeader) bool
	ParseProxyRespMsg([]byte, *RpcProxyCallRetHeader) bool
	ParseSubMsg([]byte, *RpcSubHeader) bool
	ParsePubMsg([]byte, *RpcPubHeader) bool
	ParseCancelMsg([]byte, *RpcCancelSubHeader) bool
	PackPlatoMsg(interface{}, []byte, int) ([]byte, int)
	PackRespMsg(resp *ResponsePackage) ([]byte, int)
	PackReqMsg(req *RequestPackage) ([]byte, int)
	PackProxyReqMsg(req *ProxyRequestPackage) ([]byte, int)
	PackProxyRespMsg(resp *ProxyRespPackage) ([]byte, int)
	PackSubMsg(header *RpcSubPackage) ([]byte, int)
	PackPubMsg(header *RpcPubPackage) ([]byte, int)
	PackCancelMsg(header *RpcCancelPackage) ([]byte, int)
}

type ProxyRequestPackage struct {
	Header *RpcProxyCallHeader
	Buffer []byte
}

type ProxyRespPackage struct {
	Header *RpcProxyCallRetHeader
	Buffer []byte
}

type RequestPackage struct {
	Header *RpcCallHeader //请求协议头
	Buffer []byte         //协议提二进制数据， 可以对接pb 或者自己的结构体
}

type ResponsePackage struct {
	Header *RpcCallRetHeader //回包结构体
	Buffer []byte            //协议体二进制数据， 可以对接pb 或者自己的结构体
}

type RpcCallHeader struct {
	RpcMsgHeader
	ServiceUUID uint64 //服务UUID
	ServerID    uint32 //服务器实例ID
	CallID      uint32 //代理调用id
	MethodID    uint32 //方法id
}

type RpcCallRetHeader struct {
	RpcMsgHeader
	ServerID  uint32
	CallID    uint32
	ErrorCode uint32
}

type RpcCancelPackage struct {
	Header *RpcCancelSubHeader
	Buffer []byte
}

type RpcCancelSubHeader struct {
	RpcMsgHeader
	SubId [32]byte //订阅id
}

type RpcIdentityNotifyHeader struct {
	RpcMsgHeader
	IdentityID [32]byte // 身份标识ID，唯一ID，启动时候生成
}

type RpcIdentityNotifyPackage struct {
	Header *RpcIdentityNotifyHeader
	Buffer []byte
}

type RpcLoggedOutHeader struct {
	RpcMsgHeader
	GlobalIndexId GlobalIndexType
}

type RpcLoggedOutPackage struct {
	Header *RpcLoggedOutHeader
}

type RpcMsgHeader struct {
	Length uint32 //整个包长，包含头
	Type   uint32 //调用 返回 非rpc 请求
}

type RpcPingHeader struct {
	RpcMsgHeader
	PingId uint64 //ping id, 客户端第一次连接网关时候，赋值一次，可以用于定时器轮询
}

type RpcPingPackage struct {
	Header *RpcPingHeader
}

type RpcPongHeader struct {
	RpcMsgHeader
	PingId uint64 //ping id, 客户端第一次连接网关时候，赋值一次，可以用于定时器轮询
}

type RpcPongPackage struct {
	Header *RpcPongHeader
}

type RpcProxyCallHeader struct {
	RpcMsgHeader
	ServiceUUID uint64          //服务UUID
	ServerID    uint32          //服务器实例ID
	CallID      uint32          //代理调用id
	MethodID    uint32          //方法id
	GlobalIndex GlobalIndexType //代理节点标识
	OneWay      uint16          // 是否是one way节点
}

type RpcProxyCallRetHeader struct {
	RpcMsgHeader
	ServerID    uint32          //服务实例id
	CallID      uint32          //调用id对端赋值
	ErrorCode   uint32          //错误代码
	GlobalIndex GlobalIndexType //代理节点标识
}

type RpcPubHeader struct {
	RpcMsgHeader
	SubId    [32]byte //订阅id
	ProxyId  uint32   //代理id
	ValueLen uint32   //附带数据长度
}

type RpcPubPackage struct {
	Header *RpcPubHeader
	Buffer []byte
}

type RpcSubHeader struct {
	RpcMsgHeader
	SubId       [32]byte //订阅id
	ProxyId     uint32   //代理id
	ServiceUUID uint64   //服务uid
	ServiceID   uint32   //服务实例id
	NameLen     uint32   //事件名称长度
	DataLen     uint32   //数据长度
}

type RpcSubPackage struct {
	Header *RpcSubHeader
	Buffer []byte
}

type RpcTimeoutHeader struct {
	RpcMsgHeader
	GlobalIndexId GlobalIndexType // 网关唯一 id
}

type RpcTimeoutPackage struct {
	Header *RpcTimeoutHeader
}