Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterMessageHandlers ¶
func RegisterMessageHandlers( router *bridge.Router, manager *connections.Manager, subs *store.Subscriptions, bus event.Bus, maxTopicsPerConn int, validators *store.ValidatorRegistry, evBridge *bridge.EventBridge, )
RegisterMessageHandlers wires up all client message type handlers on the given router. The evBridge parameter is optional; when non-nil, client subscriptions automatically create corresponding event bus subscriptions so that events published by other modules are forwarded to WebSocket clients.
Types ¶
type WebSocketHandler ¶
type WebSocketHandler struct {
// contains filtered or unexported fields
}
WebSocketHandler manages WebSocket upgrade and read loop.
func NewWebSocketHandler ¶
func NewWebSocketHandler( cfg *wsconfig.Config, manager *connections.Manager, pool *connections.Pool, subs *store.Subscriptions, router *bridge.Router, ) *WebSocketHandler
NewWebSocketHandler creates a WebSocketHandler.
func (*WebSocketHandler) Handle ¶
func (h *WebSocketHandler) Handle(c *gin.Context)
Handle processes a WebSocket upgrade request.
Source Files
Click to show internal directories.
Click to hide internal directories.