coordinator

Documentation

Index

• func GetConnectionRequest(data string) (api.ConnectionRequest, error)
• func New(conf coordinator.Config) (services service.Group)
• func NewHTTPServer(conf coordinator.Config, fnMux func(mux *http.ServeMux)) (*httpx.Server, error)
• type BrowserClient
  • func NewBrowserClient(c *websocket.Conn, browserID string) *BrowserClient
  • func (bc *BrowserClient) Printf(format string, args ...interface{})
  • func (bc *BrowserClient) Println(args ...interface{})
• type Server
  • func NewServer(cfg coordinator.Config, library games.GameLibrary) *Server
  • func (s *Server) WS(w http.ResponseWriter, r *http.Request)
  • func (s *Server) WSO(w http.ResponseWriter, r *http.Request)
• type WorkerClient
  • func NewWorkerClient(c *websocket.Conn, workerID string) *WorkerClient
  • func (wc *WorkerClient) ChangeUserQuantityBy(n int)
  • func (wc *WorkerClient) HasGameSlot() bool
  • func (wc *WorkerClient) Printf(format string, args ...interface{})
  • func (wc *WorkerClient) Println(args ...interface{})

Functions

func GetConnectionRequest

func GetConnectionRequest(data string) (api.ConnectionRequest, error)

func New

func New(conf coordinator.Config) (services service.Group)

func NewHTTPServer

func NewHTTPServer(conf coordinator.Config, fnMux func(mux *http.ServeMux)) (*httpx.Server, error)

Types

type BrowserClient

type BrowserClient struct {
	*cws.Client
	SessionID string
	RoomID    string
	WorkerID  string // TODO: how about pointer to workerClient?
}

func NewBrowserClient

func NewBrowserClient(c *websocket.Conn, browserID string) *BrowserClient

NewCoordinatorClient returns a client connecting to browser. This connection exchanges information between browser and coordinator.

func (*BrowserClient) Printf

func (bc *BrowserClient) Printf(format string, args ...interface{})

Register new log

func (*BrowserClient) Println

func (bc *BrowserClient) Println(args ...interface{})

type Server

type Server struct {
	service.Service
	// contains filtered or unexported fields
}

func NewServer

func NewServer(cfg coordinator.Config, library games.GameLibrary) *Server

func (*Server) WS

func (s *Server) WS(w http.ResponseWriter, r *http.Request)

WSO handles all connections from user/frontend to coordinator

func (*Server) WSO

func (s *Server) WSO(w http.ResponseWriter, r *http.Request)

WSO handles all connections from a new worker to coordinator

type WorkerClient

type WorkerClient struct {
	*cws.Client

	WorkerID string
	Address  string // ip address of worker
	// public server used for ping check
	PingServer     string
	StunTurnServer string

	Zone string
	// contains filtered or unexported fields
}

func NewWorkerClient

func NewWorkerClient(c *websocket.Conn, workerID string) *WorkerClient

NewWorkerClient returns a client connecting to worker. This connection exchanges information between workers and server.

func (*WorkerClient) ChangeUserQuantityBy

func (wc *WorkerClient) ChangeUserQuantityBy(n int)

ChangeUserQuantityBy increases or decreases the total amount of users connected to the current worker. We count users to determine when the worker becomes new game ready.

func (*WorkerClient) HasGameSlot

func (wc *WorkerClient) HasGameSlot() bool

HasGameSlot tells whether the current worker has a free slot to start a new game. Workers support only one game at a time.

func (*WorkerClient) Printf

func (wc *WorkerClient) Printf(format string, args ...interface{})

func (*WorkerClient) Println

func (wc *WorkerClient) Println(args ...interface{})