serverMgr

Documentation

Index

• Variables
• type LoadBalancer
  • func NewLoadBalancer() *LoadBalancer
  • func (app *LoadBalancer) GetServerByType(t uint8) (*iserver.ServerInfo, error)
  • func (app *LoadBalancer) GetServerList() ([]*iserver.ServerInfo, error)
• type LoadUpdater
  • func NewLoadUpdater(ctrl iUpdateCtrl, serverID uint64, interval time.Duration) *LoadUpdater
  • func (app *LoadUpdater) Start()
  • func (app *LoadUpdater) Stop()
• type ServerMgr
  • func GetServerMgr() *ServerMgr
  • func (mgr *ServerMgr) RegState(server *iserver.ServerInfo) error
  • func (mgr *ServerMgr) Unregister(server *iserver.ServerInfo) error
  • func (mgr *ServerMgr) Update(server *iserver.ServerInfo) error
  • func (mgr *ServerMgr) VerifyServer(uid uint64, token string) bool

Variables

var ErrServerBusy = errors.New("Get server failed, busy")

ErrServerBusy 服务器忙

Types

type LoadBalancer

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

LoadBalancer 负载均衡器

func NewLoadBalancer

func NewLoadBalancer() *LoadBalancer

NewLoadBalancer 创建负载均衡器

func (*LoadBalancer) GetServerByType

func (app *LoadBalancer) GetServerByType(t uint8) (*iserver.ServerInfo, error)

GetServerByType 轮询获取服务器

func (*LoadBalancer) GetServerList

func (app *LoadBalancer) GetServerList() ([]*iserver.ServerInfo, error)

GetServerList 获取最新的服务器列表

type LoadUpdater

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

LoadUpdater 负载更新器

func NewLoadUpdater

func NewLoadUpdater(ctrl iUpdateCtrl, serverID uint64, interval time.Duration) *LoadUpdater

NewLoadUpdater 创建负载更新器 服务器需要提供GetLoad方法获取负载信息 需要指定负载信息更新间隔

func (*LoadUpdater) Start

func (app *LoadUpdater) Start()

Start 启动负载更新器

func (*LoadUpdater) Stop

func (app *LoadUpdater) Stop()

Stop 停止负载更新器

type ServerMgr

type ServerMgr struct {
	*LoadBalancer
}

ServerMgr 服务器管理类

func GetServerMgr

func GetServerMgr() *ServerMgr

GetServerMgr 获取服务器管理实例

func (*ServerMgr) RegState

func (mgr *ServerMgr) RegState(server *iserver.ServerInfo) error

RegState 注册服务器信息

func (*ServerMgr) Unregister

func (mgr *ServerMgr) Unregister(server *iserver.ServerInfo) error

Unregister 将服务器信息从redis中删除

func (*ServerMgr) Update

func (mgr *ServerMgr) Update(server *iserver.ServerInfo) error

Update 更新服务器信息

func (*ServerMgr) VerifyServer

func (mgr *ServerMgr) VerifyServer(uid uint64, token string) bool

VerifyServer 验证服务器连接有效性