tcp

Documentation

Index

• Variables
• type Client
  • func NewClient(connection net.Conn) *Client
  • func (client *Client) Listen()
  • func (client *Client) Read()
  • func (client *Client) Write()
• 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) Broadcast(data string)
  • func (server *Server) Join(connection net.Conn)
  • func (server *Server) Start()
  • func (server *Server) Stop()

Variables

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

	return NewServer(game, "8023")
})

Module ... fx module export

Types

type Client

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

Client ... asd

func NewClient

func NewClient(connection net.Conn) *Client

NewClient ... creates a new client

func (*Client) Listen

func (client *Client) Listen()

Listen ... asda

func (*Client) Read

func (client *Client) Read()

func (*Client) Write

func (client *Client) Write()

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 {
	MessageHandler *MessageHandler
	// contains filtered or unexported fields
}

Server ... tbd

func NewServer

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

NewServer ... creates and returns a new TCPGameServer instance

func (*Server) Broadcast

func (server *Server) Broadcast(data string)

Broadcast ...

func (*Server) Join

func (server *Server) Join(connection net.Conn)

Join ... handles a new client joining

func (*Server) Start

func (server *Server) Start()

Start .. starts the created server

func (*Server) Stop

func (server *Server) Stop()

Stop ... start tcp server