gate

Documentation

Index

• func NewAgent() *agent
• type Agent
• type Gate
  • func (gate *Gate) OnDestroy()
  • func (gate *Gate) Run(closeSig chan bool)
• type IdUser
• type UserHandler

Functions

func NewAgent

func NewAgent() *agent

Types

type Agent

type Agent interface {
	WriteMsg(msg interface{}, id ...string)
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
	RemoteIP() string
	Close(int)
	Destroy()
	UserData() interface{}
	SetUserData(data interface{})
	SetCloseFunc(f func(args ...interface{}))
	Skeleton() *module.Skeleton
	ChanRPC() *chanrpc.Server
}

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
	LittleEndian bool

	// agent
	GoLen              int
	TimerDispatcherLen int
	AsynCallLen        int
	NewChanRPCFunc     func(Agent) UserHandler
	OnAgentInit        func(Agent)
	OnAgentDestroy     func(Agent)
}

func (*Gate) OnDestroy

func (gate *Gate) OnDestroy()

func (*Gate) Run

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

type IdUser

type IdUser interface {
	GetUid() int64
}

type UserHandler

type UserHandler interface {
	OnInit()
	OnDestroy()
	Run()
	GetChanRPC() *chanrpc.Server
}