ws

README

socklace

Websockets stuff

Documentation

Index

• Variables
• func SM(success bool, message string) sm
• type Connection
  • func (conn *Connection) Context() context.Context
  • func (conn *Connection) Send(id int64, topic string, data interface{}) error
• type Hook
• type Request
  • func (r *Request) Respond(data interface{}) error
• type WS
  • func (m *WS) AddPostHook(hook Hook)
  • func (m *WS) AddPreHook(hook Hook)
  • func (m *WS) RegisterHandler(topic string, handlerFn interface{})
  • func (m *WS) ServeHTTP(w http.ResponseWriter, r *http.Request)

Variables

var ErrInvalidPacket = errors.New("ws: invalid packet")

var ErrUnknowHandler = errors.New("ws: unknown handler")

Functions

func SM

func SM(success bool, message string) sm

Types

type Connection

type Connection struct {
	Request *http.Request
	Values  sync.Map
	// contains filtered or unexported fields
}

Connection holds all data and websocket connection

func (*Connection) Context

func (conn *Connection) Context() context.Context

func (*Connection) Send

func (conn *Connection) Send(id int64, topic string, data interface{}) error

type Hook

type Hook func(conn *Connection)

Hook is function called before main loop or after connection was closed

type Request

type Request struct {
	C *Connection `json:"-"`

	ID    int64
	Topic string
	Data  json.RawMessage
}

Request represents data sends from client to server

func (*Request) Respond

func (r *Request) Respond(data interface{}) error

Respond sends response to client and returns error if failed

type WS

type WS struct {
	ErrorHandler func(c *Connection, err error)
	Upgrader     websocket.Upgrader
	// contains filtered or unexported fields
}

func (*WS) AddPostHook

func (m *WS) AddPostHook(hook Hook)

AddPostHook appends post request hook

func (*WS) AddPreHook

func (m *WS) AddPreHook(hook Hook)

AddPreHook appends pre main loop hook

func (*WS) RegisterHandler

func (m *WS) RegisterHandler(topic string, handlerFn interface{})

RegisterHandler register function for entered topic note that handlerFn is interface{} but should be function (func(r *Request, optionalParameter string))

func (*WS) ServeHTTP

func (m *WS) ServeHTTP(w http.ResponseWriter, r *http.Request)