ws

package

v1.0.0 Latest Latest Go to latest Published: May 29, 2025 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Event string

const (
	EventMessage    Event = "message"
	EventClose      Event = "close"
	EventError      Event = "error"
	EventDisconnect Event = "disconnect"
)

type EventPayload struct {
	Event string      `json:"event"`
	Data  interface{} `json:"data"`
}

type Room string

const (
	RoomAll   Room = "*" // Broadcast global
	RoomLobby Room = "lobby"
)

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

func (e *WebsocketEmitter) Emit(event string, data interface{}) error

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

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

func NewWebsocketManager(upgrader *websocket.Upgrader, logger *zap.Logger) *WebsocketManager

func (c *WebsocketManager) Broadcast(event string, data interface{})

func (m *WebsocketManager) CleanupRoom(room Room)

func (h *WebsocketManager) Close() error

func (h *WebsocketManager) Connect(w http.ResponseWriter, r *http.Request) error

func (c *WebsocketManager) Join(room Room)

func (c *WebsocketManager) Leave(room Room)

func (h *WebsocketManager) On(event string, handler func(data interface{}))

func (h *WebsocketManager) Replit(event string, data interface{}) error

func (h *WebsocketManager) Start()

func (c *WebsocketManager) To(room Room) *WebsocketEmitter