jkws

package

v0.0.0-...-a9e9222 Latest Latest Go to latest Published: Jan 6, 2022 License: GPL-3.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

CMWSHandler base of weboscket handler

func NewCMWSHandler(addr string, port int) (*CMWSHandler, error)

NewCMWSHandler create one cmwshandler

func (ws *CMWSHandler) Add(url string, msgDeal func(*websocket.Conn))

Add pair of url and handler function

func (ws *CMWSHandler) Read(wc *websocket.Conn, data []byte) (int, error)

Read read message

func (ws *CMWSHandler) Start() error

Start start to listen on special port

func (ws *CMWSHandler) StartTls(permfile, keyfile string) error

func (ws *CMWSHandler) Write(wc *websocket.Conn, data []byte) (int, error)

Write write message to special socket wc

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

CMWSHandlerClient handler

func NewWSHandlerClient(addr string, port int, secure bool, baseurl string) (*CMWSHandlerClient, error)

NewWSHandlerClient create ws handler client

func (ws *CMWSHandlerClient) Close()

Close close handler

func (ws *CMWSHandlerClient) Connect(retry int) error

Connect retry count (interval 1 second)

func (ws *CMWSHandlerClient) ConnectTls(retry int) error

func (ws *CMWSHandlerClient) Recv(msg []byte) (int, error)

Recv recv data

func (ws *CMWSHandlerClient) Send(msg []byte, recv bool) (int, error)

Send send data, @recv if recv response

Path	Synopsis
jkwsclient