- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for PluginConnected (0.15 sec)
-
pkg/kubelet/cm/devicemanager/endpoint_test.go
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) } func (m *mockPluginManager) PluginConnected(r string, p plugin.DevicePlugin) error {
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
// 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) 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
klog.ErrorS(err, "Unable to connect to device plugin client with socket path", "path", c.socket) return err } c.mutex.Lock() c.grpc = conn c.client = client c.mutex.Unlock() return c.handler.PluginConnected(c.resource, c) } // Run is for running the device plugin gRPC client. func (c *client) Run() { stream, err := c.client.ListAndWatch(context.Background(), &api.Empty{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 21:35:13 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager.go
klog.ErrorS(err, "Failed to remove file", "path", filePath) continue } } return errorsutil.NewAggregate(errs) } // PluginConnected is to connect a plugin to a new endpoint. // This is done as part of device plugin registration. func (m *ManagerImpl) PluginConnected(resourceName string, p plugin.DevicePlugin) error { options, err := p.API().GetDevicePluginOptions(context.Background(), &pluginapi.Empty{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0)