ws

Documentation

Index

• func FrameReader(r io.Reader, server bool) io.Reader
• func FrameWriter(w io.Writer, server bool) io.Writer
• func NewWSDialer(s string, d proxy.Dialer) (proxy.Dialer, error)
• func NewWSSDialer(s string, d proxy.Dialer) (proxy.Dialer, error)
• func NewWSSServer(s string, p proxy.Proxy) (proxy.Server, error)
• func NewWSServer(s string, p proxy.Proxy) (proxy.Server, error)
• type ClientConn
  • func (c *ClientConn) Handshake(host, path, origin string) error
  • func (c *ClientConn) Read(b []byte) (n int, err error)
  • func (c *ClientConn) Write(b []byte) (n int, err error)
• type ServerConn
  • func (c *ServerConn) Handshake(host, path string) error
  • func (c *ServerConn) Read(b []byte) (n int, err error)
  • func (c *ServerConn) Write(b []byte) (n int, err error)
• type WS
  • func NewWS(s string, d proxy.Dialer, p proxy.Proxy, withTLS bool) (*WS, error)
  • func (s *WS) Addr() string
  • func (s *WS) Dial(network, addr string) (net.Conn, error)
  • func (s *WS) DialUDP(network, addr string) (net.PacketConn, net.Addr, error)
  • func (s *WS) ListenAndServe()
  • func (s *WS) NewClientConn(rc net.Conn) (*ClientConn, error)
  • func (s *WS) NewServerConn(rc net.Conn) (*ServerConn, error)
  • func (s *WS) Serve(cc net.Conn)

Functions

func FrameReader

func FrameReader(r io.Reader, server bool) io.Reader

FrameReader returns a chunked reader.

func FrameWriter

func FrameWriter(w io.Writer, server bool) io.Writer

FrameWriter returns a frame writer.

func NewWSDialer

func NewWSDialer(s string, d proxy.Dialer) (proxy.Dialer, error)

NewWSDialer returns a ws proxy dialer.

func NewWSSDialer

func NewWSSDialer(s string, d proxy.Dialer) (proxy.Dialer, error)

NewWSSDialer returns a wss proxy dialer.

func NewWSSServer

func NewWSSServer(s string, p proxy.Proxy) (proxy.Server, error)

NewWSSServer returns a wss transport server.

func NewWSServer

func NewWSServer(s string, p proxy.Proxy) (proxy.Server, error)

NewWSServer returns a ws transport server.

Types

type ClientConn

type ClientConn struct {
	net.Conn
	// contains filtered or unexported fields
}

ClientConn is a connection to ws server.

func (*ClientConn) Handshake

func (c *ClientConn) Handshake(host, path, origin string) error

Handshake handshakes with the server using HTTP to request a protocol upgrade.

func (*ClientConn) Read

func (c *ClientConn) Read(b []byte) (n int, err error)

func (*ClientConn) Write

func (c *ClientConn) Write(b []byte) (n int, err error)

type ServerConn

type ServerConn struct {
	net.Conn
	// contains filtered or unexported fields
}

ServerConn is a connection to ws client.

func (*ServerConn) Handshake

func (c *ServerConn) Handshake(host, path string) error

Handshake handshakes with the client.

func (*ServerConn) Read

func (c *ServerConn) Read(b []byte) (n int, err error)

func (*ServerConn) Write

func (c *ServerConn) Write(b []byte) (n int, err error)

type WS

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

WS is the base ws proxy struct.

func NewWS

func NewWS(s string, d proxy.Dialer, p proxy.Proxy, withTLS bool) (*WS, error)

NewWS returns a websocket proxy.

func (*WS) Addr

func (s *WS) Addr() string

Addr returns forwarder's address.

func (*WS) Dial

func (s *WS) Dial(network, addr string) (net.Conn, error)

Dial connects to the address addr on the network net via the proxy.

func (*WS) DialUDP

func (s *WS) DialUDP(network, addr string) (net.PacketConn, net.Addr, error)

DialUDP connects to the given address via the proxy.

func (*WS) ListenAndServe

func (s *WS) ListenAndServe()

ListenAndServe listens on server's addr and serves connections.

func (*WS) NewClientConn

func (s *WS) NewClientConn(rc net.Conn) (*ClientConn, error)

NewClientConn creates a new ws client connection.

func (*WS) NewServerConn

func (s *WS) NewServerConn(rc net.Conn) (*ServerConn, error)

NewServerConn creates a new ws server connection.

func (*WS) Serve

func (s *WS) Serve(cc net.Conn)

Serve serves a connection.