Kcpnet

package

Go to main page

Versions in this module

v0

v0.0.5

May 21, 2020

Changes in this version

type KcpClientSession

+ Name string

+ RegPoint define.ERouteId

+ StrIdentify string

+ SvrType define.ERouteId

+ func (this *KcpClientSession) WriteMessage(data []byte) (succ bool)

type KcpServerSession

+ Name string

+ RegPoint define.ERouteId

+ StrIdentify string

+ SvrType define.ERouteId

+ func (this *KcpServerSession) Alive() bool

+ func (this *KcpServerSession) GetModuleName() string

+ func (this *KcpServerSession) IsUser() bool

+ func (this *KcpServerSession) RefreshHeartBeat(mainid, subid uint16) bool

+ func (this *KcpServerSession) WriteMessage(data []byte) (succ bool)

v0.0.4

May 12, 2020

Changes in this version

+ const EnMessage_DataPackLen

+ const EnMessage_IdentifyEixst

+ const EnMessage_IdentifyLen

+ const EnMessage_MainIDPackLen

+ const EnMessage_NoDataLen

+ const EnMessage_PostType

+ const EnMessage_RemoteAddrEixst

+ const EnMessage_RemoteAddrLen

+ const EnMessage_SubIDPackLen

+ const EnMessage_SvrDataPackLen

+ const EnMessage_SvrNoDataLen

+ const MsgPostType_Broadcast

+ const MsgPostType_Single

+ func GetAllMessageIDs() (msgs []uint32)

+ func RegisterMessage(mainID, subID uint16, proc interface{})

+ func RegisterMessageRet(session TcpSession) (succ bool, err error)

+ func ResponseHeartBeat(session TcpSession) (succ bool, err error)

+ func SpecialLoginMsgFilter(main, sub uint16) (ok bool)

+ func UnPackExternalMsg(c *kcp.UDPSession, pack IMessagePack) (succ bool)

+ func UnPackInnerMsg(c *kcp.UDPSession, pack IMessagePack) (succ bool)

+ type IMessagePack interface

+ Clean func()

+ GetDataLen func() (datalen uint32)

+ GetIdentify func() string

+ GetMessageID func() (mainID uint16, subID uint16)

+ GetPostType func() (pt uint16)

+ GetRemoteAddr func() (addr string)

+ GetRouteID func() (route uint16)

+ GetSrcMsg func() (data []byte)

+ PackAction func(Output []byte) (err error)

+ PackAction4Client func(Output []byte) (err error)

+ PackClientMsg func(mainid, subid uint16, msg proto.Message) (out []byte, err error)

+ PackData func(msg proto.Message) (data []byte, err error)

+ PackInnerMsg func(mainid, subid uint16, msg proto.Message) (out []byte, err error)

+ SetCmd func(mainid, subid uint16, data []byte)

+ SetIdentify func(identify string)

+ SetPostType func(pt uint16)

+ SetRemoteAddr func(addr string)

+ UnPackData func() (msg proto.Message, cb reflect.Value, err error, exist bool)

+ UnPackMsg4Client func(InData []byte) (pos int, err error)

+ UnPackMsg4Svr func(InData []byte) (pos int, err error)

+ type KcpClient struct

+ Addr string

+ func NewKcpClient(addr, pprofAddr string, name string) *KcpClient

+ func (this *KcpClient) Run()

+ type KcpClientProtocol struct

+ func (this *KcpClientProtocol) Clean()

+ func (this *KcpClientProtocol) GetDataLen() (datalen uint32)

+ func (this *KcpClientProtocol) GetIdentify() string

+ func (this *KcpClientProtocol) GetMessageID() (mainID uint16, subID uint16)

+ func (this *KcpClientProtocol) GetPostType() (pt uint16)

+ func (this *KcpClientProtocol) GetRemoteAddr() (addr string)

+ func (this *KcpClientProtocol) GetRouteID() (route uint16)

+ func (this *KcpClientProtocol) GetSrcMsg() (data []byte)

+ func (this *KcpClientProtocol) PackAction(Output []byte) (err error)

+ func (this *KcpClientProtocol) PackAction4Client(Output []byte) (err error)

+ func (this *KcpClientProtocol) PackClientMsg(mainid, subid uint16, msg proto.Message) (out []byte, err error)

+ func (this *KcpClientProtocol) PackData(msg proto.Message) (data []byte, err error)

+ func (this *KcpClientProtocol) PackInnerMsg(mainid, subid uint16, msg proto.Message) (out []byte, err error)

+ func (this *KcpClientProtocol) SetCmd(mainid, subid uint16, data []byte)

+ func (this *KcpClientProtocol) SetIdentify(identify string)

+ func (this *KcpClientProtocol) SetPostType(pt uint16)

+ func (this *KcpClientProtocol) SetRemoteAddr(addr string)

+ func (this *KcpClientProtocol) UnPackData() (msg proto.Message, cb reflect.Value, err error, exist bool)

+ func (this *KcpClientProtocol) UnPackMsg4Client(InData []byte) (pos int, err error)

+ func (this *KcpClientProtocol) UnPackMsg4Svr(InData []byte) (pos int, err error)

+ type KcpClientSession struct

+ func (this *KcpClientSession) Alive() bool

+ func (this *KcpClientSession) GetIdentify() string

+ func (this *KcpClientSession) GetModuleName() string

+ func (this *KcpClientSession) GetPack() (obj IMessagePack)

+ func (this *KcpClientSession) GetRegPoint() (RegPoint Define.ERouteId)

+ func (this *KcpClientSession) GetRemoteAddr() string

+ func (this *KcpClientSession) Handler()

+ func (this *KcpClientSession) IsUser() bool

+ func (this *KcpClientSession) Offline()

+ func (this *KcpClientSession) Push(RegPoint Define.ERouteId)

+ func (this *KcpClientSession) RefreshHeartBeat(mainid, subid uint16) bool

+ func (this *KcpClientSession) SendInnerBroadcastMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ func (this *KcpClientSession) SendInnerClientMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ func (this *KcpClientSession) SendInnerSvrMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ func (this *KcpClientSession) SendSvrClientMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ func (this *KcpClientSession) SetIdentify(StrIdentify string)

+ func (this *KcpClientSession) SetSendCache(data []byte)

+ type KcpServer struct

+ func NewKcpServer(Name string, addr string, pprofAddr string) *KcpServer

+ func (this *KcpServer) Run()

+ type KcpServerProtocol struct

+ func (this *KcpServerProtocol) Clean()

+ func (this *KcpServerProtocol) GetDataLen() (datalen uint32)

+ func (this *KcpServerProtocol) GetIdentify() string

+ func (this *KcpServerProtocol) GetMessageID() (mainID uint16, subID uint16)

+ func (this *KcpServerProtocol) GetPostType() (pt uint16)

+ func (this *KcpServerProtocol) GetRemoteAddr() (addr string)

+ func (this *KcpServerProtocol) GetRouteID() (route uint16)

+ func (this *KcpServerProtocol) GetSrcMsg() (data []byte)

+ func (this *KcpServerProtocol) PackAction(Output []byte) (err error)

+ func (this *KcpServerProtocol) PackAction4Client(Output []byte) (err error)

+ func (this *KcpServerProtocol) PackClientMsg(mainid, subid uint16, msg proto.Message) (out []byte, err error)

+ func (this *KcpServerProtocol) PackData(msg proto.Message) (data []byte, err error)

+ func (this *KcpServerProtocol) PackInnerMsg(mainid, subid uint16, msg proto.Message) (out []byte, err error)

+ func (this *KcpServerProtocol) SetCmd(mainid, subid uint16, data []byte)

+ func (this *KcpServerProtocol) SetIdentify(identify string)

+ func (this *KcpServerProtocol) SetPostType(pt uint16)

+ func (this *KcpServerProtocol) SetRemoteAddr(addr string)

+ func (this *KcpServerProtocol) UnPackData() (msg proto.Message, cb reflect.Value, err error, exist bool)

+ func (this *KcpServerProtocol) UnPackMsg4Client(InData []byte) (pos int, err error)

+ func (this *KcpServerProtocol) UnPackMsg4Svr(InData []byte) (pos int, err error)

+ type KcpServerSession struct

+ RemoteAddr string

+ func NewKcpClientSession(c *kcp.UDPSession) *KcpServerSession

+ func NewKcpSvrSession(c *kcp.UDPSession) *KcpServerSession

+ func (this *KcpServerSession) GetIdentify() string

+ func (this *KcpServerSession) GetPack() (obj IMessagePack)

+ func (this *KcpServerSession) GetRegPoint() (RegPoint Define.ERouteId)

+ func (this *KcpServerSession) GetRemoteAddr() string

+ func (this *KcpServerSession) Handler()

+ func (this *KcpServerSession) Offline()

+ func (this *KcpServerSession) Push(RegPoint Define.ERouteId)

+ func (this *KcpServerSession) SendInnerBroadcastMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ func (this *KcpServerSession) SendInnerClientMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ func (this *KcpServerSession) SendInnerSvrMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ func (this *KcpServerSession) SendSvrClientMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ func (this *KcpServerSession) SetIdentify(StrIdentify string)

+ func (this *KcpServerSession) SetSendCache(data []byte)

+ type KcpSvrConfig struct

+ type SessionMgr struct

+ var GClient2ServerSession *SessionMgr

+ var GServer2ServerSession *SessionMgr

+ func (this *SessionMgr) AddSession(key interface{}, sess TcpSession)

+ func (this *SessionMgr) GetAllSession() (sess sync.Map)

+ func (this *SessionMgr) GetSession(key interface{}) (sess TcpSession)

+ func (this *SessionMgr) GetSessionByIdentify(key interface{}) (sess TcpSession)

+ func (this *SessionMgr) RemoveSession(key interface{}) (succ bool)

+ type TMessageProc struct

+ func GetMessageInfo(mainID, subID uint16) (proc *TMessageProc, finded bool)

+ type TcpSession interface

+ Alive func() bool

+ GetIdentify func() string

+ GetModuleName func() string

+ GetPack func() (obj IMessagePack)

+ GetRegPoint func() (RegPoint Define.ERouteId)

+ GetRemoteAddr func() string

+ IsUser func() bool

+ Push func(RegPoint Define.ERouteId)

+ RefreshHeartBeat func(mainid, subid uint16) bool

+ SendInnerBroadcastMsg func(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ SendInnerClientMsg func(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ SendInnerSvrMsg func(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ SendSvrClientMsg func(mainid, subid uint16, msg proto.Message) (succ bool, err error)

+ SetIdentify func(StrIdentify string)

+ SetSendCache func(data []byte)

+ WriteMessage func(data []byte) (succ bool)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL