gap

package
v0.2.70 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 16, 2024 License: LGPL-2.1 Imports: 11 Imported by: 2

Documentation

Overview

Package gap Golaxy应用层协议（Golaxy Application Protocol），适用于开发应用层通信消息，需要工作在GTP协议或MQ之上，支持消息判重、自定义消息、自定义可变类型等特性。

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrGAP = errors.New("gap") // 消息协议错误
)
View Source 
var (
	ErrNotDeclared = fmt.Errorf("%w: msg not declared", ErrGAP) // 消息未注册
)

Functions

func Marshal added in v0.1.36 

func Marshal[T MsgReader](msg T) (ret binaryutil.RecycleBytes, err error)

Marshal 序列化

func Unmarshal added in v0.1.36 

func Unmarshal[T MsgWriter](msg T, data []byte) error

Unmarshal 反序列化

Types

type IMsgCreator 

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

IMsgCreator 消息对象构建器接口

func DefaultMsgCreator 

func DefaultMsgCreator() IMsgCreator

DefaultMsgCreator 默认消息对象构建器

func NewMsgCreator 

func NewMsgCreator() IMsgCreator

NewMsgCreator 创建消息对象构建器

type Msg 

type Msg interface {
	MsgReader
	MsgWriter
}

Msg 消息接口

type MsgForward added in v0.1.32 

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

MsgForward 转发

func (MsgForward) MsgId added in v0.1.32 

func (MsgForward) MsgId() MsgId

MsgId 消息Id

func (MsgForward) Read added in v0.1.32 

func (m MsgForward) Read(p []byte) (int, error)

Read implements io.Reader

func (MsgForward) Size added in v0.1.32 

func (m MsgForward) Size() int

Size 大小

func (*MsgForward) Write added in v0.1.32 

func (m *MsgForward) Write(p []byte) (int, error)

Write implements io.Writer

type MsgHead 

type MsgHead struct {
	Len   uint32 // 消息长度
	MsgId MsgId  // 消息Id
	Svc   string // 来源服务
	Src   string // 来源地址
	Seq   int64  // 序号
}

MsgHead 消息头

func (MsgHead) Read 

func (m MsgHead) Read(p []byte) (int, error)

Read implements io.Reader

func (MsgHead) Size 

func (m MsgHead) Size() int

Size 大小

func (*MsgHead) Write 

func (m *MsgHead) Write(p []byte) (int, error)

Write implements io.Writer

type MsgId 

type MsgId = uint32

MsgId 消息Id 

const (
	MsgId_None        MsgId = iota // 未设置
	MsgId_RPC_Request              // RPC请求
	MsgId_RPC_Reply                // RPC答复
	MsgId_OnewayRPC                // 单程RPC请求
	MsgId_Forward                  // 转发
	MsgId_Customize   = 32         // 自定义消息起点
)

func MakeMsgId added in v0.1.57 

func MakeMsgId(msg Msg) MsgId

MakeMsgId 创建类型Id

func MakeMsgIdT added in v0.1.57 

func MakeMsgIdT[T any]() MsgId

MakeMsgIdT 创建类型Id

type MsgOnewayRPC added in v0.2.38 

type MsgOnewayRPC struct {
	CallChain variant.CallChain // 调用链
	Path      []byte            // 调用路径
	Args      variant.Array     // 参数列表
}

MsgOnewayRPC 单程RPC请求

func (MsgOnewayRPC) MsgId added in v0.2.38 

func (MsgOnewayRPC) MsgId() MsgId

MsgId 消息Id

func (MsgOnewayRPC) Read added in v0.2.38 

func (m MsgOnewayRPC) Read(p []byte) (int, error)

Read implements io.Reader

func (MsgOnewayRPC) Size added in v0.2.38 

func (m MsgOnewayRPC) Size() int

Size 大小

func (*MsgOnewayRPC) Write added in v0.2.38 

func (m *MsgOnewayRPC) Write(p []byte) (int, error)

Write implements io.Writer

type MsgPacket 

type MsgPacket struct {
	Head MsgHead   // 消息头
	Msg  MsgReader // 消息
}

MsgPacket 消息包

func (MsgPacket) Read 

func (mp MsgPacket) Read(p []byte) (int, error)

Read implements io.Reader

func (MsgPacket) Size 

func (mp MsgPacket) Size() int

Size 大小

type MsgRPCReply 

type MsgRPCReply struct {
	CorrId int64         // 关联Id，用于支持Future等异步模型
	Rets   variant.Array // 调用结果
	Error  variant.Error // 调用错误
}

MsgRPCReply RPC答复

func (MsgRPCReply) MsgId 

func (MsgRPCReply) MsgId() MsgId

MsgId 消息Id

func (MsgRPCReply) Read 

func (m MsgRPCReply) Read(p []byte) (int, error)

Read implements io.Reader

func (MsgRPCReply) Size 

func (m MsgRPCReply) Size() int

Size 大小

func (*MsgRPCReply) Write 

func (m *MsgRPCReply) Write(p []byte) (int, error)

Write implements io.Writer

type MsgRPCRequest 

type MsgRPCRequest struct {
	CorrId    int64             // 关联Id，用于支持Future等异步模型
	CallChain variant.CallChain // 调用链
	Path      []byte            // 调用路径
	Args      variant.Array     // 参数列表
}

MsgRPCRequest RPC请求

func (MsgRPCRequest) MsgId 

func (MsgRPCRequest) MsgId() MsgId

MsgId 消息Id

func (MsgRPCRequest) Read 

func (m MsgRPCRequest) Read(p []byte) (int, error)

Read implements io.Reader

func (MsgRPCRequest) Size 

func (m MsgRPCRequest) Size() int

Size 大小

func (*MsgRPCRequest) Write 

func (m *MsgRPCRequest) Write(p []byte) (int, error)

Write implements io.Writer

type MsgReader 

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

MsgReader 读取消息

type MsgWriter 

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

MsgWriter 写入消息

type SerializedMsg added in v0.2.17 

type SerializedMsg struct {
	Id   MsgId  // 消息Id
	Data []byte // 消息内容（引用）
}

SerializedMsg 已序列化消息

func (*SerializedMsg) MsgId added in v0.2.17 

func (m *SerializedMsg) MsgId() MsgId

MsgId 消息Id

func (*SerializedMsg) Read added in v0.2.17 

func (m *SerializedMsg) Read(p []byte) (int, error)

Read implements io.Reader

func (*SerializedMsg) Size added in v0.2.17 

func (m *SerializedMsg) Size() int

Size 大小

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.