wsconn

Documentation

Index

• func DialCustomWS(addr string, dialer *websocket.Dialer) (net.Conn, error)
• func DialWS(addr string) (net.Conn, error)
• func WSClient(addr string, conn net.Conn, readBufSize, writeBufSize int) (net.Conn, error)
• func WSServe(addr string, backlog int, innerListener net.Listener, ...) (net.Listener, error)
• type Conn
  • func WrapConn(conn *websocket.Conn) *Conn
  • func (c *Conn) Close() error
  • func (c *Conn) CloseChan() <-chan struct{}
  • func (c *Conn) LocalAddr() net.Addr
  • func (c *Conn) Read(b []byte) (n int, err error)
  • func (c *Conn) RemoteAddr() net.Addr
  • func (c *Conn) SetDeadline(t time.Time) error
  • func (c *Conn) SetReadDeadline(t time.Time) error
  • func (c *Conn) SetWriteDeadline(t time.Time) error
  • func (c *Conn) Write(b []byte) (n int, err error)
• type HttpHandler
  • func (h HttpHandler) ServeHTTP(response http.ResponseWriter, request *http.Request)
• type Listener
  • func (l *Listener) Accept() (net.Conn, error)
  • func (l *Listener) Addr() net.Addr
  • func (l *Listener) Close() error

Functions

func DialCustomWS

func DialCustomWS(addr string, dialer *websocket.Dialer) (net.Conn, error)

func DialWS

func DialWS(addr string) (net.Conn, error)

func WSClient

func WSClient(addr string, conn net.Conn, readBufSize, writeBufSize int) (net.Conn, error)

func WSServe

func WSServe(addr string, backlog int, innerListener net.Listener, readBufSize, writeBufSize int) (net.Listener, error)

when "innerListener" is set to null, will start listening on address defined in "addr"

Types

type Conn

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

func WrapConn

func WrapConn(conn *websocket.Conn) *Conn

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) CloseChan

func (c *Conn) CloseChan() <-chan struct{}

func (*Conn) LocalAddr

func (c *Conn) LocalAddr() net.Addr

func (*Conn) Read

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

func (*Conn) RemoteAddr

func (c *Conn) RemoteAddr() net.Addr

func (*Conn) SetDeadline

func (c *Conn) SetDeadline(t time.Time) error

func (*Conn) SetReadDeadline

func (c *Conn) SetReadDeadline(t time.Time) error

func (*Conn) SetWriteDeadline

func (c *Conn) SetWriteDeadline(t time.Time) error

func (*Conn) Write

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

type HttpHandler

type HttpHandler func(response http.ResponseWriter, request *http.Request)

func (HttpHandler) ServeHTTP

func (h HttpHandler) ServeHTTP(response http.ResponseWriter, request *http.Request)

type Listener

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

func (*Listener) Accept

func (l *Listener) Accept() (net.Conn, error)

func (*Listener) Addr

func (l *Listener) Addr() net.Addr

func (*Listener) Close

func (l *Listener) Close() error