gate

Documentation

Index

• type Agent
• type Gate
  • func (gate *Gate) InitClient(ConnNum int)
  • func (gate *Gate) InitClients(ConnAddrs map[string]string) (clients map[int]*network.WSClient)
  • func (gate *Gate) OnDestroy()
  • func (gate *Gate) Run(closeSig chan bool)

Types

type Agent

type Agent interface {
	WriteMsg(msg interface{})
	Close()
	Destroy()
	UserData() interface{}
	SetUserData(data interface{})
	RemoteAddr() net.Addr
}

type Gate

type Gate struct {
	MaxConnNum      int
	PendingWriteNum int
	MaxMsgLen       uint32
	Processor       network.Processor
	AgentChanRPC    *chanrpc.Server

	// websocket
	WSAddr      string
	HTTPTimeout time.Duration

	// tcp
	TCPAddr      string
	LenMsgLen    int
	LittleEndian bool
}

func (*Gate) InitClient

func (gate *Gate) InitClient(ConnNum int)

func (*Gate) InitClients

func (gate *Gate) InitClients(ConnAddrs map[string]string) (clients map[int]*network.WSClient)

func (*Gate) OnDestroy

func (gate *Gate) OnDestroy()

func (*Gate) Run

func (gate *Gate) Run(closeSig chan bool)