debounce_fswatcher

func DebounceFSWatcherEvents ¶

func DebounceFSWatcherEvents(
	ctx context.Context,
	watcher *fsnotify.Watcher,
	debounceDur time.Duration,
	filter func(event fsnotify.Event) (bool, error),
) ([]fsnotify.Event, error)

DebounceFSWatcherEvents debounces a fswatcher event stream. Waits for a "quiet period" before syncing. Returns when an event happened. If filter is set, events are checked against the filter. If filter returns false, the event will be ignored. If filter returns an err, it will be returned.