Documentation
¶
Index ¶
- func HeaderMiddleware(headers http.Header) func(http.Handler) http.Handler
- func NewFileServer(dir string, useGzip bool) http.Handler
- func NewWatcherFn(ctx context.Context, cfg WatcherConfig, b *Broadcaster) (func(), error)
- func NewWebsocketHandler(b *Broadcaster) http.HandlerFunc
- type Broadcaster
- type Subscriber
- type WatcherConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HeaderMiddleware ¶
HeaderMiddleware returns a middleware that sets one or more values per header key
func NewWatcherFn ¶
func NewWatcherFn(ctx context.Context, cfg WatcherConfig, b *Broadcaster) (func(), error)
func NewWebsocketHandler ¶
func NewWebsocketHandler(b *Broadcaster) http.HandlerFunc
Types ¶
type Broadcaster ¶
type Broadcaster struct {
// contains filtered or unexported fields
}
Broadcaster struct manages subscribers and broadcasting events to them.
func NewBroadcaster ¶
func NewBroadcaster() *Broadcaster
func (*Broadcaster) AddSubscriber ¶
func (b *Broadcaster) AddSubscriber() Subscriber
AddSubscriber adds a new subscriber channel to the broadcaster.
func (*Broadcaster) Broadcast ¶
func (b *Broadcaster) Broadcast(message string)
Broadcast sends the message to all active subscribers.
func (*Broadcaster) Remove ¶
func (b *Broadcaster) Remove(ch Subscriber)
Remove removes a subscriber channel from the broadcaster.
type Subscriber ¶
type Subscriber chan string
type WatcherConfig ¶
Click to show internal directories.
Click to hide internal directories.