Versions in this module Expand all Collapse all v0 v0.0.1 May 4, 2024 Changes in this version + type WebsocketClientBase struct + func NewWebsocketClientBase(baseURL string, reconnectDuration time.Duration) *WebsocketClientBase + func (s *WebsocketClientBase) Conn() *websocket.Conn + func (s *WebsocketClientBase) Connect(ctx context.Context) error + func (s *WebsocketClientBase) EmitConnected(conn *websocket.Conn) + func (s *WebsocketClientBase) EmitDisconnected(conn *websocket.Conn) + func (s *WebsocketClientBase) EmitError(err error) + func (s *WebsocketClientBase) EmitMessage(message []byte) + func (s *WebsocketClientBase) Listen(ctx context.Context) + func (s *WebsocketClientBase) OnConnected(cb func(conn *websocket.Conn)) + func (s *WebsocketClientBase) OnDisconnected(cb func(conn *websocket.Conn)) + func (s *WebsocketClientBase) OnError(cb func(err error)) + func (s *WebsocketClientBase) OnMessage(cb func(message []byte)) + func (s *WebsocketClientBase) Reconnect()
Go to main page