Versions in this module Expand all Collapse all v0 v0.0.2 Mar 21, 2024 v0.0.1 Mar 13, 2024 Changes in this version + const PubAckFailed + const PubAckOK + type Hub struct + func New() *Hub + func (h *Hub) CloseSession(sessionID string) + func (h *Hub) Publish(id string, data []byte) + func (h *Hub) RegisterSession(w http.ResponseWriter, r *http.Request) + func (h *Hub) Run(registerFunc, unregisterFunc func(id string)) + func (h *Hub) Subscribe() <-chan Message + type Message struct + Data []byte + ID string + type Session struct
Go to main page