websocket

Documentation

Index

• type BroadcastMessage
• type Client
  • func (c *Client) Read()
• type Message
• type Pool
  • func NewPool() *Pool
  • func (pool *Pool) Start()

Types

type BroadcastMessage

type BroadcastMessage interface {
	GetType() types.MessageType
}

BroadcastMessage is a message that can be broadcast to websocket clients

type Client

type Client struct {
	ID    string
	Conn  *websocket.Conn
	Pool  *Pool
	Mutex sync.Mutex
}

func (*Client) Read

func (c *Client) Read()

Read listens for new messages being sent to the websocket connection

type Message

type Message struct {
	Type int         `json:"type"`
	Body interface{} `json:"body"`
}

type Pool

type Pool struct {
	Register   chan *Client
	Unregister chan *Client
	Clients    map[*Client]bool
	Broadcast  chan BroadcastMessage
}

func NewPool

func NewPool() *Pool

func (*Pool) Start

func (pool *Pool) Start()