Documentation ¶
Index ¶
- func DefaultDialer() *websocket.Dialer
- type WsConn
- func (ws *WsConn) Close()
- func (ws *WsConn) Dialer() *websocket.Dialer
- func (ws *WsConn) ReceiveMessage(msg []byte)
- func (ws *WsConn) SendCloseMessage(msg []byte)
- func (ws *WsConn) SendJsonMessage(m interface{}) error
- func (ws *WsConn) SendMessage(msg []byte)
- func (ws *WsConn) SendPingMessage(msg []byte)
- func (ws *WsConn) Subscribe(sub interface{}) error
- type WsParameter
- type WsParameterOption
- func WsAutoReconnectOption(autoReconnect bool) WsParameterOption
- func WsDialerOption(dialer *websocket.Dialer) WsParameterOption
- func WsDumpOption(dump bool) WsParameterOption
- func WsErrorHandleFuncOption(f func(err error)) WsParameterOption
- func WsMessageHandleFuncOption(f func([]byte) error) WsParameterOption
- func WsReSubscribeFuncOption(f func(ws *WsConn) error) WsParameterOption
- func WsReSubscribeOption(reSubscribe bool) WsParameterOption
- func WsReqHeaderOption(key, value string) WsParameterOption
- func WsUrlOption(wsUrl string) WsParameterOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultDialer ¶ added in v1.0.2
Types ¶
type WsConn ¶
type WsConn struct { WsParameter // contains filtered or unexported fields }
func NewWs ¶
func NewWs(opts ...WsParameterOption) *WsConn
func (*WsConn) ReceiveMessage ¶
func (*WsConn) SendCloseMessage ¶
func (*WsConn) SendJsonMessage ¶
func (*WsConn) SendMessage ¶
func (*WsConn) SendPingMessage ¶
type WsParameter ¶
type WsParameter struct { WsUrl string ReqHeaders map[string][]string Dialer *websocket.Dialer MessageHandleFunc func([]byte) error ReSubscribeFunc func(ws *WsConn) error // 短线重连后触发,你可以重新订阅,因为有些订阅跟当前时间相关 ErrorHandleFunc func(err error) AutoReconnect bool // 自动重连(默认: true) ReSubscribe bool // 自动重新订阅(默认: true) IsDump bool // contains filtered or unexported fields }
type WsParameterOption ¶
type WsParameterOption func(p *WsParameter)
func WsAutoReconnectOption ¶
func WsAutoReconnectOption(autoReconnect bool) WsParameterOption
func WsDialerOption ¶ added in v1.0.2
func WsDialerOption(dialer *websocket.Dialer) WsParameterOption
func WsDumpOption ¶
func WsDumpOption(dump bool) WsParameterOption
func WsErrorHandleFuncOption ¶
func WsErrorHandleFuncOption(f func(err error)) WsParameterOption
func WsMessageHandleFuncOption ¶
func WsMessageHandleFuncOption(f func([]byte) error) WsParameterOption
func WsReSubscribeFuncOption ¶ added in v1.0.4
func WsReSubscribeFuncOption(f func(ws *WsConn) error) WsParameterOption
func WsReSubscribeOption ¶ added in v1.0.4
func WsReSubscribeOption(reSubscribe bool) WsParameterOption
func WsReqHeaderOption ¶
func WsReqHeaderOption(key, value string) WsParameterOption
func WsUrlOption ¶
func WsUrlOption(wsUrl string) WsParameterOption
Click to show internal directories.
Click to hide internal directories.