websockets

Documentation

Index

• type Connection
  • func (c *Connection) Run()
  • func (c *Connection) SendError(target string, msg string)
  • func (c *Connection) SendPacket(data map[string]interface{})
• type ReceiveMessage
• type Websocket
  • func New() *Websocket
  • func (s *Websocket) Broadcast(pkt map[string]interface{})
  • func (s *Websocket) ConnectionCount() int
  • func (h *Websocket) Run()
  • func (s *Websocket) Serve(w http.ResponseWriter, r *http.Request)

Types

type Connection

type Connection struct {
	Send      chan []byte
	SendQueue chan []byte
	// contains filtered or unexported fields
}

func (*Connection) Run

func (c *Connection) Run()

func (*Connection) SendError

func (c *Connection) SendError(target string, msg string)

func (*Connection) SendPacket

func (c *Connection) SendPacket(data map[string]interface{})

type ReceiveMessage

type ReceiveMessage struct {
	Message    []byte
	Connection *Connection
}

type Websocket

type Websocket struct {
	ReceiveMessages chan ReceiveMessage
	NewConnection   chan ReceiveMessage
	// contains filtered or unexported fields
}

func New

func New() *Websocket

func (*Websocket) Broadcast

func (s *Websocket) Broadcast(pkt map[string]interface{})

func (*Websocket) ConnectionCount

func (s *Websocket) ConnectionCount() int

func (*Websocket) Run

func (h *Websocket) Run()

func (*Websocket) Serve

func (s *Websocket) Serve(w http.ResponseWriter, r *http.Request)