ws_protocol

Documentation

Index

• Constants
• func OptionHandler(c echo.Context) error
• func OriginMiddlewareFunc(next echo.HandlerFunc) echo.HandlerFunc
• type WsConnection
  • func NewWsConnection(conn *websocket.Conn) *WsConnection
  • func (this *WsConnection) Addr() string
  • func (this *WsConnection) Close() error
  • func (this *WsConnection) ConnProtocol() string
  • func (this *WsConnection) ReadMsg() ([]byte, error)
  • func (this *WsConnection) WriteMsg(data []byte) error
• type WsProtocol
  • func NewWsProtocol(clientPath string, h func(conn protocol.Connection) echo.HandlerFunc) *WsProtocol
  • func (this *WsProtocol) Dial(addr string) (protocol.Connection, error)
  • func (this *WsProtocol) ListenAndServe(port int64, onConnect func(conn protocol.Connection)) error

Constants

const WsConnProtocol = "ws"

Functions

func OptionHandler

func OptionHandler(c echo.Context) error

func OriginMiddlewareFunc

func OriginMiddlewareFunc(next echo.HandlerFunc) echo.HandlerFunc

Types

type WsConnection

type WsConnection struct {
	Conn  *websocket.Conn
	Mutex sync.Mutex
	protocol.Connection
}

func NewWsConnection

func NewWsConnection(conn *websocket.Conn) *WsConnection

func (*WsConnection) Addr

func (this *WsConnection) Addr() string

func (*WsConnection) Close

func (this *WsConnection) Close() error

func (*WsConnection) ConnProtocol

func (this *WsConnection) ConnProtocol() string

func (*WsConnection) ReadMsg

func (this *WsConnection) ReadMsg() ([]byte, error)

func (*WsConnection) WriteMsg

func (this *WsConnection) WriteMsg(data []byte) error

WriteMsg send byte array message

type WsProtocol

type WsProtocol struct {
	ClientPath  string
	HandlerFunc func(conn protocol.Connection) echo.HandlerFunc
}

func NewWsProtocol

func NewWsProtocol(clientPath string, h func(conn protocol.Connection) echo.HandlerFunc) *WsProtocol

func (*WsProtocol) Dial

func (this *WsProtocol) Dial(addr string) (protocol.Connection, error)

func (*WsProtocol) ListenAndServe

func (this *WsProtocol) ListenAndServe(port int64, onConnect func(conn protocol.Connection)) error