Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

connectionutils

package

Go to main page

Versions in this module

v0

v0.3.0

Oct 30, 2025

v0.2.0

Jul 17, 2025

v0.1.0

Jan 3, 2025

Changes in this version

+ const Closed

+ const Connected

+ const Connecting

+ const Disconnected

+ const LobbySessionID

+ const Reconnecting

+ func DecodeWSMessage(msg string) map[string]interface

+ type ConnectionManager interface

+ Close func() error

+ Get func() *WSConnection

+ Save func(wsConnection *WSConnection)

+ type LobbyWebSocketClient struct

+ WSConn *WSConnection

+ func NewLobbyWebSocketClient(wsConn *WSConnection) *LobbyWebSocketClient

+ func (c *LobbyWebSocketClient) ClearData()

+ func (c *LobbyWebSocketClient) Close() error

+ func (c *LobbyWebSocketClient) Connect(reconnecting bool) (bool, error)

+ func (c *LobbyWebSocketClient) Get() *WSConnection

+ func (c *LobbyWebSocketClient) GetData(key string) interface{}

+ func (c *LobbyWebSocketClient) HasData(key string) bool

+ func (c *LobbyWebSocketClient) OnConnect(reconnecting bool)

+ func (c *LobbyWebSocketClient) OnDisconnect(code int32, reason string)

+ func (c *LobbyWebSocketClient) OnMessage(msg string)

+ func (c *LobbyWebSocketClient) ReadWSMessage(done chan struct{}, messageHandler func(message []byte))

+ func (c *LobbyWebSocketClient) ReconnectDelay(numberOfAttempts int32) float32

+ func (c *LobbyWebSocketClient) Save(conn *WSConnection)

+ func (c *LobbyWebSocketClient) Send(code int, message string) error

+ func (c *LobbyWebSocketClient) SetData(key string, value interface{})

+ func (c *LobbyWebSocketClient) ShouldReconnect(code int, reason string, numberOfAttempts int) bool

+ func (c *LobbyWebSocketClient) WSHeartbeat(done chan struct{})

+ type WSConnection struct

+ Conn *websocket.Conn

+ Data map[string]interface{}

+ EnableAutoReconnect bool

+ Header http.Header

+ MaxReconnectAttempts int

+ MessageHandler WSConnectionMessageHandler

+ Meta map[string]interface{}

+ Mu sync.RWMutex

+ MuStatus sync.RWMutex

+ StatusHandler WSConnectionStatusHandler

+ func NewWSConnection(configRepo repository.ConfigRepository, tokenRepo repository.TokenRepository, ...) (*WSConnection, error)

+ func NewWebsocketConnection(configRepo repository.ConfigRepository, tokenRepo repository.TokenRepository, ...) (*WSConnection, error)

+ func (c *WSConnection) Close(code int, reason string) error

+ func (c *WSConnection) DefaultCloseHandler(code int, reason string) error

+ func (c *WSConnection) DefaultPongHandler(text string) error

+ func (c *WSConnection) Dial(url string, headers http.Header) (*websocket.Conn, error)

+ func (c *WSConnection) GetData(key string) interface{}

+ func (c *WSConnection) GetStatus() string

+ func (c *WSConnection) Lock(location string)

+ func (c *WSConnection) SetStatus(status string)

+ func (c *WSConnection) Unlock(location string)

+ type WSConnectionMessageHandler func(msg []byte)

+ type WSConnectionOption func(wsConn *WSConnection) error

+ func WithEnableAutoReconnect() WSConnectionOption

+ func WithMaxReconnectAttempts(maxReconnectAttempts int) WSConnectionOption

+ func WithMessageHandler(handler WSConnectionMessageHandler) WSConnectionOption

+ func WithScheme(scheme string) WSConnectionOption

+ func WithStatusHandler(handler WSConnectionStatusHandler) WSConnectionOption

+ func WithToken(token string) WSConnectionOption

+ type WSConnectionStatusHandler func(status string)

v0.1.0-alpha.7

Sep 6, 2024