ws

Documentation

Index

• func NewHandler(opts *fwd.Options, dialer gnatsdgw.Dialer, upgrader *websocket.Upgrader, ...) (http.Handler, error)
• type Conn
  • func (wsc *Conn) Read(b []byte) (n int, err error)
  • func (wsc *Conn) RemoteAddrString() string
  • func (wsc *Conn) SetDeadline(t time.Time) error
  • func (wsc *Conn) Write(b []byte) (n int, err error)

Functions

func NewHandler

func NewHandler(opts *fwd.Options, dialer gnatsdgw.Dialer, upgrader *websocket.Upgrader, mimConnector gnatsdgw.Connector) (http.Handler, error)

NewHandler creates new forwarder to handle websocket connections

Types

type Conn

type Conn struct {
	*websocket.Conn

	// addition info from request
	Request struct {
		Header     http.Header
		Method     string
		URL        *url.URL
		Host       string
		RemoteAddr string
		RequestURI string
	}
	// contains filtered or unexported fields
}

Conn wrapps upgraded *websocket.Conn with addition request info.

func (*Conn) Read

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

func (*Conn) RemoteAddrString

func (wsc *Conn) RemoteAddrString() string

RemoteAddrString returns string in request

func (*Conn) SetDeadline

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

SetDeadline implements the net.Conn

func (*Conn) Write

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