- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for pluginListAndWatchReceiver (0.26 sec)
-
pkg/kubelet/cm/devicemanager/endpoint_test.go
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()) } func TestNewEndpoint(t *testing.T) {
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
} // 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 ( // errFailedToDialDevicePlugin is the error raised when the device plugin could not be
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
return } klog.V(2).InfoS("State pushed for device plugin", "resource", c.resource, "resourceCapacity", len(response.Devices)) c.handler.PluginListAndWatchReceiver(c.resource, response) } } // Disconnect is for closing gRPC connection between device manager and device plugin. func (c *client) Disconnect() error { c.mutex.Lock() if c.grpc != 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
ep.e.setStopTime(time.Now()) } } // PluginListAndWatchReceiver receives ListAndWatchResponse from a device plugin // and ensures that an upto date state (e.g. number of devices and device health) // is captured. Also, registered device and device to container allocation // information is checkpointed to the disk. func (m *ManagerImpl) PluginListAndWatchReceiver(resourceName string, resp *pluginapi.ListAndWatchResponse) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
return w } type wrappedManagerImpl struct { *ManagerImpl socketdir string callback func(string, []pluginapi.Device) } func (m *wrappedManagerImpl) PluginListAndWatchReceiver(r string, resp *pluginapi.ListAndWatchResponse) { var devices []pluginapi.Device for _, d := range resp.Devices { devices = append(devices, *d) } m.callback(r, devices) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0)