Function InitWatcher

internal/watcher/watcher.go:57–87

(ct context.Context, slogger *slog.Logger, groups []*PatternGroup)

}

func InitWatcher(ct context.Context, slogger *slog.Logger, groups []*PatternGroup) error {
	if len(groups) == 0 {
		return nil
	}

	if watcherIsActive.Load() {
		return ErrAlreadyStarted
	}

	watcherIsActive.Store(true)
	globalCtx = ct
	globalLogger = slogger

	activeWatcher = &globalWatcher{groups: groups}

	for _, g := range groups {
		if len(g.Patterns) == 0 {
			continue
		}

		for _, p := range g.Patterns {
			activeWatcher.watchers = append(activeWatcher.watchers, &pattern{patternGroup: g, value: p})
		}
	}

	if err := activeWatcher.startWatching(); err != nil {
		return err
	}

	return nil
}

func DrainWatcher() {
	if !watcherIsActive.Load() {