cluster

Documentation

Index

• type IMasterNodeServer
• type MasterNodeServer
  • func NewMasterNodeServer() *MasterNodeServer
  • func (s *MasterNodeServer) AddRouter()
  • func (s *MasterNodeServer) InitNetServer(ip string, port int)
  • func (s *MasterNodeServer) SaveServer(serverInfo *pb.ServerReport)
  • func (s *MasterNodeServer) SyncServer(session ISession)
• type MasterServer
  • func NewMasterServer() *MasterServer
• type ServerInfoMap
• type ServerRouter
  • func (router *ServerRouter) Handle(request IRequest) MsgErrCode

Types

type IMasterNodeServer

type IMasterNodeServer interface {
	// 保存服务器信息
	SaveServer(serverInfo *pb.ServerReport)
	SyncServer(session ISession)

	InitNetServer(ip string, port int)
}

type MasterNodeServer

type MasterNodeServer struct {

	// 继承自 nodeservice
	INodeService
	// contains filtered or unexported fields
}

func NewMasterNodeServer

func NewMasterNodeServer() *MasterNodeServer

func (*MasterNodeServer) AddRouter

func (s *MasterNodeServer) AddRouter()

func (*MasterNodeServer) InitNetServer

func (s *MasterNodeServer) InitNetServer(ip string, port int)

func (*MasterNodeServer) SaveServer

func (s *MasterNodeServer) SaveServer(serverInfo *pb.ServerReport)

func (*MasterNodeServer) SyncServer

func (s *MasterNodeServer) SyncServer(session ISession)

type MasterServer

type MasterServer struct {
	IBaseServer
	// contains filtered or unexported fields
}

func NewMasterServer

func NewMasterServer() *MasterServer

type ServerInfoMap

type ServerInfoMap map[int32]*pb.ServerReport

type ServerRouter

type ServerRouter struct {
	BaseRouter
}

define master router

func (*ServerRouter) Handle

func (router *ServerRouter) Handle(request IRequest) MsgErrCode