(message WatcherUpdate)
| 111 | } |
| 112 | |
| 113 | func (w *Watcher) broadcast(message WatcherUpdate) { |
| 114 | wps.Broker.Publish(wps.WaveEvent{ |
| 115 | Event: wps.Event_Config, |
| 116 | Data: message, |
| 117 | }) |
| 118 | w.notifyHandlers(message.FullConfig) |
| 119 | } |
| 120 | |
| 121 | func (w *Watcher) RegisterUpdateHandler(handler ConfigUpdateHandler) { |
| 122 | w.mutex.Lock() |
no test coverage detected