messaging

Documentation

Index

• func HandleMessage(c *Client, input map[string]string)
• func HandleNewConnection(w http.ResponseWriter, r *http.Request)
• type Client
  • func (c *Client) Listen()
• type Hub
  • func NewHub() *Hub
• type Message
  • func (m *Message) Broadcast()
  • func (m *Message) BroadcastTo(client *Client)

Functions

func HandleMessage

func HandleMessage(c *Client, input map[string]string)

func HandleNewConnection

func HandleNewConnection(w http.ResponseWriter, r *http.Request)

Types

type Client

type Client struct {
	ID       int `json:"id"`
	Username string
	Socket   *websocket.Conn
}

func (*Client) Listen

func (c *Client) Listen()

Listens for inbound messages.

type Hub

type Hub struct {
	// Register requests from clients.
	Register chan *Client

	// Unregister requests from clients.
	Unregister chan *Client

	// Handle inbound messages.
	ReadMessage chan *Message

	// Handle outbound messages.
	WriteMessage chan *Message
}

Primary message handler.

func NewHub

func NewHub() *Hub

type Message

type Message struct {
	SenderID int    `json:"senderID"`
	Username string `json:"username"`
	Action   string `json:"action"`
	Body     string `json:"body"`
}

func (*Message) Broadcast

func (m *Message) Broadcast()

func (*Message) BroadcastTo

func (m *Message) BroadcastTo(client *Client)