- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for PluginDisconnected (0.22 sec)
-
pkg/kubelet/cm/devicemanager/endpoint_test.go
func (m *mockPluginManager) PluginConnected(r string, p plugin.DevicePlugin) error { return m.pluginConnected(r, p) } func (m *mockPluginManager) PluginDisconnected(r string) { m.pluginDisconnected(r) } func (m *mockPluginManager) PluginListAndWatchReceiver(r string, lr *pluginapi.ListAndWatchResponse) { m.pluginListAndWatchReceiver(r, lr) } func esocketName() string { return fmt.Sprintf("mock%d.sock", time.Now().UnixNano()) }
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
CleanupPluginDirectory(string) error } // ClientHandler is an interface for handling device plugin connections. type ClientHandler interface { PluginConnected(string, DevicePlugin) error PluginDisconnected(string) PluginListAndWatchReceiver(string, *api.ListAndWatchResponse) } // TODO: evaluate whether we need these error definitions. const (
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/client.go
if c.grpc != nil { if err := c.grpc.Close(); err != nil { klog.V(2).ErrorS(err, "Failed to close grcp connection", "resource", c.Resource()) } c.grpc = nil } c.mutex.Unlock() c.handler.PluginDisconnected(c.resource) return nil } func (c *client) Resource() string { return c.resource } func (c *client) API() api.DevicePluginClient { return c.client }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 21:35:13 UTC 2023 - 3.8K bytes - Viewed (0)