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

worker

package

Go to main page

Versions in this module

v3

v3.0.5

Apr 16, 2023

Changes in this version

+ type Connection interface

+ Disconnect func()

+ Id func() com.Uid

+ Notify func(api.PT, any)

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

+ Route func(api.In[com.Uid], *api.Out)

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

type Router

+ func (r *Router) RemoveDisconnect(user *Session)

type Session

+ func (s *Session) Disconnect()

v3.0.4

Mar 16, 2023

Changes in this version

+ func GetFrameSizeFor(hz int, frame int) int

+ func New(conf worker.Config, log *logger.Logger, done chan struct{}) (services service.Group)

+ func ResampleStretchNew(pcm []int16, size int) []int16

+ type Buffer struct

+ func NewBuffer(numSamples int) Buffer

+ func (b *Buffer) Write(s Samples, onFull OnFull) (r int)

+ type CloudSaveRoom struct

+ func WithCloudStorage(room GamingRoom, storage CloudStorage) *CloudSaveRoom

+ func (c *CloudSaveRoom) Download() error

+ func (c *CloudSaveRoom) HasSave() bool

+ func (c *CloudSaveRoom) SaveGame() error

+ type CloudStorage interface

+ Load func(name string) (data []byte, err error)

+ Save func(name string, localPath string) (err error)

+ func GetCloudStorage(provider, key string) (CloudStorage, error)

+ type GamingRoom interface

+ AddUser func(*Session)

+ CleanupUser func(*Session)

+ Close func()

+ EnableAutosave func(periodS int)

+ GetEmulator func() emulator.Emulator

+ GetId func() string

+ GetLog func() *logger.Logger

+ HasSave func() bool

+ HasUser func(*Session) bool

+ LoadGame func() error

+ PollUserInput func(*Session)

+ SaveGame func() error

+ StartEmulator func()

+ ToggleMultitap func()

+ type OnFull func(s Samples)

+ type OracleDataStorageClient struct

+ func NewOracleDataStorageClient(accessURL string) (*OracleDataStorageClient, error)

+ func (s *OracleDataStorageClient) Load(name string) (data []byte, err error)

+ func (s *OracleDataStorageClient) Save(name string, localPath string) (err error)

+ type RecordingRoom struct

+ func WithRecording(room GamingRoom, rec bool, recUser string, game string, conf worker.Config) *RecordingRoom

+ func (r *RecordingRoom) Close()

+ func (r *RecordingRoom) IsRecording() bool

+ func (r *RecordingRoom) ToggleRecording(active bool, user string)

+ type Room struct

+ func NewRoom(id string, game games.GameMetadata, onClose func(*Room), conf worker.Config, ...) *Room

+ func (r *Room) AddUser(user *Session)

+ func (r *Room) CleanupUser(user *Session)

+ func (r *Room) Close()

+ func (r *Room) EnableAutosave(periodSec int)

+ func (r *Room) GetEmulator() emulator.Emulator

+ func (r *Room) GetId() string

+ func (r *Room) GetLog() *logger.Logger

+ func (r *Room) HasSave() bool

+ func (r *Room) HasUser(u *Session) bool

+ func (r *Room) IsEmpty() bool

+ func (r *Room) LoadGame() error

+ func (r *Room) PollUserInput(session *Session)

+ func (r *Room) SaveGame() error

+ func (r *Room) StartEmulator()

+ func (r *Room) ToggleMultitap()

+ type Router struct

+ func NewRouter() Router

+ func (r *Router) AddUser(user *Session)

+ func (r *Router) Close()

+ func (r *Router) GetRoom(id string) GamingRoom

+ func (r *Router) GetUser(uid network.Uid) *Session

+ func (r *Router) RemoveRoom()

+ func (r *Router) RemoveUser(user *Session)

+ func (r *Router) SetRoom(room GamingRoom)

+ type Samples []int16

+ type Session struct

+ func NewSession(rtc *webrtc.Peer, id network.Uid) *Session

+ func (s *Session) Close()

+ func (s *Session) GetPeerConn() *webrtc.Peer

+ func (s *Session) GetPlayerIndex() int

+ func (s *Session) GetSetRoom(v GamingRoom) GamingRoom

+ func (s *Session) Id() network.Uid

+ func (s *Session) IsConnected() bool

+ func (s *Session) SendAudio(sample *media.Sample) error

+ func (s *Session) SendVideo(sample *media.Sample) error

+ func (s *Session) SetPlayerIndex(index int)

+ func (s *Session) SetRoom(room GamingRoom)

+ type Worker struct

+ func (w *Worker) Run()

+ func (w *Worker) Stop() error

Other modules containing this package

github.com/giongto35/cloud-game/v2