Versions in this module Expand all Collapse all v0 v0.1.0 Mar 23, 2025 Changes in this version + type Client struct + Connection *websocket.Conn + ID string + LastActivity time.Time + Send chan Event + Subscribed map[EventType]bool + UserID string + func (client *Client) ReadPump(manager *Manager) + func (client *Client) WritePump() + type Event struct + Data interface{} + ID string + Timestamp time.Time + Type EventType + type EventType string + const EventTypeError + const EventTypeFunction + const EventTypeNotification + const EventTypeOracle + const EventTypePing + const EventTypePriceFeed + const EventTypeRandomNumber + const EventTypeServiceStatus + const EventTypeTransaction + const EventTypeTrigger + type Manager struct + func NewManager() *Manager + func (m *Manager) Authenticate(client *Client, userID string) + func (m *Manager) Broadcast(eventType EventType, data interface{}) + func (m *Manager) GetConnectedClientsCount() int + func (m *Manager) Register(client *Client) + func (m *Manager) SendToUser(userID string, eventType EventType, data interface{}) + func (m *Manager) Start() + func (m *Manager) Stop() + func (m *Manager) Unregister(client *Client)
Go to main page