servers

Documentation

Index

• type Server
• type ServerHealthStatus
• type ServerManager
  • func (sm *ServerManager) AddServer(s *Server) error
  • func (sm *ServerManager) GetLowestLoadedServer() *Server
  • func (sm *ServerManager) GetServerByIndex(index int) *Server
  • func (sm *ServerManager) GetServerHealth(s Server, endpoint string) (MUXworkerStructs.ServerStatusJSON, error)
  • func (sm *ServerManager) GetServers() []*Server
  • func (sm *ServerManager) GetServersCount() int
  • func (sm *ServerManager) GetServersWithHealth() []ServerHealthStatus
  • func (sm *ServerManager) InitTestServers()
  • func (sm *ServerManager) LoadServers() error
  • func (sm *ServerManager) RemoveServer(key string)

Types

type Server

type Server struct {
	Key        string `json:"key"`
	Protocol   string `json:"protocol"`
	Addr       string `json:"addr"`
	Port       string `json:"port"`
	WorkerPort string `json:"worker_port"`
}

type ServerHealthStatus

type ServerHealthStatus struct {
	Server Server                            `json:"server"`
	Health MUXworkerStructs.ServerStatusJSON `json:"health"`
	Online bool                              `json:"online"`
}

type ServerManager

type ServerManager struct {
	RedisOptions *redis.Options
	// contains filtered or unexported fields
}

func (*ServerManager) AddServer

func (sm *ServerManager) AddServer(s *Server) error

func (*ServerManager) GetLowestLoadedServer

func (sm *ServerManager) GetLowestLoadedServer() *Server

func (*ServerManager) GetServerByIndex

func (sm *ServerManager) GetServerByIndex(index int) *Server

func (*ServerManager) GetServerHealth

func (sm *ServerManager) GetServerHealth(s Server, endpoint string) (MUXworkerStructs.ServerStatusJSON, error)

func (*ServerManager) GetServers

func (sm *ServerManager) GetServers() []*Server

func (*ServerManager) GetServersCount

func (sm *ServerManager) GetServersCount() int

func (*ServerManager) GetServersWithHealth

func (sm *ServerManager) GetServersWithHealth() []ServerHealthStatus

func (*ServerManager) InitTestServers

func (sm *ServerManager) InitTestServers()

func (*ServerManager) LoadServers

func (sm *ServerManager) LoadServers() error

func (*ServerManager) RemoveServer

func (sm *ServerManager) RemoveServer(key string)