conns

Feb 28, 2017

Changes in this version

+ type QueuedMessage struct

+ Payload []byte

+ UsePrepared bool

+ func NewQueuedMessage(payload []byte, usePrepared bool) *QueuedMessage

+ func (m *QueuedMessage) Len() int

+ func (m *QueuedMessage) Prepared() *websocket.PreparedMessage

Dec 17, 2016

Changes in this version

+ var DefaultDisconnectAdvice = &DisconnectAdvice

+ var ShutdownSemaphoreChanBufferSize = 1000

+ type AdminConn interface

+ Close func(*DisconnectAdvice) error

+ Handle func(message []byte) error

+ Send func(message []byte) error

+ UID func() string

+ type AdminHub interface

+ Add func(c AdminConn) error

+ Broadcast func(message []byte) error

+ NumAdmins func() int

+ Remove func(c AdminConn) error

+ Shutdown func() error

+ func NewAdminHub() AdminHub

+ type ClientConn interface

+ Channels func() []string

+ Close func(*DisconnectAdvice) error

+ Handle func(message []byte) error

+ Send func(message []byte) error

+ UID func() string

+ Unsubscribe func(ch string) error

+ User func() string

+ type ClientHub interface

+ Add func(c ClientConn) error

+ AddSub func(ch string, c ClientConn) (bool, error)

+ Broadcast func(ch string, message []byte) error

+ Channels func() []string

+ NumChannels func() int

+ NumClients func() int

+ NumSubscribers func(ch string) int

+ NumUniqueClients func() int

+ Remove func(c ClientConn) error

+ RemoveSub func(ch string, c ClientConn) (bool, error)

+ Shutdown func() error

+ UserConnections func(user string) map[string]ClientConn

+ func NewClientHub() ClientHub

+ type DisconnectAdvice struct

+ Reason string

+ Reconnect bool

+ func (a *DisconnectAdvice) JSONString() (string, error)

+ type Session interface

+ Close func(*DisconnectAdvice) error

+ Send func([]byte) error