uwebsocket

package module

v0.0.1 Latest Latest Go to latest Published: Oct 3, 2019 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func OnConnect(onConnectFunc func(r *http.Request)) *func(r *http.Request)

func SetConfig(_config Config)

SetConfig set config for all handlers

func UpgradeConnection(hub *WebSocketHub, clientAttributes ClientAttributes, w http.ResponseWriter, r *http.Request) error

type ClientAttributes interface{}

type ClientMessage struct {
	Message []byte
	Client  ClientAttributes
}

type Config struct {
	CORS      *string
	CustomLog ulog.ULogger
}

func GetConfig() Config

type Handler struct {
	UhttpHandler     uhttp.Handler
	ClientAttributes ClientAttributes
	OnConnect        *func(r *http.Request)
}

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

Client is a middleman between the websocket connection and the hub.

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

func CreateHubAndRunInBackground(messagHandler *chan ClientMessage) *WebSocketHub

func NewWebSocketHub(messagHandler *chan ClientMessage) *WebSocketHub

func (h *WebSocketHub) Handle(pattern string, handler *Handler)

func (h *WebSocketHub) Run()

func (h *WebSocketHub) SendWithFilter(filterFunc func(attrs ClientAttributes) bool, message []byte) error