broadcast

Apr 1, 2024

Changes in this version

type HTTPBroadcaster

+ func (s *HTTPBroadcaster) Prepare() error

type HTTPConfig

+ AddCORSHeaders bool

+ CORSHosts string

+ SecretBase string

+ func (c *HTTPConfig) IsSecured() bool

Jul 8, 2023

Changes in this version

+ type Broadcaster interface

+ IsFanout func() bool

+ Shutdown func() error

+ Start func(done chan (error)) error

+ type HTTPBroadcaster struct

+ func NewHTTPBroadcaster(node Handler, config *HTTPConfig) *HTTPBroadcaster

+ func (HTTPBroadcaster) IsFanout() bool

+ func (s *HTTPBroadcaster) Handler(w http.ResponseWriter, r *http.Request)

+ func (s *HTTPBroadcaster) Shutdown() error

+ func (s *HTTPBroadcaster) Start(done chan (error)) error

+ type HTTPConfig struct

+ Path string

+ Port int

+ Secret string

+ func NewHTTPConfig() HTTPConfig

+ type Handler interface

+ HandleBroadcast func(json []byte)

+ HandlePubSub func(json []byte)

+ type LegacyNATSBroadcaster struct

+ func NewLegacyNATSBroadcaster(node Handler, c *nconfig.NATSConfig) *LegacyNATSBroadcaster

+ func (LegacyNATSBroadcaster) IsFanout() bool

+ func (s *LegacyNATSBroadcaster) Shutdown() error

+ func (s *LegacyNATSBroadcaster) Start(done chan (error)) error

+ type LegacyRedisBroadcaster struct

+ func NewLegacyRedisBroadcaster(node Handler, config *rconfig.RedisConfig) *LegacyRedisBroadcaster

+ func (LegacyRedisBroadcaster) IsFanout() bool

+ func (s *LegacyRedisBroadcaster) Shutdown() error

+ func (s *LegacyRedisBroadcaster) Start(done chan (error)) error

+ type RedisBroadcaster struct

+ func NewRedisBroadcaster(node Handler, config *rconfig.RedisConfig) *RedisBroadcaster

+ func (s *RedisBroadcaster) IsFanout() bool

+ func (s *RedisBroadcaster) Shutdown() error

+ func (s *RedisBroadcaster) Start(done chan error) error