logic

Documentation

Index

• func CheckOnline(sec int, notify offlineNotify) (err error)
• func ClearSub(clientID string)
• func LPPMQConnect(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQConnect.Req) (resp *PPMQConnect.Resp, code uint64, err error)
• func LPPMQDisconnect(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQDisconnect.Req) (resp *PPMQDisconnect.Resp, code uint64, err error)
• func LPPMQEXChangeMsg(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQEXChangeMsg.Req) (resp *PPMQEXChangeMsg.Resp, code uint64, err error)
• func LPPMQGetClientID(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQGetClientID.Req) (resp *PPMQGetClientID.Resp, code uint64, err error)
• func LPPMQGetSublist(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQGetSublist.Req, ...) (resp *PPMQGetSublist.Resp, code uint64, err error)
• func LPPMQPing(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQPing.Req) (resp *PPMQPing.Resp, code uint64, err error)
• func LPPMQPublish(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQPublish.Req, ci *g.ConnAttr) (resp *PPMQPublish.Resp, code uint64, err error)
• func LPPMQSubscribe(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQSubscribe.Req, ...) (resp *PPMQSubscribe.Resp, code uint64, err error)
• func LPPMQUnSub(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQUnSub.Req, ci *g.ConnAttr) (resp *PPMQUnSub.Resp, code uint64, err error)
• func LoopSendOfflineMsg(c pprpc.RPCConn, ci *g.ConnAttr, fn writemsg, endMS int64)
• func RunMsgOrder(c pprpc.RPCConn, ci *g.ConnAttr)
• func UpdateStatus(cid string, status int32)

Functions

func CheckOnline

func CheckOnline(sec int, notify offlineNotify) (err error)

CheckOnline .

func ClearSub

func ClearSub(clientID string)

ClearSub .

func LPPMQConnect

func LPPMQConnect(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQConnect.Req) (resp *PPMQConnect.Resp, code uint64, err error)

LPPMQConnect PPMQConnect Business logic

func LPPMQDisconnect

func LPPMQDisconnect(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQDisconnect.Req) (resp *PPMQDisconnect.Resp, code uint64, err error)

LPPMQDisconnect PPMQDisconnect Business logic

func LPPMQEXChangeMsg

func LPPMQEXChangeMsg(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQEXChangeMsg.Req) (resp *PPMQEXChangeMsg.Resp, code uint64, err error)

LPPMQEXChangeMsg PPMQEXChangeMsg Business logic

func LPPMQGetClientID

func LPPMQGetClientID(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQGetClientID.Req) (resp *PPMQGetClientID.Resp, code uint64, err error)

LPPMQGetClientID PPMQGetClientID Business logic

func LPPMQGetSublist

func LPPMQGetSublist(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQGetSublist.Req, clientID string) (resp *PPMQGetSublist.Resp, code uint64, err error)

LPPMQGetSublist PPMQGetSublist Business logic

func LPPMQPing

func LPPMQPing(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQPing.Req) (resp *PPMQPing.Resp, code uint64, err error)

LPPMQPing PPMQPing Business logic

func LPPMQPublish

func LPPMQPublish(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQPublish.Req, ci *g.ConnAttr) (resp *PPMQPublish.Resp, code uint64, err error)

LPPMQPublish PPMQPublish Business logic

func LPPMQSubscribe

func LPPMQSubscribe(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQSubscribe.Req, ci *g.ConnAttr) (resp *PPMQSubscribe.Resp, code uint64, err error)

LPPMQSubscribe PPMQSubscribe Business logic

func LPPMQUnSub

func LPPMQUnSub(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQUnSub.Req, ci *g.ConnAttr) (resp *PPMQUnSub.Resp, code uint64, err error)

LPPMQUnSub PPMQUnSub Business logic

func LoopSendOfflineMsg

func LoopSendOfflineMsg(c pprpc.RPCConn, ci *g.ConnAttr, fn writemsg, endMS int64)

LoopSendOfflineMsg .

func RunMsgOrder

func RunMsgOrder(c pprpc.RPCConn, ci *g.ConnAttr)

RunMsgOrder .

func UpdateStatus

func UpdateStatus(cid string, status int32)

UpdateStatus .