websocket

type ContextProvider struct {
	// The websocket ContextProvider
	Conn *websocket.Conn
	// Buffered channel of outbound messages
	Send  chan []byte
	Host  string
	Port  string
	Path  string
	Close chan bool
}

type Hub struct {
	/*
	   A central hub will receive all incoming messages and broadcast them
	   to all registered "Subscriber"s
	   (i.e. the Subscriber structures in the clients map)
	*/
	Clients    map[Subscriber]bool
	Broadcast  chan Message
	Register   chan Subscriber
	Unregister chan Subscriber
	// contains filtered or unexported fields
}

type Message struct {
	Type        message.ExoWSMsgType `json:"type"`
	SerialData  string               `json:"serialData"`
	ReBroadcast bool                 `json:"reBroadcast"`
}

type Subscriber interface {
	Send(message Message) error
}