(watcherID string)
| 22 | } |
| 23 | |
| 24 | func (k *Kontrol) cancelWatcher(watcherID string) error { |
| 25 | k.watchersMutex.Lock() |
| 26 | defer k.watchersMutex.Unlock() |
| 27 | watcher, ok := k.watchers[watcherID] |
| 28 | if !ok { |
| 29 | return errors.New("Watcher not found") |
| 30 | } |
| 31 | watcher.Stop() |
| 32 | delete(k.watchers, watcherID) |
| 33 | return nil |
| 34 | } |
| 35 | |
| 36 | // TODO watchAndSendKiteEvents takes too many arguments. Refactor it. |
| 37 | func (k *Kontrol) watchAndSendKiteEvents( |