protocol

package
v2.4.3 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DecodeBindReq 

func DecodeBindReq(data []byte) (seq uint64, cid, uid int64, err error)

DecodeBindReq 解码绑定请求 协议：size + header + route + seq + cid + uid

func DecodeBindRes 

func DecodeBindRes(data []byte) (code uint16, err error)

DecodeBindRes 解码绑定响应 协议：size + header + route + seq + code

func DecodeBroadcastReq 

func DecodeBroadcastReq(data []byte) (seq uint64, kind session.Kind, message []byte, err error)

DecodeBroadcastReq 解码广播请求 协议：size + header + route + seq + session kind + <message packet>

func DecodeBroadcastRes 

func DecodeBroadcastRes(data []byte) (code uint16, total uint64, err error)

DecodeBroadcastRes 解码广播响应 协议：size + header + route + seq + code + [total]

func DecodeDeliverReq 

func DecodeDeliverReq(data []byte) (seq uint64, cid int64, uid int64, message []byte, err error)

DecodeDeliverReq 解码投递消息请求

func DecodeDeliverRes 

func DecodeDeliverRes(data []byte) (code uint16, err error)

DecodeDeliverRes 解码投递消息响应 协议：size + header + route + seq + code

func DecodeDisconnectReq 

func DecodeDisconnectReq(data []byte) (seq uint64, kind session.Kind, target int64, force bool, err error)

DecodeDisconnectReq 解码端连请求 协议：size + header + route + seq + session kind + target + force

func DecodeDisconnectRes 

func DecodeDisconnectRes(data []byte) (code uint16, err error)

DecodeDisconnectRes 解码断连响应 协议：size + header + route + seq + code

func DecodeGetIPReq 

func DecodeGetIPReq(data []byte) (seq uint64, kind session.Kind, target int64, err error)

DecodeGetIPReq 解码获取IP请求 协议：size + header + route + seq + session kind + target

func DecodeGetIPRes 

func DecodeGetIPRes(data []byte) (code uint16, ip string, err error)

func DecodeGetStateReq 

func DecodeGetStateReq(data []byte) (seq uint64, err error)

DecodeGetStateReq 解码获取状态请求 协议：size + header + route + seq

func DecodeGetStateRes 

func DecodeGetStateRes(data []byte) (code uint16, state cluster.State, err error)

DecodeGetStateRes 解码获取状态响应 协议：size + header + route + seq + code + cluster state

func DecodeHandshakeReq 

func DecodeHandshakeReq(data []byte) (seq uint64, insKind cluster.Kind, insID string, err error)

DecodeHandshakeReq 解码握手请求 协议：size + header + route + seq + ins kind + ins id

func DecodeHandshakeRes 

func DecodeHandshakeRes(data []byte) (code uint16, err error)

DecodeHandshakeRes 解码握手响应 协议：size + header + route + seq + code

func DecodeIsOnlineReq 

func DecodeIsOnlineReq(data []byte) (seq uint64, kind session.Kind, target int64, err error)

DecodeIsOnlineReq 解码检测用户是否在线请求 协议：size + header + route + seq + session kind + target

func DecodeIsOnlineRes 

func DecodeIsOnlineRes(data []byte) (code uint16, isOnline bool, err error)

DecodeIsOnlineRes 解码检测用户是否在线响应 协议：size + header + route + seq + code + online state

func DecodeMulticastReq 

func DecodeMulticastReq(data []byte) (seq uint64, kind session.Kind, targets []int64, message []byte, err error)

DecodeMulticastReq 解码组播请求 协议：size + header + route + seq + session kind + count + targets + <message packet>

func DecodeMulticastRes 

func DecodeMulticastRes(data []byte) (code uint16, total uint64, err error)

DecodeMulticastRes 解码组播响应 协议：size + header + route + seq + code + [total]

func DecodePublishReq added in v2.3.0 

func DecodePublishReq(data []byte) (seq uint64, channel string, message []byte, err error)

DecodePublishReq 解码发布频道消息请求 协议：size + header + route + seq + channel len + channel + <message packet>

func DecodePublishRes added in v2.3.0 

func DecodePublishRes(data []byte) (total uint64, err error)

DecodeMulticastRes 解码组播响应 协议：size + header + route + seq + code + [total]

func DecodePushReq 

func DecodePushReq(data []byte) (seq uint64, kind session.Kind, target int64, message []byte, err error)

DecodePushReq 解码推送消息 协议：size + header + route + seq + session kind + target + <message packet>

func DecodePushRes 

func DecodePushRes(data []byte) (code uint16, err error)

DecodePushRes 解码推送响应 协议：size + header + route + seq + code

func DecodeSetStateReq 

func DecodeSetStateReq(data []byte) (seq uint64, state cluster.State, err error)

DecodeSetStateReq 解码设置状态请求 协议：size + header + route + seq + cluster state

func DecodeSetStateRes 

func DecodeSetStateRes(data []byte) (code uint16, err error)

DecodeSetStateRes 解码绑定响应 协议：size + header + route + seq + code

func DecodeStatReq 

func DecodeStatReq(data []byte) (seq uint64, kind session.Kind, err error)

DecodeStatReq 解码统计在线人数请求 协议：size + header + route + seq + session kind

func DecodeStatRes 

func DecodeStatRes(data []byte) (code uint16, total uint64, err error)

DecodeStatRes 解码统计在线人数响应 协议：size + header + route + seq + code + [total]

func DecodeSubscribeReq added in v2.3.0 

func DecodeSubscribeReq(data []byte) (seq uint64, kind session.Kind, targets []int64, channel string, err error)

DecodeSubscribeReq 解码订阅频道请求 协议：size + header + route + seq + session kind + count + targets + channel

func DecodeSubscribeRes added in v2.3.0 

func DecodeSubscribeRes(data []byte) (code uint16, err error)

DecodeSubscribeRes 解码订阅频道响应 协议：size + header + route + seq + code

func DecodeTriggerReq 

func DecodeTriggerReq(data []byte) (seq uint64, event cluster.Event, cid int64, uid int64, err error)

DecodeTriggerReq 解码触发事件请求 协议：size + header + route + seq + event + cid + [uid]

func DecodeTriggerRes 

func DecodeTriggerRes(data []byte) (code uint16, err error)

DecodeTriggerRes 解码触发事件响应 协议：size + header + route + seq + code

func DecodeUnbindReq 

func DecodeUnbindReq(data []byte) (seq uint64, uid int64, err error)

DecodeUnbindReq 解码解绑请求 协议：size + header + route + seq + uid

func DecodeUnbindRes 

func DecodeUnbindRes(data []byte) (code uint16, err error)

DecodeUnbindRes 解码解绑响应 协议：size + header + route + seq + code

func DecodeUnsubscribeReq added in v2.3.0 

func DecodeUnsubscribeReq(data []byte) (seq uint64, kind session.Kind, targets []int64, channel string, err error)

DecodeUnsubscribeReq 解码取消订阅频道请求 协议：size + header + route + seq + session kind + count + targets + channel

func DecodeUnsubscribeRes added in v2.3.0 

func DecodeUnsubscribeRes(data []byte) (code uint16, err error)

DecodeUnsubscribeRes 解码取消订阅频道响应 协议：size + header + route + seq + code

func EncodeBindReq 

func EncodeBindReq(seq uint64, cid, uid int64) *buffer.NocopyBuffer

EncodeBindReq 编码绑定请求 协议：size + header + route + seq + cid + uid

func EncodeBindRes 

func EncodeBindRes(seq uint64, code uint16) *buffer.NocopyBuffer

EncodeBindRes 编码绑定响应 协议：size + header + route + seq + code

func EncodeBroadcastReq 

func EncodeBroadcastReq(seq uint64, kind session.Kind, message buffer.Buffer) *buffer.NocopyBuffer

EncodeBroadcastReq 编码广播请求 协议：size + header + route + seq + session kind + <message packet>

func EncodeBroadcastRes 

func EncodeBroadcastRes(seq uint64, code uint16, total ...uint64) *buffer.NocopyBuffer

EncodeBroadcastRes 编码广播响应 协议：size + header + route + seq + code + [total]

func EncodeDeliverReq 

func EncodeDeliverReq(seq uint64, cid int64, uid int64, buf buffer.Buffer) *buffer.NocopyBuffer

EncodeDeliverReq 编码投递消息请求 协议：size + header + route + seq + cid + uid + <message packet>

func EncodeDeliverRes 

func EncodeDeliverRes(seq uint64, code uint16) *buffer.NocopyBuffer

EncodeDeliverRes 编码投递消息响应 协议：size + header + route + seq + code

func EncodeDisconnectReq 

func EncodeDisconnectReq(seq uint64, kind session.Kind, target int64, force bool) *buffer.NocopyBuffer

EncodeDisconnectReq 编码断连请求 协议：size + header + route + seq + session kind + target + force

func EncodeDisconnectRes 

func EncodeDisconnectRes(seq uint64, code uint16) *buffer.NocopyBuffer

EncodeDisconnectRes 编码断连响应 协议：size + header + route + seq + code

func EncodeGetIPReq 

func EncodeGetIPReq(seq uint64, kind session.Kind, target int64) *buffer.NocopyBuffer

EncodeGetIPReq 编码获取IP请求 协议：size + header + route + seq + session kind + target

func EncodeGetIPRes 

func EncodeGetIPRes(seq uint64, code uint16, ip ...string) *buffer.NocopyBuffer

EncodeGetIPRes 编码获取IP响应 协议：size + header + route + seq + code + [ip]

func EncodeGetStateReq 

func EncodeGetStateReq(seq uint64) *buffer.NocopyBuffer

EncodeGetStateReq 编码获取状态请求 协议：size + header + route + seq

func EncodeGetStateRes 

func EncodeGetStateRes(seq uint64, code uint16, state cluster.State) *buffer.NocopyBuffer

EncodeGetStateRes 编码获取状态响应 协议：size + header + route + seq + code + cluster state

func EncodeHandshakeReq 

func EncodeHandshakeReq(seq uint64, insKind cluster.Kind, insID string) *buffer.NocopyBuffer

EncodeHandshakeReq 编码握手请求 协议：size + header + route + seq + ins kind + ins id

func EncodeHandshakeRes 

func EncodeHandshakeRes(seq uint64, code uint16) *buffer.NocopyBuffer

EncodeHandshakeRes 编码握手响应 协议：size + header + route + seq + code

func EncodeIsOnlineReq 

func EncodeIsOnlineReq(seq uint64, kind session.Kind, target int64) *buffer.NocopyBuffer

EncodeIsOnlineReq 编码检测用户是否在线请求 协议：size + header + route + seq + session kind + target

func EncodeIsOnlineRes 

func EncodeIsOnlineRes(seq uint64, code uint16, isOnline bool) *buffer.NocopyBuffer

EncodeIsOnlineRes 编码检测用户是否在线响应 协议：size + header + route + seq + code + online state

func EncodeMulticastReq 

func EncodeMulticastReq(seq uint64, kind session.Kind, targets []int64, message buffer.Buffer) *buffer.NocopyBuffer

EncodeMulticastReq 编码组播请求（最多组播65535个对象） 协议：size + header + route + seq + session kind + count + targets + <message packet>

func EncodeMulticastRes 

func EncodeMulticastRes(seq uint64, code uint16, total ...uint64) *buffer.NocopyBuffer

EncodeMulticastRes 编码组播响应 协议：size + header + route + seq + code + [total]

func EncodePublishReq added in v2.3.0 

func EncodePublishReq(seq uint64, channel string, message buffer.Buffer) *buffer.NocopyBuffer

EncodePublishReq 编码发布频道消息请求 协议：size + header + route + seq + channel len + channel + <message packet>

func EncodePublishRes added in v2.3.0 

func EncodePublishRes(seq uint64, total uint64) *buffer.NocopyBuffer

EncodePublishRes 编码发布频道消息响应 协议：size + header + route + seq + total

func EncodePushReq 

func EncodePushReq(seq uint64, kind session.Kind, target int64, message buffer.Buffer) *buffer.NocopyBuffer

EncodePushReq 编码推送请求 协议：size + header + route + seq + session kind + target + <message packet>

func EncodePushRes 

func EncodePushRes(seq uint64, code uint16) *buffer.NocopyBuffer

EncodePushRes 编码推送响应 协议：size + header + route + seq + code

func EncodeSetStateReq 

func EncodeSetStateReq(seq uint64, state cluster.State) *buffer.NocopyBuffer

EncodeSetStateReq 编码设置状态请求 协议：size + header + route + seq + cluster state

func EncodeSetStateRes 

func EncodeSetStateRes(seq uint64, code uint16) *buffer.NocopyBuffer

EncodeSetStateRes 编码设置状态响应 协议：size + header + route + seq + code

func EncodeStatReq 

func EncodeStatReq(seq uint64, kind session.Kind) *buffer.NocopyBuffer

EncodeStatReq 编码统计在线人数请求 协议：size + header + route + seq + session kind

func EncodeStatRes 

func EncodeStatRes(seq uint64, code uint16, total ...uint64) *buffer.NocopyBuffer

EncodeStatRes 编码统计在线人数响应 协议：size + header + route + seq + code + [total]

func EncodeSubscribeReq added in v2.3.0 

func EncodeSubscribeReq(seq uint64, kind session.Kind, targets []int64, channel string) *buffer.NocopyBuffer

EncodeSubscribeReq 编码订阅频道请求（单次最多订阅65535个对象） 协议：size + header + route + seq + session kind + count + targets + channel

func EncodeSubscribeRes added in v2.3.0 

func EncodeSubscribeRes(seq uint64, code uint16) *buffer.NocopyBuffer

EncodeSubscribeRes 编码订阅频道响应 协议：size + header + route + seq + code

func EncodeTriggerReq 

func EncodeTriggerReq(seq uint64, event cluster.Event, cid int64, uid ...int64) *buffer.NocopyBuffer

EncodeTriggerReq 编码触发事件请求 协议：size + header + route + seq + event + cid + [uid]

func EncodeTriggerRes 

func EncodeTriggerRes(seq uint64, code uint16) *buffer.NocopyBuffer

EncodeTriggerRes 编码触发事件响应 协议：size + header + route + seq + code

func EncodeUnbindReq 

func EncodeUnbindReq(seq uint64, uid int64) *buffer.NocopyBuffer

EncodeUnbindReq 编码解绑请求 协议：size + header + route + seq + uid

func EncodeUnbindRes 

func EncodeUnbindRes(seq uint64, code uint16) *buffer.NocopyBuffer

EncodeUnbindRes 编码解绑响应 协议：size + header + route + seq + code

func EncodeUnsubscribeReq added in v2.3.0 

func EncodeUnsubscribeReq(seq uint64, kind session.Kind, targets []int64, channel string) *buffer.NocopyBuffer

EncodeUnsubscribeReq 编码取消订阅频道请求（单次最多取消订阅65535个对象） 协议：size + header + route + seq + session kind + count + targets + channel

func EncodeUnsubscribeRes added in v2.3.0 

func EncodeUnsubscribeRes(seq uint64, code uint16) *buffer.NocopyBuffer

EncodeUnsubscribeRes 编码取消订阅频道响应 协议：size + header + route + seq + code

func Heartbeat 

func Heartbeat() []byte

func ReadMessage 

func ReadMessage(reader io.Reader) (isHeartbeat bool, route uint8, seq uint64, data []byte, err error)

ReadMessage 读取消息

Types

This section is empty.

Source Files

View all Source files

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.