websocket

Documentation

Index

• func WebSocketHandler(broadcaster *Broadcaster) http.Handler
• type Broadcaster
  • func NewBroadcaster() *Broadcaster
  • func (b *Broadcaster) AddClient(client *Client)
  • func (b *Broadcaster) Broadcast(message []byte)
  • func (b *Broadcaster) RemoveClient(client *Client)
• type Client
  • func NewClient(conn *websocket.Conn) *Client
  • func (c *Client) ReadPump()
  • func (c *Client) Send(message []byte)
  • func (c *Client) WritePump()
• type ClientOption
  • func WithSendChannel(send chan []byte) ClientOption

Functions

func WebSocketHandler

func WebSocketHandler(broadcaster *Broadcaster) http.Handler

Types

type Broadcaster

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

func NewBroadcaster

func NewBroadcaster() *Broadcaster

func (*Broadcaster) AddClient

func (b *Broadcaster) AddClient(client *Client)

func (*Broadcaster) Broadcast

func (b *Broadcaster) Broadcast(message []byte)

func (*Broadcaster) RemoveClient

func (b *Broadcaster) RemoveClient(client *Client)

type Client

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

func NewClient

func NewClient(conn *websocket.Conn) *Client

func (*Client) ReadPump

func (c *Client) ReadPump()

func (*Client) Send

func (c *Client) Send(message []byte)

func (*Client) WritePump

func (c *Client) WritePump()

type ClientOption

type ClientOption func(*Client)

func WithSendChannel

func WithSendChannel(send chan []byte) ClientOption