func()

in pkg/filesystem/file_watcher.go [119:134]

• 14 lines of code
• 3 McCabe index (conditional complexity)

func (f *FileWatcher) processNextWorkItem(ctx context.Context) (continuePoll bool) {
	k, quit := f.queue.Get()
	if quit {
		return false
	}
	defer f.queue.Done(k)

	if err := f.loadFile(); err != nil {
		klog.ErrorS(err, "failed processing files")
		f.queue.AddRateLimited(k)
		return true
	}

	f.queue.Forget(k)
	return true
}