realtime

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

type InboundMessage struct {
	UserID     string          `json:"user_id"`
	ClientID   string          `json:"client_id"`
	Transport  Transport       `json:"transport"`
	Payload    map[string]any  `json:"payload"`
	Raw        json.RawMessage `json:"raw"`
	ReceivedAt time.Time       `json:"received_at"`
}

type PushAckResult struct {
	OK        bool   `json:"ok"`
	UserID    string `json:"user_id"`
	Acked     int    `json:"acked"`
	Total     int    `json:"total"`
	Delivered int    `json:"delivered"`
	Detail    string `json:"detail,omitempty"`
	Error     string `json:"error,omitempty"`
}

type Stats struct {
	Transport             string         `json:"transport"`
	MaxConnectionsPerUser int            `json:"max_connections_per_user"`
	Users                 int            `json:"users"`
	TotalConnections      int            `json:"total_connections"`
	ConnectionsByUser     map[string]int `json:"connections_by_user"`
}

type Transport string