- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for cleanupPluginDirectory (0.28 sec)
-
pkg/kubelet/cm/devicemanager/endpoint_test.go
} } type mockPluginManager struct { cleanupPluginDirectory func(string) error pluginConnected func(string, plugin.DevicePlugin) error pluginDisconnected func(string) pluginListAndWatchReceiver func(string, *pluginapi.ListAndWatchResponse) } func (m *mockPluginManager) CleanupPluginDirectory(r string) error { return m.cleanupPluginDirectory(r) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 16:05:48 UTC 2022 - 7.6K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/api.go
import ( api "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1" ) // RegistrationHandler is an interface for handling device plugin registration // and plugin directory cleanup. type RegistrationHandler interface { CleanupPluginDirectory(string) error } // ClientHandler is an interface for handling device plugin connections. type ClientHandler interface { PluginConnected(string, DevicePlugin) error PluginDisconnected(string)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 02 11:05:20 UTC 2022 - 1.9K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/server.go
// (even though we should in theory be able to just wipe the whole directory) // because the Handler stores its checkpoint file (amongst others) in here. if err := s.rhandler.CleanupPluginDirectory(s.socketDir); err != nil { klog.ErrorS(err, "Failed to cleanup the device plugin directory", "directory", s.socketDir) return err } ln, err := net.Listen("unix", s.SocketPath()) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager.go
} manager.checkpointManager = checkpointManager return manager, nil } // CleanupPluginDirectory is to remove all existing unix sockets // from /var/lib/kubelet/device-plugins on Device Plugin Manager start func (m *ManagerImpl) CleanupPluginDirectory(dir string) error { d, err := os.Open(dir) if err != nil { return err } defer d.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0)