Method broadcastUpdatesLocked

agent/agentcontainers/api.go:749–757

broadcastUpdatesLocked sends the current state to any listening clients. This method assumes that api.mu is held.

()

// broadcastUpdatesLocked sends the current state to any listening clients.
// This method assumes that api.mu is held.
func (api *API) broadcastUpdatesLocked() {
	// Broadcast state changes to WebSocket listeners.
	for _, ch := range api.updateChans {
		select {
		case ch <- struct{}{}:
		default:
		}
	}
}

func (api *API) watchContainers(rw http.ResponseWriter, r *http.Request) {
	ctx := r.Context()