proxy

package

v0.0.1 Latest Latest Go to latest Published: Dec 23, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

func WSHTTPHandler(w http.ResponseWriter, r *http.Request, wsl *WSListener)

wsHandler handles an inbound HTTP WS connection.

func WSHandle(c *websocket.Conn, wsl *WSListener)

wsHandler handles an inbound WS connection.

type UpdateListener interface {
	// What just changed and the new full state.
	Update(update, full map[string]interface{})
}

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

func NewWSDialer() (*WSDialer, error)

func (d *WSDialer) Dial(context context.Context, url string) (*websocket.Conn, *http.Response, error)

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

A WSListener represents a connection to a Scoreboard, which listens to WS updates and forwards them on.

func NewWSListener(kf *keyfilter.KeyFilter) *WSListener

func (wsl *WSListener) AddListener(l UpdateListener)

AddListener adds a listener.

The initial update will be in the same thread.

func (wsl *WSListener) Receive(w http.ResponseWriter, r *http.Request)

Receive uses an inbound WS connection. This is an alternative to Run.

func (wsl *WSListener) RemoveListener(l UpdateListener)

AddListener removes a listener.

func (wsl *WSListener) Run(url string, dialer *WSDialer)

Run keeps a WS connection open to the given URL.

func (wsl *WSListener) Status() (time.Time, int, map[string]interface{})