worker

Documentation

Index

• func MakeConnectionRequest(conf worker.Worker, address string) (string, error)
• func New(conf worker.Config) (services service.Group)
• func NewHTTPServer(conf worker.Config) (*httpx.Server, error)
• type CoordinatorClient
  • func NewCoordinatorClient(oc *websocket.Conn) *CoordinatorClient
• type Handler
  • func NewHandler(conf worker.Config, address string) *Handler
  • func (h *Handler) Close()
  • func (h *Handler) GetCoordinatorClient() *CoordinatorClient
  • func (h *Handler) Prepare()
  • func (h *Handler) Run()
  • func (h *Handler) Shutdown(context.Context) error
• type Session
  • func (s *Session) Close()

Functions

func MakeConnectionRequest

func MakeConnectionRequest(conf worker.Worker, address string) (string, error)

func New

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

func NewHTTPServer

func NewHTTPServer(conf worker.Config) (*httpx.Server, error)

Types

type CoordinatorClient

type CoordinatorClient struct {
	*cws.Client
}

CoordinatorClient maintains connection to coordinator. We expect only one CoordinatorClient for each server.

func NewCoordinatorClient

func NewCoordinatorClient(oc *websocket.Conn) *CoordinatorClient

NewCoordinatorClient returns a client connecting to coordinator for coordination between different server.

type Handler

type Handler struct {
	service.RunnableService
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(conf worker.Config, address string) *Handler

NewHandler returns a new server

func (*Handler) Close

func (h *Handler) Close()

func (*Handler) GetCoordinatorClient

func (h *Handler) GetCoordinatorClient() *CoordinatorClient

func (*Handler) Prepare

func (h *Handler) Prepare()

func (*Handler) Run

func (h *Handler) Run()

Run starts a Handler running logic

func (*Handler) Shutdown

func (h *Handler) Shutdown(context.Context) error

type Session

type Session struct {
	ID string

	// Should I make direct reference
	RoomID string
	// contains filtered or unexported fields
}

Session represents a session connected from the browser to the current server It requires one connection to browser and one connection to the coordinator connection to browser is 1-1. connection to coordinator is n - 1 Peerconnection can be from other server to ensure better latency

func (*Session) Close

func (s *Session) Close()

Close close a session