Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for GetWatcherHandler (0.18 sec)

  1. pkg/kubelet/cm/devicemanager/types.go

    	// and inactive device plugin resources previously registered on the node.
    	GetCapacity() (v1.ResourceList, v1.ResourceList, []string)
    	GetWatcherHandler() cache.PluginHandler
    
    	// GetDevices returns information about the devices assigned to pods and containers
    	GetDevices(podUID, containerName string) ResourceDeviceInstances
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 5K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/container_manager_windows.go

    	return cm.capacity
    }
    
    func (cm *containerManagerImpl) GetPluginRegistrationHandler() cache.PluginHandler {
    	return cm.deviceManager.GetWatcherHandler()
    }
    
    func (cm *containerManagerImpl) GetDevicePluginResourceCapacity() (v1.ResourceList, v1.ResourceList, []string) {
    	return cm.deviceManager.GetCapacity()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 11:25:36 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/devicemanager/manager.go

    	}
    	klog.V(2).InfoS("Processed device updates for resource", "resourceName", resourceName, "totalCount", len(devices), "healthyCount", healthyCount)
    }
    
    // GetWatcherHandler returns the plugin handler
    func (m *ManagerImpl) GetWatcherHandler() cache.PluginHandler {
    	return m.server
    }
    
    // checkpointFile returns device plugin checkpoint file path.
    func (m *ManagerImpl) checkpointFile() string {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/container_manager_linux.go

    		return err
    	}
    
    	return nil
    }
    
    func (cm *containerManagerImpl) GetPluginRegistrationHandler() cache.PluginHandler {
    	return cm.deviceManager.GetWatcherHandler()
    }
    
    // TODO: move the GetResources logic to PodContainerManager.
    func (cm *containerManagerImpl) GetResources(pod *v1.Pod, container *v1.Container) (*kubecontainer.RunContainerOptions, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/devicemanager/manager_test.go

    		filepath.Dir(pluginSocketName), /* sockDir */
    		&record.FakeRecorder{},
    	)
    
    	runPluginManager(pluginManager)
    	pluginManager.AddHandler(watcherapi.DevicePlugin, m.GetWatcherHandler())
    	return pluginManager
    }
    
    func runPluginManager(pluginManager pluginmanager.PluginManager) {
    	// FIXME: Replace sets.Set[string] with sets.Set[string]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
Back to top