gate

Documentation

Index

• type Agent
• type Gate
  • func NewGate(maxConnNum int, maxMsgLen uint32, processor network.Processor, WSAddr string, ...) *Gate
  • func (gate *Gate) OnDestroy()
  • func (gate *Gate) Run(closeSig chan bool)
  • func (gate *Gate) SetFun(Fun1 func(Agent), Fun2 func(Agent), Fun3 func(interface{}, Agent))

Types

type Agent

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

type Gate

type Gate struct {
	MaxConnNum      int
	PendingWriteNum int
	MaxMsgLen       uint32
	Processor       network.Processor

	// websocket
	WSAddr      string
	HTTPTimeout time.Duration
	CertFile    string
	KeyFile     string

	// tcp
	TCPAddr   string
	LenMsgLen int

	//add by huanglin
	FunNewAgent   func(Agent)
	FunCloseAgent func(Agent)
	FuncMsgRecv   func(interface{}, Agent)
}

func NewGate

func NewGate(maxConnNum int, maxMsgLen uint32, processor network.Processor, WSAddr string,
	HTTPTimeout time.Duration, writerChanLen int) *Gate

func (*Gate) OnDestroy

func (gate *Gate) OnDestroy()

func (*Gate) Run

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

Run starts the gate service and listens for incoming connections.

func (*Gate) SetFun

func (gate *Gate) SetFun(Fun1 func(Agent), Fun2 func(Agent), Fun3 func(interface{}, Agent))

SetFun sets the functions for handling new agents, closing agents, and receiving messages.