dispatch

Documentation

Index

• func DecodeMsg(packs []byte, pkgLen int) bool
• func MsgRecv(conn net.Conn)
• func SingMsgProc(pkg []byte)
• type DisTask
  • func NewDispatch() *DisTask
  • func (d *DisTask) MsgProc(closeSig chan bool, message interface{})
  • func (d *DisTask) OnDestroy()
  • func (d *DisTask) OnInit()

Functions

func DecodeMsg

func DecodeMsg(packs []byte, pkgLen int) bool

func MsgRecv

func MsgRecv(conn net.Conn)

func SingMsgProc

func SingMsgProc(pkg []byte)

Types

type DisTask

type DisTask struct {
	// contains filtered or unexported fields
}

func NewDispatch

func NewDispatch() *DisTask

func (*DisTask) MsgProc

func (d *DisTask) MsgProc(closeSig chan bool, message interface{})

func (*DisTask) OnDestroy

func (d *DisTask) OnDestroy()

func (*DisTask) OnInit

func (d *DisTask) OnInit()