websocket

type Websocket interface {
	OnConnect(cb func())
	ConnectContext(ctx context.Context, addr string, headers http.Header) error
	ConnectWithRetry(parentCtx context.Context, addr string, headers http.Header)
	Wait()
	Read() <-chan []byte
	// WriteJSON writes interface{} encoded as JSON to our connection
	WriteJSON(v interface{}) error
	WriteMessage(messageType int, data []byte) error
	SetTLSConfig(c *tls.Config)
}