websocket

type Client struct {

	// Unique client ID
	ID string `json:"id"`
	// contains filtered or unexported fields
}

type Hub struct {

	// Shutdown channel to stop the Hub
	Shutdown chan struct{}

	// Client subscriptions
	Subscriptions []*Subscription

	// Register channel for requests from the clients.
	Register chan *Client

	// Unregister channel for requests from clients.
	Unregister chan *Client
	// contains filtered or unexported fields
}

type Message struct {
	Action     string `json:"action"`
	ExchangeID string `json:"exchange_id"`
	Message    string `json:"message"`
}

type MessageResponse struct {
	Type    string `json:"type"`
	Message string `json:"message"`
}

type Subscription struct {
	ExchangeClient qsx.IExchange
	Client         *Client
	Shutdown       chan struct{}
}