ws

Documentation

Index

• Constants
• type Conn
  • func NewConn(wsConn *websocket.Conn, lAddr, rAddr *net.TCPAddr) *Conn
  • func (c *Conn) Close() error
  • 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) (int, error)
• type Listener
  • func (l *Listener) Listen(acceptFn func(conn net.Conn)) error
  • func (l *Listener) Shutdown(ctx context.Context) error

Constants

const URLPath = "/relay"

URLPath is the path for the websocket connection.

Types

type Conn

type Conn struct {
	*websocket.Conn
	// contains filtered or unexported fields
}

func NewConn

func NewConn(wsConn *websocket.Conn, lAddr, rAddr *net.TCPAddr) *Conn

func (*Conn) Close

func (c *Conn) Close() error

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) (int, error)

Write writes a binary message with the given payload. It does not block until fill the internal buffer. If the buffer filled up, wait until the buffer is drained or timeout.

type Listener

type Listener struct {
	// Address is the address to listen on.
	Address string
	// TLSConfig is the TLS configuration for the server.
	TLSConfig *tls.Config
	// contains filtered or unexported fields
}

func (*Listener) Listen

func (l *Listener) Listen(acceptFn func(conn net.Conn)) error

func (*Listener) Shutdown

func (l *Listener) Shutdown(ctx context.Context) error