websocket

Documentation

Index

• Variables
• func Dial(url string, args ...interface{}) (net.Conn, error)
• func Listen(addr string, upgrader *websocket.Upgrader) (net.Listener, error)
• type Conn
  • func (c *Conn) HandleWebsocket(handler func())
  • func (c *Conn) Read(b []byte) (int, error)
  • func (c *Conn) SetDeadline(t time.Time) error
  • func (c *Conn) Write(b []byte) (int, error)
• type Listener
  • func (ln *Listener) Accept() (net.Conn, error)
  • func (ln *Listener) Addr() net.Addr
  • func (ln *Listener) Close() error
  • func (ln *Listener) Handler(w http.ResponseWriter, r *http.Request)

Variables

var (
	// ErrClosed .
	ErrClosed = errors.New("websocket listener closed")
	// ErrInvalidMessage .
	ErrInvalidMessage = errors.New("invalid message")
	// ErrInvalidMessageType .
	ErrInvalidMessageType = errors.New("invalid message type")
)

Functions

func Dial

func Dial(url string, args ...interface{}) (net.Conn, error)

Dial wraps websocket dial

func Listen

func Listen(addr string, upgrader *websocket.Upgrader) (net.Listener, error)

Listen wraps websocket listen

Types

type Conn

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

Conn wraps websocket.Conn to net.Conn

func (*Conn) HandleWebsocket

func (c *Conn) HandleWebsocket(handler func())

HandleWebsocket .

func (*Conn) Read

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

Read .

func (*Conn) SetDeadline

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

SetDeadline .

func (*Conn) Write

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

Write .

type Listener

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

Listener .

func (*Listener) Accept

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

Accept .

func (*Listener) Addr

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

Addr .

func (*Listener) Close

func (ln *Listener) Close() error

Close .

func (*Listener) Handler

func (ln *Listener) Handler(w http.ResponseWriter, r *http.Request)

Handler .