in pkg/filesystem/file_watcher.go [59:65]
func NewFileWatcher(purpose string, path string, handler FileContentHandler) *FileWatcher {
return &FileWatcher{
path: path,
handler: handler,
queue: workqueue.NewNamedRateLimitingQueue(workqueue.NewItemExponentialFailureRateLimiter(workqueueBaseDelay, workqueueMaxDelay), purpose),
}
}