(handler ConfigUpdateHandler)
| 119 | } |
| 120 | |
| 121 | func (w *Watcher) RegisterUpdateHandler(handler ConfigUpdateHandler) { |
| 122 | w.mutex.Lock() |
| 123 | defer w.mutex.Unlock() |
| 124 | w.handlers = append(w.handlers, handler) |
| 125 | } |
| 126 | |
| 127 | func (w *Watcher) notifyHandlers(config FullConfigType) { |
| 128 | handlers := w.handlers |
no outgoing calls
no test coverage detected