Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

coordinator

package

Go to main page

Versions in this module

v3

v3.0.5

Apr 16, 2023

Changes in this version

+ func RequestToHandshake(data string) (*api.ConnectionRequest[com.Uid], error)

+ func StateRoom(id T, rid string) api.StatefulRoom[T]

+ type Connection interface

+ Disconnect func()

+ Id func() com.Uid

+ Notify func(api.PT, any)

+ ProcessPackets func(func(api.In[com.Uid]) error) chan struct{}

+ Send func(api.PT, any) ([]byte, error)

+ type HasServerInfo interface

+ GetServerList func() []api.Server

+ type HasUserRegistry interface

+ Find func(com.Uid) (*User, bool)

+ type RegionalClient interface

+ In func(region string) bool

type User

+ func NewUser(sock *com.Connection, log *logger.Logger) *User

+ func (u *User) Bind(w *Worker)

type Worker

+ func NewWorker(sock *com.Connection, handshake api.ConnectionRequest[com.Uid], ...) *Worker

v3.0.4

Mar 16, 2023

Changes in this version

+ func New(conf coordinator.Config, log *logger.Logger) (services service.Group)

+ func NewHTTPServer(conf coordinator.Config, log *logger.Logger, fnMux func(*httpx.Mux) *httpx.Mux) (*httpx.Server, error)

+ type Hub struct

+ func NewHub(conf coordinator.Config, lib games.GameLibrary, log *logger.Logger) *Hub

+ func (h *Hub) GetServerList() (r []api.Server)

+ type User struct

+ func NewUserConnection(conn *com.SocketClient) *User

+ func (u *User) CheckLatency(req api.CheckLatencyUserResponse) (api.CheckLatencyUserRequest, error)

+ func (u *User) Disconnect()

+ func (u *User) HandleChangePlayer(rq api.ChangePlayerUserRequest)

+ func (u *User) HandleLoadGame() error

+ func (u *User) HandleQuitGame(rq api.GameQuitRequest)

+ func (u *User) HandleRecordGame(rq api.RecordGameRequest)

+ func (u *User) HandleRequests(info api.HasServerInfo, launcher games.Launcher, conf coordinator.Config)

+ func (u *User) HandleSaveGame() error

+ func (u *User) HandleStartGame(rq api.GameStartUserRequest, launcher games.Launcher, conf coordinator.Config)

+ func (u *User) HandleToggleMultitap()

+ func (u *User) HandleWebrtcAnswer(rq api.WebrtcAnswerUserRequest)

+ func (u *User) HandleWebrtcIceCandidate(rq api.WebrtcUserIceCandidate)

+ func (u *User) HandleWebrtcInit()

+ func (u *User) InitSession(wid string, ice []webrtc.IceServer, games []string)

+ func (u *User) SendWebrtcIceCandidate(candidate string)

+ func (u *User) SendWebrtcOffer(sdp string)

+ func (u *User) SetWorker(w *Worker)

+ func (u *User) StartGame()

+ type Worker struct

+ Addr string

+ PingServer string

+ Port string

+ RoomId string

+ Tag string

+ Zone string

+ func (s *Worker) FreeSlots()

+ func (s *Worker) HasSlot() bool

+ func (s *Worker) Reserve()

+ func (s *Worker) UnReserve()

+ func (w *Worker) ChangePlayer(id network.Uid, index int) (*api.ChangePlayerResponse, error)

+ func (w *Worker) Disconnect()

+ func (w *Worker) HandleCloseRoom(rq api.CloseRoomRequest)

+ func (w *Worker) HandleIceCandidate(rq api.WebrtcIceCandidateRequest, users *com.NetMap[*User])

+ func (w *Worker) HandleRegisterRoom(rq api.RegisterRoomRequest)

+ func (w *Worker) HandleRequests(users *com.NetMap[*User])

+ func (w *Worker) In(region string) bool

+ func (w *Worker) LoadGame(id network.Uid) (*api.LoadGameResponse, error)

+ func (w *Worker) PrintInfo() string

+ func (w *Worker) QuitGame(id network.Uid)

+ func (w *Worker) RecordGame(id network.Uid, rec bool, recUser string) (*api.RecordGameResponse, error)

+ func (w *Worker) SaveGame(id network.Uid) (*api.SaveGameResponse, error)

+ func (w *Worker) StartGame(id network.Uid, app games.AppMeta, req api.GameStartUserRequest) (*api.StartGameResponse, error)

+ func (w *Worker) TerminateSession(id network.Uid)

+ func (w *Worker) ToggleMultitap(id network.Uid)

+ func (w *Worker) WebrtcAnswer(id network.Uid, sdp string)

+ func (w *Worker) WebrtcIceCandidate(id network.Uid, can string)

+ func (w *Worker) WebrtcInit(id network.Uid) (*api.WebrtcInitResponse, error)

Other modules containing this package

github.com/giongto35/cloud-game/v2