server

Documentation

Index

• type Gate
  • func NewGate(serverID int32, addr string, config goserver.Config) (*Gate, error)
  • func (p *Gate) AfterPost(duration time.Duration, f func())
  • func (p *Gate) Close()
  • func (p *Gate) GetServerById(serverID int32) rpc.Server
  • func (p *Gate) GetSession(sesID int32) (network.Session, bool)
  • func (p *Gate) Post(f func())
  • func (p *Gate) RegisterCloseFunc(f func())
  • func (p *Gate) RegisterNetWorkEvent(onNew, onClose func(conn network.Session))
  • func (p *Gate) RegisterRawSessionMsgHandler(msg proto.Message, f func(s network.Session, message proto.Message))
  • func (p *Gate) RegisterRequestMsgHandler(cb interface{})
  • func (p *Gate) RegisterServerHandler(cb interface{})
  • func (p *Gate) RegisterSessionMsgHandler(cb interface{})
  • func (p *Gate) RouteSessionMsg(msg proto.Message, serverID int32)
  • func (p *Gate) Run()
• type Server
  • func NewServer(serverID int32, config goserver.Config) (*Server, error)
  • func (p *Server) GetServerById(serverID int32) rpc.Server
  • func (p *Server) ID() int32
  • func (p *Server) Post(f func())
  • func (p *Server) RPCSession(s rpc.GateSessionID) rpc.Session
  • func (p *Server) RegisterRequestMsgHandler(cb interface{})
  • func (p *Server) RegisterServerHandler(cb interface{})
  • func (p *Server) RegisterSessionMsgHandler(cb interface{})
  • func (p *Server) Run()
  • func (p *Server) Worker() service.Worker

Types

type Gate

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

func NewGate

func NewGate(serverID int32, addr string, config goserver.Config) (*Gate, error)

func (*Gate) AfterPost

func (p *Gate) AfterPost(duration time.Duration, f func())

func (*Gate) Close

func (p *Gate) Close()

func (*Gate) GetServerById

func (p *Gate) GetServerById(serverID int32) rpc.Server

func (*Gate) GetSession

func (p *Gate) GetSession(sesID int32) (network.Session, bool)

func (*Gate) Post

func (p *Gate) Post(f func())

func (*Gate) RegisterCloseFunc

func (p *Gate) RegisterCloseFunc(f func())

注册关闭事件 worker线程外

func (*Gate) RegisterNetWorkEvent

func (p *Gate) RegisterNetWorkEvent(onNew, onClose func(conn network.Session))

func (*Gate) RegisterRawSessionMsgHandler

func (p *Gate) RegisterRawSessionMsgHandler(msg proto.Message, f func(s network.Session, message proto.Message))

func (*Gate) RegisterRequestMsgHandler

func (p *Gate) RegisterRequestMsgHandler(cb interface{})

func (*Gate) RegisterServerHandler

func (p *Gate) RegisterServerHandler(cb interface{})

func (*Gate) RegisterSessionMsgHandler

func (p *Gate) RegisterSessionMsgHandler(cb interface{})

func (*Gate) RouteSessionMsg

func (p *Gate) RouteSessionMsg(msg proto.Message, serverID int32)

func (*Gate) Run

func (p *Gate) Run()

TODO 添加关闭信号

type Server

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

func NewServer

func NewServer(serverID int32, config goserver.Config) (*Server, error)

func (*Server) GetServerById

func (p *Server) GetServerById(serverID int32) rpc.Server

func (*Server) ID

func (p *Server) ID() int32

func (*Server) Post

func (p *Server) Post(f func())

func (*Server) RPCSession

func (p *Server) RPCSession(s rpc.GateSessionID) rpc.Session

func (*Server) RegisterRequestMsgHandler

func (p *Server) RegisterRequestMsgHandler(cb interface{})

func (*Server) RegisterServerHandler

func (p *Server) RegisterServerHandler(cb interface{})

func (*Server) RegisterSessionMsgHandler

func (p *Server) RegisterSessionMsgHandler(cb interface{})

func (*Server) Run

func (p *Server) Run()

TODO 添加关闭信号

func (*Server) Worker

func (p *Server) Worker() service.Worker