wsProxy

Documentation

Index

• Constants
• type WsBridge
  • func NewWsbridge(conn *websocket.Conn) (*WsBridge, error)
  • func (u *WsBridge) Close()
  • func (u *WsBridge) OnDisconnect(conn *pollio.Conn, err error)
  • func (u *WsBridge) OnRequest(conn *pollio.Conn, data []byte)
  • func (u *WsBridge) Receive(data []byte) error
• type WsProxy
  • func NewWsProxy() *WsProxy
  • func (w *WsProxy) AddClient(conn *websocket.Conn) (*WsBridge, error)
  • func (w *WsProxy) DelClient(conn *websocket.Conn)
  • func (w *WsProxy) GetClient(conn *websocket.Conn) (*WsBridge, bool)
  • func (w *WsProxy) OnConnect(conn *websocket.Conn)
  • func (w *WsProxy) OnDisconnect(conn *websocket.Conn, err error)
  • func (w *WsProxy) OnMessage(conn *websocket.Conn, messageType websocket.MessageType, data []byte)
  • func (ws *WsProxy) Start(addr, pem, key string) error

Constants

const SockAddr = "/tmp/cp9.sock"

Types

type WsBridge

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

func NewWsbridge

func NewWsbridge(conn *websocket.Conn) (*WsBridge, error)

func (*WsBridge) Close

func (u *WsBridge) Close()

func (*WsBridge) OnDisconnect

func (u *WsBridge) OnDisconnect(conn *pollio.Conn, err error)

func (*WsBridge) OnRequest

func (u *WsBridge) OnRequest(conn *pollio.Conn, data []byte)

func (*WsBridge) Receive

func (u *WsBridge) Receive(data []byte) error

type WsProxy

type WsProxy struct {
	Clients *sync.Map
	Srv     *iohttp.Server
	// contains filtered or unexported fields
}

func NewWsProxy

func NewWsProxy() *WsProxy

func (*WsProxy) AddClient

func (w *WsProxy) AddClient(conn *websocket.Conn) (*WsBridge, error)

func (*WsProxy) DelClient

func (w *WsProxy) DelClient(conn *websocket.Conn)

func (*WsProxy) GetClient

func (w *WsProxy) GetClient(conn *websocket.Conn) (*WsBridge, bool)

func (*WsProxy) OnConnect

func (w *WsProxy) OnConnect(conn *websocket.Conn)

func (*WsProxy) OnDisconnect

func (w *WsProxy) OnDisconnect(conn *websocket.Conn, err error)

func (*WsProxy) OnMessage

func (w *WsProxy) OnMessage(conn *websocket.Conn, messageType websocket.MessageType, data []byte)

func (*WsProxy) Start

func (ws *WsProxy) Start(addr, pem, key string) error