transport

Documentation

Index

• type ITransport
• type Polling
  • func NewPolling(opt PollingOptions, sid string) *Polling
  • func (p *Polling) GetName() string
  • func (p *Polling) HandleDataRequest(r *http.Request, w http.ResponseWriter)
  • func (p *Polling) HandlePollRequest(r *http.Request, w http.ResponseWriter) error
  • func (p *Polling) HandleRequest(r *http.Request, w http.ResponseWriter)
  • func (p *Polling) SetHeaders(r *http.Request, w http.ResponseWriter)
  • func (p *Polling) SetReadDeadline(t time.Time) error
  • func (p *Polling) SetWriteDeadline(t time.Time) error
• type PollingOptions
• type PollingType
• type Transport
  • func NewTransport(opt TransportOptions) *Transport
  • func (t *Transport) Close()
  • func (t *Transport) Discard()
  • func (t *Transport) HandleRequest(r *http.Request, w http.ResponseWriter)
  • func (t *Transport) Recv() (packet.Packet, []byte, error)
  • func (t *Transport) Send(pack packet.Packet, data []byte, force bool) bool
• type TransportOptions
• type WSOptions
• type Websocket
  • func NewWebsocket(opt WSOptions, sid string, con *websocket.Conn) *Websocket
  • func (ws *Websocket) GetName() string
  • func (ws *Websocket) SetReadDeadline(t time.Time) error
  • func (ws *Websocket) SetWriteDeadline(t time.Time) error

Types

type ITransport

type ITransport interface {
	GetName() string
	Discard()
	Close()
	Recv() (packet.Packet, []byte, error)
	Send(pack packet.Packet, data []byte, force bool) bool
	//
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error

	HandleRequest(r *http.Request, w http.ResponseWriter)
}

type Polling

type Polling struct {
	*Transport
	PollingOptions PollingOptions
	// contains filtered or unexported fields
}

func NewPolling

func NewPolling(opt PollingOptions, sid string) *Polling

func (*Polling) GetName

func (p *Polling) GetName() string

func (*Polling) HandleDataRequest

func (p *Polling) HandleDataRequest(r *http.Request, w http.ResponseWriter)

func (*Polling) HandlePollRequest

func (p *Polling) HandlePollRequest(r *http.Request, w http.ResponseWriter) error

func (*Polling) HandleRequest

func (p *Polling) HandleRequest(r *http.Request, w http.ResponseWriter)

func (*Polling) SetHeaders

func (p *Polling) SetHeaders(r *http.Request, w http.ResponseWriter)

func (*Polling) SetReadDeadline

func (p *Polling) SetReadDeadline(t time.Time) error

func (*Polling) SetWriteDeadline

func (p *Polling) SetWriteDeadline(t time.Time) error

type PollingOptions

type PollingOptions struct {
	TransportOptions
	Type              PollingType
	MaxHttpBufferSize uint64
	HttpCompression   bool
}

type PollingType

type PollingType int

const (
	XHR   PollingType = 0
	JSONP PollingType = 1
)

type Transport

type Transport struct {
	SupportsBinary bool
	// contains filtered or unexported fields
}

func NewTransport

func NewTransport(opt TransportOptions) *Transport

func (*Transport) Close

func (t *Transport) Close()

func (*Transport) Discard

func (t *Transport) Discard()

func (*Transport) HandleRequest

func (t *Transport) HandleRequest(r *http.Request, w http.ResponseWriter)

func (*Transport) Recv

func (t *Transport) Recv() (packet.Packet, []byte, error)

func (*Transport) Send

func (t *Transport) Send(pack packet.Packet, data []byte, force bool) bool

type TransportOptions

type TransportOptions struct {
	SupportsBinary bool
}

type WSOptions

type WSOptions struct {
	TransportOptions
}

type Websocket

type Websocket struct {
	*Transport
	// contains filtered or unexported fields
}

func NewWebsocket

func NewWebsocket(opt WSOptions, sid string, con *websocket.Conn) *Websocket

func (*Websocket) GetName

func (ws *Websocket) GetName() string

func (*Websocket) SetReadDeadline

func (ws *Websocket) SetReadDeadline(t time.Time) error

func (*Websocket) SetWriteDeadline

func (ws *Websocket) SetWriteDeadline(t time.Time) error