Documentation
¶
Overview ¶
Package gap Golaxy应用层协议（golaxy application protocol），适用于开发应用层通信消息，需要工作在GTP协议或MQ之上，支持消息判重，解决了幂等性问题。
- 可以实现消息（Msg）接口新增自定义消息。
- 支持可变类型（Variant），提供了一些常用的内置类型，也可以实现可变类型值（variant.Value）接口，新增自定义类型。
- 支持自己实现消息（Msg）接口或可变类型值（variant.Value）接口，扩展支持protobuf（Protocol Buffers）等消息结构。
- 支持消息判重，解决幂等性问题。
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrNotDeclared = errors.New("gap: msg not declared") // 消息未注册
)
Functions ¶
func Marshal ¶ added in v0.1.36
func Marshal[T Msg](msg T) (binaryutil.RecycleBytes, error)
Types ¶
type IMsgCreator ¶
type IMsgCreator interface {
// Declare 注册消息
Declare(msg Msg)
// Undeclare 取消注册消息
Undeclare(msgId MsgId)
// New 创建消息指针
New(msgId MsgId) (Msg, error)
}
IMsgCreator 消息对象构建器接口
type MsgForward ¶ added in v0.1.32
type MsgForward struct {
Transit string // 中转地址
Dst string // 目标地址
CorrId int64 // 关联Id，用于支持Future等异步模型
TransId MsgId // 传输消息Id
TransData []byte // 传输消息内容（引用）
}
MsgForward 转发
type MsgOneWayRPC ¶
type MsgOneWayRPC struct {
CallChain variant.CallChain // 调用链
Path string // 调用路径
Args variant.Array // 参数列表
}
MsgOneWayRPC 单程RPC请求
type MsgRPCReply ¶
type MsgRPCReply struct {
CorrId int64 // 关联Id，用于支持Future等异步模型
Rets variant.Array // 调用结果
Error variant.Error // 调用错误
}
MsgRPCReply RPC答复
type MsgRPCRequest ¶
type MsgRPCRequest struct {
CorrId int64 // 关联Id，用于支持Future等异步模型
CallChain variant.CallChain // 调用链
Path string // 调用路径
Args variant.Array // 参数列表
}
MsgRPCRequest RPC请求
type MsgRaw ¶ added in v0.1.32
MsgRaw 原始消息
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.