code: func (w *Watcher) Stop() error {
  	close(w.stopCh)
  
  	c := make(chan struct{})
  	go func() {
  		defer close(c)
  		w.wg.Wait()
  	}()
  
  	select {
  	case <-c:
  	case <-time.After(11 * time.Second):
  		return fmt.Errorf("timeout on stopping watcher")
  	}
  
  	w.fsWatcher.Close()
  
  	return nil
  }
docs: // Stop stops probing the creation of plugin sockets at the path