websocket

Jan 25, 2017

Changes in this version

+ type Conn interface

+ Close func() error

+ ReadMessage func() (messageType int, p []byte, err error)

+ SetCloseHandler func(h func(code int, text string) error)

+ WriteControl func(messageType int, data []byte, deadline time.Time) error

+ WriteMessage func(messageType int, data []byte) error

+ func NewWebsocketConn(c *gorilla.Conn) Conn

+ type Dialer interface

+ Dial func(urlStr string, requestHeader http.Header) (Conn, *http.Response, error)

+ type Hub interface

+ Dial func(urlStr string, requestHeader http.Header) (Conn, *http.Response, error)

+ Upgrade func(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (Conn, error)

+ func NewWebsocketHub() Hub

+ type Stream interface

+ Close func() error

+ CloseWrite func() error

+ Flush func() error

+ Read func() (thrift.TStruct, error)

+ Start func() error

+ Write func(thrift.TStruct) error

+ func NewStream(conn Conn, opts *StreamOpts) Stream

+ type StreamClient interface

+ Done func() error

+ Flush func() error

+ Read func() (thrift.TStruct, error)

+ Start func() error

+ Write func(thrift.TStruct) error

+ func NewStreamClient(url string, requestHeader http.Header, dialer Dialer, readMsgType reflect.Type) StreamClient

+ type StreamOpts struct

+ FlushThreshold int

+ PingInterval time.Duration

+ ReadMsgType reflect.Type

+ Server bool

+ type StreamServer interface

+ Done func() (err error)

+ Flush func() (err error)

+ Read func() (msg thrift.TStruct, err error)

+ Start func() error

+ Write func(msg thrift.TStruct) (err error)

+ func NewStreamServer(httpRespWriter http.ResponseWriter, httpRequest *http.Request, ...) StreamServer

+ type Upgrader interface

+ Upgrade func(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (Conn, error)