websocket

Documentation

Index

• type Connector
• type Handler
• type Hub
  • func New(handler Handler, log logger.Logger) *Hub
  • func (v *Hub) Add(c *connection)
  • func (v *Hub) CloseAll()
  • func (v *Hub) Down() error
  • func (v *Hub) SendAll(b []byte)
  • func (v *Hub) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (v *Hub) Up() error

Types

type Connector

type Connector interface {
	UUID() string
	Headers() http.Header
	Send(v []byte)
	OnClose(cb func(string))
	Close()
}

Connector interface

type Handler

type Handler func([]byte, Connector)

Handler request processor

type Hub

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

func New

func New(handler Handler, log logger.Logger) *Hub

func (*Hub) Add

func (v *Hub) Add(c *connection)

Add connection to hub

func (*Hub) CloseAll

func (v *Hub) CloseAll()

CloseAll close all connection

func (*Hub) Down

func (v *Hub) Down() error

Down hub

func (*Hub) SendAll

func (v *Hub) SendAll(b []byte)

SendAll broadcast send message

func (*Hub) ServeHTTP

func (v *Hub) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP http handler

func (*Hub) Up

func (v *Hub) Up() error

Up hub