sockjsclient

Documentation

Index

• type DialOptions
• type Rand
• type WebsocketSession
  • func ConnectWebsocketSession(opts *DialOptions) (*WebsocketSession, error)
  • func NewWebsocketSession(conn *websocket.Conn) *WebsocketSession
  • func (w *WebsocketSession) Close(status uint32, reason string) error
  • func (w *WebsocketSession) ID() string
  • func (w *WebsocketSession) Recv() (string, error)
  • func (w *WebsocketSession) RemoteAddr() string
  • func (w *WebsocketSession) Send(str string) error
• type XHRSession
  • func NewXHRSession(opts *DialOptions) (*XHRSession, error)
  • func (x *XHRSession) Close(status uint32, reason string) error
  • func (x *XHRSession) ID() string
  • func (x *XHRSession) Recv() (string, error)
  • func (x *XHRSession) Send(frame string) error

Types

type DialOptions

type DialOptions struct {
	BaseURL                         string
	ReadBufferSize, WriteBufferSize int
	Timeout                         time.Duration
}

type Rand

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

Rand is a threaSafe rand.Rand type

type WebsocketSession

type WebsocketSession struct {
	// contains filtered or unexported fields
}

func ConnectWebsocketSession

func ConnectWebsocketSession(opts *DialOptions) (*WebsocketSession, error)

func NewWebsocketSession

func NewWebsocketSession(conn *websocket.Conn) *WebsocketSession

func (*WebsocketSession) Close

func (w *WebsocketSession) Close(status uint32, reason string) error

Close closes the session with provided code and reason.

func (*WebsocketSession) ID

func (w *WebsocketSession) ID() string

ID returns a session id

func (*WebsocketSession) Recv

func (w *WebsocketSession) Recv() (string, error)

Recv reads one text frame from session

func (*WebsocketSession) RemoteAddr

func (w *WebsocketSession) RemoteAddr() string

func (*WebsocketSession) Send

func (w *WebsocketSession) Send(str string) error

Send sends one text frame to session

type XHRSession

type XHRSession struct {
	// contains filtered or unexported fields
}

func NewXHRSession

func NewXHRSession(opts *DialOptions) (*XHRSession, error)

NewXHRSession returns a new XHRSession, a SockJS client which supports xhr-polling http://sockjs.github.io/sockjs-protocol/sockjs-protocol-0.3.3.html#section-74

func (*XHRSession) Close

func (x *XHRSession) Close(status uint32, reason string) error

func (*XHRSession) ID

func (x *XHRSession) ID() string

func (*XHRSession) Recv

func (x *XHRSession) Recv() (string, error)

func (*XHRSession) Send

func (x *XHRSession) Send(frame string) error