kubernetes/pkg/volume/flexvolume/fake_watcher.go

type fakeWatcher …

var _ …

func newFakeWatcher() *fakeWatcher { … }

func (w *fakeWatcher) Init(eventHandler utilfs.FSEventHandler, _ utilfs.FSErrorHandler) error { … }

func (w *fakeWatcher) Run() { … }

func (w *fakeWatcher) AddWatch(path string) error { … }

// Triggers a mock filesystem event.
func (w *fakeWatcher) TriggerEvent(op fsnotify.Op, filename string) { … }