Versions in this module Expand all Collapse all v1 v1.0.2 Nov 28, 2022 v1.0.0 Nov 24, 2022 Changes in this version + type Collector struct + OpenConnectionsCount *atomicFloat64 + PrivateConnectionsCount *atomicFloat64 + PrivateConnectionsGauge int32 + SubscribedChannelsCount *atomicFloat64 + func NewCollector() *Collector + func (c *Collector) OpenConnections(val float64) + func (c *Collector) PrivateConnections(val float64) + func (c *Collector) PrivateConnectionsDec() + func (c *Collector) PrivateConnectionsInc() + func (c *Collector) SubscribedChannels(val float64) + type Connection struct + func NewConnection(id string, userID *string, authFunc func() error) *Connection + func (c Connection) Authenticate() error + func (c Connection) Close() + func (c Connection) ID() string + func (c Connection) Message() <-chan []byte + func (c Connection) SendMessage(data []byte) error + func (c Connection) UserID() *string + func (c Connection) WithError(err error) Connection + type Logger struct + func NewLogger(t *testing.T) *Logger + func (l *Logger) Expected(expected ...interface{}) + func (l Logger) Debug(msg string, keyValues ...interface{}) + func (l Logger) Error(msg string, keyValues ...interface{}) + func (l Logger) Info(msg string, keyValues ...interface{}) + func (l Logger) Warn(msg string, keyValues ...interface{}) + type Store struct + func NewStore(userConnections map[string]common.ConnectionWrapper) *Store + func (s Store) ConnectionByUserID(_ context.Context, _ channel.Channel, userID string) common.ConnectionWrapper + func (s Store) Connections(_ context.Context, _ channel.Channel) []common.ConnectionWrapper + func (s Store) Receive() string + func (s Store) UnsubscribeUserID(_ context.Context, _ string, _ string, ch channel.Channel)