ws

Documentation

Index

• Variables
• type DisplayRoom
  • func NewDisplayRoom(room *game.Room) *DisplayRoom
• type Message
  • func NewWebSocketMessage(user string, message string) *Message
• type MessageHandler
  • func NewMessageHandler(server *Server) *MessageHandler
  • func (messageHandler *MessageHandler) OnMessage(message interface{})
• type Server
  • func NewServer(game *game.Game, port string) *Server
  • func (server *Server) OnSystemMessage(message *game.Message)
  • func (server *Server) Start()
  • func (server *Server) Stop()

Variables

var Module = fx.Provide(func(game *game.Game) *Server {

	return NewServer(game, "8000")
})

Module ... fx module export

Types

type DisplayRoom

type DisplayRoom struct {
	Type string     `json:"type"`
	Room *game.Room `json:"room"`
}

DisplayRoom ...

func NewDisplayRoom

func NewDisplayRoom(room *game.Room) *DisplayRoom

NewDisplayRoom ... creates new display room message

type Message

type Message struct {
	Type     string `json:"type"`
	Username string `json:"username"`
	Message  string `json:"message"`
}

Message ... Define our message object

func NewWebSocketMessage

func NewWebSocketMessage(user string, message string) *Message

NewWebSocketMessage ... creates a new Websocket message

type MessageHandler

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

MessageHandler ... tcp ..

func NewMessageHandler

func NewMessageHandler(server *Server) *MessageHandler

NewMessageHandler ... creates a new message handler

func (*MessageHandler) OnMessage

func (messageHandler *MessageHandler) OnMessage(message interface{})

OnMessage .. broadcast receiver

type Server

type Server struct {
	Clients   map[*websocket.Conn]bool
	Users     map[string]*websocket.Conn
	Broadcast chan Message

	MessageHandler *MessageHandler
	// contains filtered or unexported fields
}

Server ... Define our message object

func NewServer

func NewServer(game *game.Game, port string) *Server

NewServer ... creates a new websocketserver instance

func (*Server) OnSystemMessage

func (server *Server) OnSystemMessage(message *game.Message)

OnSystemMessage .. broadcast receiver

func (*Server) Start

func (server *Server) Start()

Start ... start websocketserver

func (*Server) Stop

func (server *Server) Stop()

Stop ... start websocketserver