ws

package

v0.1.0 Latest Latest Go to latest Published: Jan 23, 2024 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ConnectType int

const (
	Connect ConnectType = iota
	Reconnect
)

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

func NewWsClient(url string, imp WsImp, exchangeType constant.ExchangeType, pingInterval, pongTimeout time.Duration) *WsClient

NewWsClient 新建Ws客户端

func (ws *WsClient) Close()

func (ws *WsClient) Dial(typ ConnectType) error

func (ws *WsClient) SetPingInterval(t time.Duration)

func (ws *WsClient) SetRecvPingTime(t time.Time)

func (ws *WsClient) SetRecvPongTime(t time.Time)

func (ws *WsClient) SetpPongTimeout(t time.Duration)

func (ws *WsClient) WatchClosed()

用于监控ws是否断开

func (ws *WsClient) Write(req interface{}) error

func (ws *WsClient) WriteBytes(bs []byte)

type WsImp interface {
	OnConnected(*WsClient, ConnectType)
	Handle(*WsClient, []byte)
	Ping(*WsClient)
}