base

Documentation

Index

• func BuildBroadcast(nodeType uint32) string
• func BuildPoint(nodeType, nodeId uint32) string
• func BuildPointSlot(nodeType, nodeId uint32, slot uint32) string
• func BuildReply(nodeType, nodeId uint32) string
• func GetBytes() []byte
• func PacketHandler(msg *packet.Packet)
• func PutBytes(val []byte)
• func SetPacketFunc(f func(*packet.Packet))

Functions

func BuildBroadcast

func BuildBroadcast(nodeType uint32) string

构建广播主题

func BuildPoint

func BuildPoint(nodeType, nodeId uint32) string

构建 NATS 单播主题

func BuildPointSlot

func BuildPointSlot(nodeType, nodeId uint32, slot uint32) string

BuildPointSlot 构建分片后的单播主题：{type}/{id}/{slot}

func BuildReply

func BuildReply(nodeType, nodeId uint32) string

构建回复主题

func GetBytes

func GetBytes() []byte

func PacketHandler

func PacketHandler(msg *packet.Packet)

func PutBytes

func PutBytes(val []byte)

func SetPacketFunc

func SetPacketFunc(f func(*packet.Packet))