cluster

Documentation

Index

• type BaseServer
  • func NewBaseServer() *BaseServer
  • func (s *BaseServer) AddRouter(msgID int32, router IRouter)
  • func (s *BaseServer) GetServerInfo() pb.ServerReport
  • func (s *BaseServer) PrintServerInfo()
  • func (s *BaseServer) ReadConfig()
  • func (s *BaseServer) Serve()
  • func (s *BaseServer) SetOnStart(onStart func() bool)
  • func (s *BaseServer) SetOnStop(onStop func() bool)
  • func (s *BaseServer) SetServerInfo(id int32, name string, ip string, port int32, maxConn int32, state ServerState, ...)
  • func (s *BaseServer) Start()
  • func (s *BaseServer) StartLog()
  • func (s *BaseServer) Stop()
• type IBaseServer

Types

type BaseServer

type BaseServer struct {

	// 本服务器详细信息
	ServerInfo pb.ServerReport
	// contains filtered or unexported fields
}

GFNodeServer 包含服务器端和客户端

func NewBaseServer

func NewBaseServer() *BaseServer

func (*BaseServer) AddRouter

func (s *BaseServer) AddRouter(msgID int32, router IRouter)

func (*BaseServer) GetServerInfo

func (s *BaseServer) GetServerInfo() pb.ServerReport

func (*BaseServer) PrintServerInfo

func (s *BaseServer) PrintServerInfo()

func (*BaseServer) ReadConfig

func (s *BaseServer) ReadConfig()

读取配置

func (*BaseServer) Serve

func (s *BaseServer) Serve()

运行服务器执行

func (*BaseServer) SetOnStart

func (s *BaseServer) SetOnStart(onStart func() bool)

func (*BaseServer) SetOnStop

func (s *BaseServer) SetOnStop(onStop func() bool)

func (*BaseServer) SetServerInfo

func (s *BaseServer) SetServerInfo(id int32, name string, ip string, port int32, maxConn int32, state ServerState, serverType int32)

func (*BaseServer) Start

func (s *BaseServer) Start()

启动服务器

func (*BaseServer) StartLog

func (s *BaseServer) StartLog()

func (*BaseServer) Stop

func (s *BaseServer) Stop()

关闭服务器

type IBaseServer

type IBaseServer interface {
	Start()
	Serve()
	Stop()

	ReadConfig() // 读取配置：读取redis mysql配置
	StartLog()   // 启动日志管理

	SetOnStart(onStart func() bool)
	SetOnStop(onStop func() bool)

	// 设置服务器信息，用于广播给其他节点
	SetServerInfo(id int32, name string, ip string, port int32, maxConn int32, state ServerState, serverType int32)
	GetServerInfo() pb.ServerReport
	AddRouter(msgID int32, router IRouter)

	// 指令打印服务器信息
	PrintServerInfo()
}