transport

Documentation

Index

• func MakeLongPoll(msgs interface{}, server Server, w http.ResponseWriter)
• func WebsocketServer(m Server) func(*websocket.Conn)
• type LongPollingConnection
  • func NewLongPollingConnection() *LongPollingConnection
  • func (lp *LongPollingConnection) Close()
  • func (lp *LongPollingConnection) IsConnected() bool
  • func (lp *LongPollingConnection) IsSingleShot() bool
  • func (lp *LongPollingConnection) Send(msgs []protocol.Message) error
  • func (lp *LongPollingConnection) SendJsonp(msgs []protocol.Message, jsonp string) error
• type Server
• type WebSocketConnection
  • func (wc *WebSocketConnection) Close()
  • func (wc *WebSocketConnection) IsConnected() bool
  • func (wc *WebSocketConnection) IsSingleShot() bool
  • func (wc *WebSocketConnection) Send(msgs []protocol.Message) error
  • func (wc *WebSocketConnection) SendJsonp(msgs []protocol.Message, _ string) error

Functions

func MakeLongPoll

func MakeLongPoll(msgs interface{}, server Server, w http.ResponseWriter)

func WebsocketServer

func WebsocketServer(m Server) func(*websocket.Conn)

Types

type LongPollingConnection

type LongPollingConnection struct {
	Closed *atomic.Bool
	// contains filtered or unexported fields
}

func NewLongPollingConnection

func NewLongPollingConnection() *LongPollingConnection

func (*LongPollingConnection) Close

func (lp *LongPollingConnection) Close()

func (*LongPollingConnection) IsConnected

func (lp *LongPollingConnection) IsConnected() bool

func (*LongPollingConnection) IsSingleShot

func (lp *LongPollingConnection) IsSingleShot() bool

func (*LongPollingConnection) Send

func (lp *LongPollingConnection) Send(msgs []protocol.Message) error

func (*LongPollingConnection) SendJsonp

func (lp *LongPollingConnection) SendJsonp(msgs []protocol.Message, jsonp string) error

type Server

type Server interface {
	HandleRequest(interface{}, protocol.Connection)
	Logger() utils.Logger
}

type WebSocketConnection

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

func (*WebSocketConnection) Close

func (wc *WebSocketConnection) Close()

func (*WebSocketConnection) IsConnected

func (wc *WebSocketConnection) IsConnected() bool

func (*WebSocketConnection) IsSingleShot

func (wc *WebSocketConnection) IsSingleShot() bool

func (*WebSocketConnection) Send

func (wc *WebSocketConnection) Send(msgs []protocol.Message) error

func (*WebSocketConnection) SendJsonp

func (wc *WebSocketConnection) SendJsonp(msgs []protocol.Message, _ string) error