Function WatchChanges

main.go:1171–1197

(filename string, updated chan struct{}, l *rate.Limiter)

}

func WatchChanges(filename string, updated chan struct{}, l *rate.Limiter) {
	watcher, err := fsnotify.NewWatcher()
	capture(err)
	defer captureFunc(watcher.Close)
	done := make(chan bool)
	go func() {
		for {
			select {
			case event := <-watcher.Events:
				fmt.Println(event)
				if l != nil {
					if l.Allow() {
						updated <- struct{}{}
					} else {
						fmt.Println("skipping")
					}
				}
			case err := <-watcher.Errors:
				capture(err)
			}
		}
	}()
	if err := watcher.Add(filename); err != nil {
		capture(err)
	}
	<-done
}

func main() {
	cfg, err := loadConfig(configFile)