stream

type BroadcastClient interface {
	Broadcast(message []byte)
}

type Client struct {
	Ip        string
	Referer   string
	UserAgent string
	Width     int
	Height    int
	Cookie    bool
	Language  string
	Platform  string
	Location  string
	Href      string
	Send      chan []byte // message buffered channel

	Connect *websocket.Conn
	// contains filtered or unexported fields
}

type Hub struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type IStreamClient interface {
	Write(payload []byte) error
	Notify(t, b string)
}

type Message struct {
	Id      uuid.UUID              `json:"id"`
	Command string                 `json:"command"`
	Payload map[string]interface{} `json:"payload"`
	Forward string                 `json:"forward"`
	Status  string                 `json:"status"`
	Type    string                 `json:"type"`
}

type StreamService struct {
	Hub *Hub
}