hubx

package module

Go to main page

Versions in this module

v1

v1.0.10

Jul 16, 2020

Changes in this version

type Hubx

+ OnLocalMessage func(msg interface{})

+ func (h *Hubx) LocalChan() chan<- interface{}

type Options

+ LocalChannelSize int

v1.0.9

Jun 20, 2020

Changes in this version

type Hubx

+ func (h *Hubx) GetClients() map[*Client]bool

+ func (h *Hubx) GetOptions() Options

+ func (h *Hubx) IsEmpty() bool

v1.0.8

Jun 19, 2020

Changes in this version

type RedisOptions

+ Redis redis.Options

+ RedisChannel string

v1.0.7

Apr 8, 2020

v1.0.6

Apr 8, 2020

Changes in this version

type Hubx

+ AfterClose func()

v1.0.5

Mar 25, 2020

Changes in this version

type Client

+ func (c *Client) Send() chan<- []byte

type Hubx

+ func (h *Hubx) OnDefault(cb BcListener)

+ func (h *Hubx) OnWsDefault(cb WsListener)

v1.0.4

Mar 25, 2020

Changes in this version

type Hubx

+ func (h *Hubx) Broadcast(subject string, data interface{})

v1.0.3

Mar 25, 2020

v1.0.2

Mar 25, 2020

v1.0.1

Mar 25, 2020

v1.0.0

Mar 25, 2020

Changes in this version

+ const Debug

+ const Error

+ const Trace

+ const Warn

+ var DefaultMarhaller = func(obj interface{}) ([]byte, error)

+ var DefaultUnmarhaller = func(dataBs []byte, obj interface{}) error

+ func DefaultUpgrader() websocket.Upgrader

+ func Go(fn func())

+ func ServeWs(hub *Hubx, w http.ResponseWriter, r *http.Request, upgrader websocket.Upgrader, ...)

+ type BcFilter func(msg PartialMessage, next func())

+ type BcListener func(msg PartialMessage)

+ type Broadcaster interface

+ Close func() chan<- bool

+ Send func() chan<- []byte

+ type Client struct

+ Props sync.Map

+ type Hubx struct

+ AfterJoin UserEvent

+ AfterLeave UserEvent

+ BcListeners map[string]BcListener

+ BeforeJoin func(client *Client) error

+ BeforeLeave UserEvent

+ Marshaller func(obj interface{}) ([]byte, error)

+ RawMessageUnmarhaller func(bs []byte) (PartialMessage, error)

+ Ticker func()

+ Unmarshaller func(dataBs []byte, obj interface{}) error

+ func New(options Options) (*Hubx, error)

+ func (h *Hubx) BroadcastMessage() chan<- []byte

+ func (h *Hubx) BroadcastWs(subject string, msg interface{})

+ func (h *Hubx) Close() chan<- bool

+ func (h *Hubx) CloseAsync()

+ func (h *Hubx) On(subject string, cb BcListener)

+ func (h *Hubx) OnWs(subject string, cb WsListener)

+ func (h *Hubx) Send(subject string, data interface{})

+ func (h *Hubx) SendWs(subject string, data interface{}, clients ...Client)

+ func (h *Hubx) SendWsWithCtx(ctx context.Context, subject string, data interface{}, clients ...Client)

+ func (h *Hubx) SetBroadcaster(broadcaster Broadcaster)

+ func (h *Hubx) Start()

+ func (h *Hubx) Use(filter BcFilter)

+ func (h *Hubx) UseWs(filter WsFilter)

+ type Logger struct

+ func NewLogger(writer io.Writer, module string, level int) *Logger

+ func (l *Logger) Debug(msg string)

+ func (l *Logger) Error(msg string)

+ func (l *Logger) Trace(msg string)

+ func (l *Logger) Warn(msg string)

+ type Message struct

+ Data interface{}

+ Subject string

+ func (m Message) Marshal() ([]byte, error)

+ func (m Message) Unmarshal(result interface{}) error

+ type Options struct

+ ChannelSize int

+ Logger io.Writer

+ LoggerLevel int

+ MaxMessageSize int64

+ PingPeriod time.Duration

+ PongTimeout time.Duration

+ TickerPeriod time.Duration

+ WriteTimeout time.Duration

+ type PartialMessage struct

+ Data json.RawMessage

+ Subject string

+ func DefaultRawMessageUnmarhaller(bs []byte) (PartialMessage, error)

+ func (p *PartialMessage) Marshal() ([]byte, error)

+ func (p *PartialMessage) String() string

+ func (p *PartialMessage) Unmarshal(bs []byte) error

+ func (p *PartialMessage) UnmarshalData(result interface{}) error

+ type RawMessage struct

+ Client *Client

+ Msg []byte

+ type RedisBroadcaster struct

+ func NewRedisBroadcaster(hub *Hubx, options RedisOptions) (*RedisBroadcaster, error)

+ func (r *RedisBroadcaster) Close() chan<- bool

+ func (r *RedisBroadcaster) Send() chan<- []byte

+ func (r *RedisBroadcaster) Start()

+ type RedisOptions struct

+ Channel string

+ ChannelSize int

+ PoolSize int

+ Url string

+ type UserEvent func(client *Client) error

+ type WsFilter func(client *Client, msg PartialMessage, next func())

+ type WsListener func(client *Client, msg PartialMessage)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL