websocket

May 18, 2023

Changes in this version

+ const BindOp

+ const StdinOp

+ type Client struct

+ Address string

+ Connection Connection

+ ReadBufSize int

+ Reconnected chan struct{}

+ WebSockets bool

+ WriteBufSize int

+ func NewClient(address string, sessionId string, stop chan struct{}) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Info() (*Info, error)

+ func (c *Client) ReadMessage(p interface{}) error

+ func (c *Client) WriteMessage(p interface{}) error

+ type Connection interface

+ Close func() error

+ ReadJSON func(interface{}) error

+ WriteJSON func(interface{}) error

+ type Data struct

+ Data string

+ Op string

+ SessionID string

+ func GetBindData(sessionId string) *Data

+ func GetOpData(op string) *Data

+ func (data *Data) GetWriteMessage() (string, error)

+ type Info struct

+ CookieNeeded bool

+ Entropy int

+ Origins []string

+ WebSocket bool

+ type WebSocket struct

+ Address string

+ Connection *websocket.Conn

+ Inbound chan []byte

+ Reconnected chan struct{}

+ ServerID string

+ SessionID string

+ Stop chan struct{}

+ TransportAddress string

+ func NewWebSocket(address string, sessionId string, stop chan struct{}) (*WebSocket, error)

+ func (w *WebSocket) Close() error

+ func (w *WebSocket) Loop(sessionId string)

+ func (w *WebSocket) ReadJSON(v interface{}) error

+ func (w *WebSocket) WriteJSON(v interface{}) error

+ type XHR struct

+ Address string

+ Done chan bool

+ Inbound chan []byte

+ ServerID string

+ SessionID string

+ TransportAddress string

+ func NewXHR(address string) (*XHR, error)

+ func (x *XHR) Close() error

+ func (x *XHR) GetSessionState() sockjs.SessionState

+ func (x *XHR) Init() error

+ func (x *XHR) ReadJSON(v interface{}) error

+ func (x *XHR) StartReading()

+ func (x *XHR) WriteJSON(v interface{}) error