controller

package
v0.0.0-...-88f3d6a Latest Latest
Warning

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

 Go to latest Published: Sep 8, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PPMQConnecter 

type PPMQConnecter struct{}

PPMQConnecter .

func (*PPMQConnecter) DestructHandle 

func (t *PPMQConnecter) DestructHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, startMs int64)

DestructHandle PPMQConnect.

func (*PPMQConnecter) ReqHandle 

func (t *PPMQConnecter) ReqHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQConnect.Req) (err error)

ReqHandle PPMQConnect request handle

func (*PPMQConnecter) RespHandle 

func (t *PPMQConnecter) RespHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, resp *PPMQConnect.Resp) (err error)

RespHandle PPMQConnect response handle

type PPMQDisconnecter 

type PPMQDisconnecter struct{}

PPMQDisconnecter .

func (*PPMQDisconnecter) DestructHandle 

func (t *PPMQDisconnecter) DestructHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, startMs int64)

DestructHandle PPMQDisconnect.

func (*PPMQDisconnecter) ReqHandle 

func (t *PPMQDisconnecter) ReqHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQDisconnect.Req) (err error)

ReqHandle PPMQDisconnect request handle

func (*PPMQDisconnecter) RespHandle 

func (t *PPMQDisconnecter) RespHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, resp *PPMQDisconnect.Resp) (err error)

RespHandle PPMQDisconnect response handle

type PPMQGetClientIDer 

type PPMQGetClientIDer struct{}

PPMQGetClientIDer .

func (*PPMQGetClientIDer) DestructHandle 

func (t *PPMQGetClientIDer) DestructHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, startMs int64)

DestructHandle PPMQGetClientID.

func (*PPMQGetClientIDer) ReqHandle 

func (t *PPMQGetClientIDer) ReqHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQGetClientID.Req) (err error)

ReqHandle PPMQGetClientID request handle

func (*PPMQGetClientIDer) RespHandle 

func (t *PPMQGetClientIDer) RespHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, resp *PPMQGetClientID.Resp) (err error)

RespHandle PPMQGetClientID response handle

type PPMQGetSublister 

type PPMQGetSublister struct{}

PPMQGetSublister .

func (*PPMQGetSublister) DestructHandle 

func (t *PPMQGetSublister) DestructHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, startMs int64)

DestructHandle PPMQGetSublist.

func (*PPMQGetSublister) ReqHandle 

func (t *PPMQGetSublister) ReqHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQGetSublist.Req) (err error)

ReqHandle PPMQGetSublist request handle

func (*PPMQGetSublister) RespHandle 

func (t *PPMQGetSublister) RespHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, resp *PPMQGetSublist.Resp) (err error)

RespHandle PPMQGetSublist response handle

type PPMQPinger 

type PPMQPinger struct{}

PPMQPinger .

func (*PPMQPinger) DestructHandle 

func (t *PPMQPinger) DestructHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, startMs int64)

DestructHandle PPMQPing.

func (*PPMQPinger) ReqHandle 

func (t *PPMQPinger) ReqHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQPing.Req) (err error)

ReqHandle PPMQPing request handle

func (*PPMQPinger) RespHandle 

func (t *PPMQPinger) RespHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, resp *PPMQPing.Resp) (err error)

RespHandle PPMQPing response handle

type PPMQPublisher 

type PPMQPublisher struct{}

PPMQPublisher .

func (*PPMQPublisher) DestructHandle 

func (t *PPMQPublisher) DestructHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, startMs int64)

DestructHandle PPMQPublish.

func (*PPMQPublisher) ReqHandle 

func (t *PPMQPublisher) ReqHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQPublish.Req) (err error)

ReqHandle PPMQPublish request handle

func (*PPMQPublisher) RespHandle 

func (t *PPMQPublisher) RespHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, resp *PPMQPublish.Resp) (err error)

RespHandle PPMQPublish response handle

type PPMQSubscribeer 

type PPMQSubscribeer struct{}

PPMQSubscribeer .

func (*PPMQSubscribeer) DestructHandle 

func (t *PPMQSubscribeer) DestructHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, startMs int64)

DestructHandle PPMQSubscribe.

func (*PPMQSubscribeer) ReqHandle 

func (t *PPMQSubscribeer) ReqHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQSubscribe.Req) (err error)

ReqHandle PPMQSubscribe request handle

func (*PPMQSubscribeer) RespHandle 

func (t *PPMQSubscribeer) RespHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, resp *PPMQSubscribe.Resp) (err error)

RespHandle PPMQSubscribe response handle

type PPMQUnSuber 

type PPMQUnSuber struct{}

PPMQUnSuber .

func (*PPMQUnSuber) DestructHandle 

func (t *PPMQUnSuber) DestructHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, startMs int64)

DestructHandle PPMQUnSub.

func (*PPMQUnSuber) ReqHandle 

func (t *PPMQUnSuber) ReqHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, req *PPMQUnSub.Req) (err error)

ReqHandle PPMQUnSub request handle

func (*PPMQUnSuber) RespHandle 

func (t *PPMQUnSuber) RespHandle(c pprpc.RPCConn, pkg *packets.CmdPacket, resp *PPMQUnSub.Resp) (err error)

RespHandle PPMQUnSub response handle

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.