Function initWatchers

watcher.go:18–43

(o *opt)

var restartWorkers atomic.Bool

func initWatchers(o *opt) error {
	watchPatterns := make([]*watcher.PatternGroup, 0, len(o.hotReload))

	for _, o := range o.workers {
		if len(o.watch) == 0 {
			continue
		}

		watcherIsEnabled = true
		watchPatterns = append(watchPatterns, &watcher.PatternGroup{Patterns: o.watch, Callback: func(_ []*watcherGo.Event) {
			restartWorkers.Store(true)
		}})
	}

	if watcherIsEnabled {
		watchPatterns = append(watchPatterns, &watcher.PatternGroup{
			Callback: func(_ []*watcherGo.Event) {
				if restartWorkers.Swap(false) {
					RestartWorkers()
				}
			},
		})
	}

	return watcher.InitWatcher(globalCtx, globalLogger, append(watchPatterns, o.hotReload...))
}

func drainWatchers() {
	watcher.DrainWatcher()