websocket

Documentation

Index

• type WebSocketClient
  • func NewWebSocketClient(onOpen func(ws *WebSocketClient, isReconnecting bool), ...) *WebSocketClient
  • func (ws *WebSocketClient) Connect(webSocketUrl string, attempts int, interval time.Duration, isReconnecting bool) (err error)
  • func (ws *WebSocketClient) Disconnect(isReconnecting bool)
  • func (ws *WebSocketClient) Reconnect(url string, attempts int, interval time.Duration) error
  • func (ws *WebSocketClient) SendJSON(v any) error

Types

type WebSocketClient

type WebSocketClient struct {
	URL *url.URL
	// contains filtered or unexported fields
}

func NewWebSocketClient

func NewWebSocketClient(
	onOpen func(ws *WebSocketClient, isReconnecting bool),
	onClose func(ws *WebSocketClient, isReconnecting bool),
	onMessage func(ws *WebSocketClient, payload []byte),
) *WebSocketClient

func (*WebSocketClient) Connect

func (ws *WebSocketClient) Connect(
	webSocketUrl string,
	attempts int,
	interval time.Duration,
	isReconnecting bool,
) (err error)

func (*WebSocketClient) Disconnect

func (ws *WebSocketClient) Disconnect(isReconnecting bool)

func (*WebSocketClient) Reconnect

func (ws *WebSocketClient) Reconnect(url string, attempts int, interval time.Duration) error

func (*WebSocketClient) SendJSON

func (ws *WebSocketClient) SendJSON(v any) error