FeedHub

Documentation

Index

• func ServeFeedWs(hub *FeedHub, w http.ResponseWriter, r *http.Request, pingInterval int)
• type FeedClient
• type FeedHub
  • func NewFeedHub() *FeedHub
  • func (h *FeedHub) Run()
• type ReloadFeed

Functions

func ServeFeedWs

func ServeFeedWs(hub *FeedHub, w http.ResponseWriter, r *http.Request, pingInterval int)

ServeFeedWs handles websocket requests from the peer.

Types

type FeedClient

type FeedClient struct {
	// contains filtered or unexported fields
}

FeedClient Client is a middleman between the websocket connection and the hub.

type FeedHub

type FeedHub struct {
	// Registered clients.
	Clients map[*FeedClient]bool

	// Inbound messages from the clients.
	Broadcast chan ReloadFeed

	Quit chan bool
	// contains filtered or unexported fields
}

FeedHub Hub maintains the set of active clients and broadcasts messages to the clients.

func NewFeedHub

func NewFeedHub() *FeedHub

func (*FeedHub) Run

func (h *FeedHub) Run()

type ReloadFeed

type ReloadFeed struct {
}