sockjsclient

README

sockjs-go-client

Documentation

Index

• type Client
  • func NewClient(address string) (*Client, error)
  • func (c *Client) Info() (*Info, error)
  • func (c *Client) ReadMessage(p interface{}) error
  • func (c *Client) WriteMessage(p interface{}) error
• type Connection
• type Info
• type WebSocket
  • func NewWebSocket(address string) (*WebSocket, error)
  • func (w *WebSocket) Close() error
  • func (w *WebSocket) Loop()
  • func (w *WebSocket) ReadJSON(v interface{}) error
  • func (w *WebSocket) WriteJSON(v interface{}) error
• type XHR
  • 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

Types

type Client

type Client struct {
	Connection Connection

	WebSockets   bool
	Address      string
	ReadBufSize  int
	WriteBufSize int

	Reconnected chan struct{}
}

func NewClient

func NewClient(address string) (*Client, error)

func (*Client) Info

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

func (*Client) ReadMessage

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

func (*Client) WriteMessage

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

type Connection

type Connection interface {
	ReadJSON(interface{}) error
	WriteJSON(interface{}) error
	Close() error
}

type Info

type Info struct {
	WebSocket    bool     `json:"websocket"`
	CookieNeeded bool     `json:"cookie_needed"`
	Origins      []string `json:"origins"`
	Entropy      int      `json:"entropy"`
}

type WebSocket

type WebSocket struct {
	sync.Mutex
	Address          string
	TransportAddress string
	ServerID         string
	SessionID        string
	Connection       *websocket.Conn
	Inbound          chan []byte
	Reconnected      chan struct{}
}

func NewWebSocket

func NewWebSocket(address string) (*WebSocket, error)

func (*WebSocket) Close

func (w *WebSocket) Close() error

func (*WebSocket) Loop

func (w *WebSocket) Loop()

func (*WebSocket) ReadJSON

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

func (*WebSocket) WriteJSON

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

type XHR

type XHR struct {
	Address          string
	TransportAddress string
	ServerID         string
	SessionID        string
	Inbound          chan []byte
	Done             chan bool
	// contains filtered or unexported fields
}

func NewXHR

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

func (*XHR) Close

func (x *XHR) Close() error

func (*XHR) GetSessionState

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

func (*XHR) Init

func (x *XHR) Init() error

func (*XHR) ReadJSON

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

func (*XHR) StartReading

func (x *XHR) StartReading()

func (*XHR) WriteJSON

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