transport

Sep 14, 2017

Changes in this version

+ var ErrAcceptAfterClose = errors.New("accept after close")

+ var ErrNotBinary = errors.New("received web socket message is not binary")

+ var ErrUnsupportedProtocol = errors.New("unsupported protocol")

+ type BaseConn struct

+ func NewBaseConn(c Carrier) *BaseConn

+ func (c *BaseConn) BufferedSend(pkt packet.Packet) error

+ func (c *BaseConn) Close() error

+ func (c *BaseConn) Receive() (packet.Packet, error)

+ func (c *BaseConn) Send(pkt packet.Packet) error

+ func (c *BaseConn) SetReadLimit(limit int64)

+ func (c *BaseConn) SetReadTimeout(timeout time.Duration)

+ type Carrier interface

+ SetReadDeadline func(time.Time) error

+ type Conn interface

+ BufferedSend func(pkt packet.Packet) error

+ Close func() error

+ LocalAddr func() net.Addr

+ Receive func() (packet.Packet, error)

+ RemoteAddr func() net.Addr

+ Send func(pkt packet.Packet) error

+ SetReadLimit func(limit int64)

+ SetReadTimeout func(timeout time.Duration)

+ func Dial(urlString string) (Conn, error)

+ type Dialer struct

+ DefaultTCPPort string

+ DefaultTLSPort string

+ DefaultWSPort string

+ DefaultWSSPort string

+ RequestHeader http.Header

+ TLSConfig *tls.Config

+ func NewDialer() *Dialer

+ func (d *Dialer) Dial(urlString string) (Conn, error)

+ type Launcher struct

+ TLSConfig *tls.Config

+ func NewLauncher() *Launcher

+ func (l *Launcher) Launch(urlString string) (Server, error)

+ type NetConn struct

+ func NewNetConn(conn net.Conn) *NetConn

+ func (c *NetConn) LocalAddr() net.Addr

+ func (c *NetConn) RemoteAddr() net.Addr

+ func (c *NetConn) UnderlyingConn() net.Conn

+ type NetServer struct

+ func NewNetServer(address string) (*NetServer, error)

+ func NewSecureNetServer(address string, config *tls.Config) (*NetServer, error)

+ func (s *NetServer) Accept() (Conn, error)

+ func (s *NetServer) Addr() net.Addr

+ func (s *NetServer) Close() error

+ type Server interface

+ Accept func() (Conn, error)

+ Addr func() net.Addr

+ Close func() error

+ func Launch(urlString string) (Server, error)

+ type WebSocketConn struct

+ func NewWebSocketConn(conn *websocket.Conn) *WebSocketConn

+ func (c *WebSocketConn) LocalAddr() net.Addr

+ func (c *WebSocketConn) RemoteAddr() net.Addr

+ func (c *WebSocketConn) UnderlyingConn() *websocket.Conn

+ type WebSocketServer struct

+ func NewSecureWebSocketServer(address string, config *tls.Config) (*WebSocketServer, error)

+ func NewWebSocketServer(address string) (*WebSocketServer, error)

+ func (s *WebSocketServer) Accept() (Conn, error)

+ func (s *WebSocketServer) Addr() net.Addr

+ func (s *WebSocketServer) Close() error

+ func (s *WebSocketServer) SetFallback(handler http.Handler)

+ func (s *WebSocketServer) SetOriginChecker(fn func(r *http.Request) bool)