kubernetes/pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher.go

type Watcher …

// NewWatcher provides a new watcher for socket registration
func NewWatcher(sockDir string, desiredStateOfWorld cache.DesiredStateOfWorld) *Watcher { … }

// Start watches for the creation and deletion of plugin sockets at the path
func (w *Watcher) Start(stopCh <-chan struct{ … }

func (w *Watcher) init() error { … }

// Walks through the plugin directory discover any existing plugin sockets.
// Ignore all errors except root dir not being walkable
func (w *Watcher) traversePluginDir(dir string) error { … }

// Handle filesystem notify event.
// Files names:
// - MUST NOT start with a '.'
func (w *Watcher) handleCreateEvent(event fsnotify.Event) error { … }

func (w *Watcher) handlePluginRegistration(socketPath string) error { … }

func (w *Watcher) handleDeleteEvent(event fsnotify.Event) { … }