communication

Documentation

Index

• Constants
• type Client
  • func NewClient(ws *websocket.Conn, server *Server) *Client
  • func (c *Client) Conn() *websocket.Conn
  • func (c *Client) Done()
  • func (c *Client) Listen()
  • func (c *Client) SendMessage(bytes *[]byte)
• type FileWriter
  • func NewFileWriter(space *state.Space) (*FileWriter, error)
  • func (fileWriter *FileWriter) HandlePhysicsReady(physicsReadyEvent *events.PhysicsReady)
  • func (fileWriter *FileWriter) HandleTimeTick(timeTickEvent *events.TimeTick)
  • func (fileWriter *FileWriter) Run()
• type ScoreBoardSender
  • func NewScoreBoardSender(server *Server, scoreBoardReader *persistence.ScoreBoardReader, ...) *ScoreBoardSender
  • func (sender *ScoreBoardSender) HandleScoreSent(scoreSent *events.ScoreSent)
  • func (sender *ScoreBoardSender) HandleUserJoined(userJoinedEvent *events.UserJoined)
• type Sender
  • func NewSender(server *Server, space *state.Space, userNameRegistry *utils.UserNamesRegistry) *Sender
  • func (sender *Sender) HandleObjectDestroyed(userDiedEvent *events.ObjectDestroyed)
  • func (sender *Sender) HandlePhysicsReady(physicsReadyEvent *events.PhysicsReady)
  • func (sender *Sender) HandleProjectileFired(projectileFiredEvent *events.ProjectileFired)
  • func (sender *Sender) HandleProjectileHit(projectileHitEvent *events.ProjectileHit)
  • func (sender *Sender) HandleUserConnected(userConnectedEvent *events.UserConnected)
  • func (sender *Sender) HandleUserJoined(userJoinedEvent *events.UserJoined)
  • func (sender *Sender) HandleUserLeft(userLeftEvent *events.UserLeft)
• type Server
  • func NewServer(pattern string, monitor *monitor.Monitor, ...) *Server
  • func (s *Server) ClientIDs() []uint32
  • func (s *Server) GetClient(clientId uint32) (*Client, bool)
  • func (s *Server) HandleUserLeft(userLeftEvent *events.UserLeft)
  • func (s *Server) Listen()
  • func (s *Server) SendToAllClients(message proto.Message)
  • func (s *Server) SendToClient(clientID uint32, message proto.Message)

Constants

const (
	DIRECTORY = "log"
)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client struct holds client-specific variables.

func NewClient

func NewClient(ws *websocket.Conn, server *Server) *Client

NewClient initializes a new Client struct with given websocket.

func (*Client) Conn

func (c *Client) Conn() *websocket.Conn

Conn returns client's websocket.Conn struct.

func (*Client) Done

func (c *Client) Done()

Done sends done message to the Client which closes the conection.

func (*Client) Listen

func (c *Client) Listen()

Listen Write and Read request via chanel

func (*Client) SendMessage

func (c *Client) SendMessage(bytes *[]byte)

SendMessage sends game state to the client.

type FileWriter

type FileWriter struct {
	// contains filtered or unexported fields
}

func NewFileWriter

func NewFileWriter(space *state.Space) (*FileWriter, error)

func (*FileWriter) HandlePhysicsReady

func (fileWriter *FileWriter) HandlePhysicsReady(physicsReadyEvent *events.PhysicsReady)

func (*FileWriter) HandleTimeTick

func (fileWriter *FileWriter) HandleTimeTick(timeTickEvent *events.TimeTick)

func (*FileWriter) Run

func (fileWriter *FileWriter) Run()

type ScoreBoardSender

type ScoreBoardSender struct {
	// contains filtered or unexported fields
}

func NewScoreBoardSender

func NewScoreBoardSender(server *Server, scoreBoardReader *persistence.ScoreBoardReader,
	userNameRegistry *utils.UserNamesRegistry) *ScoreBoardSender

func (*ScoreBoardSender) HandleScoreSent

func (sender *ScoreBoardSender) HandleScoreSent(scoreSent *events.ScoreSent)

func (*ScoreBoardSender) HandleUserJoined

func (sender *ScoreBoardSender) HandleUserJoined(userJoinedEvent *events.UserJoined)

type Sender

type Sender struct {
	// contains filtered or unexported fields
}

func NewSender

func NewSender(server *Server, space *state.Space, userNameRegistry *utils.UserNamesRegistry) *Sender

func (*Sender) HandleObjectDestroyed

func (sender *Sender) HandleObjectDestroyed(userDiedEvent *events.ObjectDestroyed)

func (*Sender) HandlePhysicsReady

func (sender *Sender) HandlePhysicsReady(physicsReadyEvent *events.PhysicsReady)

func (*Sender) HandleProjectileFired

func (sender *Sender) HandleProjectileFired(projectileFiredEvent *events.ProjectileFired)

func (*Sender) HandleProjectileHit

func (sender *Sender) HandleProjectileHit(projectileHitEvent *events.ProjectileHit)

func (*Sender) HandleUserConnected

func (sender *Sender) HandleUserConnected(userConnectedEvent *events.UserConnected)

func (*Sender) HandleUserJoined

func (sender *Sender) HandleUserJoined(userJoinedEvent *events.UserJoined)

func (*Sender) HandleUserLeft

func (sender *Sender) HandleUserLeft(userLeftEvent *events.UserLeft)

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server struct holds server variables.

func NewServer

func NewServer(pattern string, monitor *monitor.Monitor, eventDispatcher *events.EventDispatcher,
	idManager *utils.IdManager, userNameRegistry *utils.UserNamesRegistry) *Server

NewServer initializes a new server.

func (*Server) ClientIDs

func (s *Server) ClientIDs() []uint32

func (*Server) GetClient

func (s *Server) GetClient(clientId uint32) (*Client, bool)

func (*Server) HandleUserLeft

func (s *Server) HandleUserLeft(userLeftEvent *events.UserLeft)

func (*Server) Listen

func (s *Server) Listen()

Listen runs puts server into listening mode.

func (*Server) SendToAllClients

func (s *Server) SendToAllClients(message proto.Message)

func (*Server) SendToClient

func (s *Server) SendToClient(clientID uint32, message proto.Message)