Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for device_plugin (0.46 sec)

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

    	for _, d := range resp.Devices {
    		devices = append(devices, *d)
    	}
    	m.callback(r, devices)
    }
    
    func tmpSocketDir() (socketDir, socketName, pluginSocketName string, err error) {
    	socketDir, err = os.MkdirTemp("", "device_plugin")
    	if err != nil {
    		return
    	}
    	socketName = filepath.Join(socketDir, "server.sock")
    	pluginSocketName = filepath.Join(socketDir, "device-plugin.sock")
    	os.MkdirAll(socketDir, 0755)
    	return
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  2. pkg/kubelet/pluginmanager/plugin_manager_test.go

    		pluginManager.Run(sourcesReady, stopChan)
    	}()
    
    	// Add handler for device plugin
    	fakeHandler := newFakePluginHandler()
    	pluginManager.AddHandler(registerapi.DevicePlugin, fakeHandler)
    
    	const maxDepth = 3
    	// Make sure the plugin manager is aware of the socket in subdirectories
    	for i := 0; i < maxDepth; i++ {
    		fakeHandler.Reset()
    		pluginDir := socketDir
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/devicemanager/pod_devices_test.go

    	"k8s.io/apimachinery/pkg/util/sets"
    	utilfeature "k8s.io/apiserver/pkg/util/feature"
    	featuregatetesting "k8s.io/component-base/featuregate/testing"
    	pluginapi "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1"
    	"k8s.io/kubernetes/pkg/features"
    	"k8s.io/kubernetes/pkg/kubelet/cm/devicemanager/checkpoint"
    	kubecontainer "k8s.io/kubernetes/pkg/kubelet/container"
    )
    
    func TestGetContainerDevices(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet.go

    	}
    	// Adding Registration Callback function for Device Manager
    	kl.pluginManager.AddHandler(pluginwatcherapi.DevicePlugin, kl.containerManager.GetPluginRegistrationHandler())
    
    	// Start the plugin manager
    	klog.V(4).InfoS("Starting plugin manager")
    	go kl.pluginManager.Run(kl.sourcesReady, wait.NeverStop)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.28.md

    - Removed GA'ed feature gate `DelegateFSGroupToCSIDriver`. ([#117655](https://github.com/kubernetes/kubernetes/pull/117655), [@carlory](https://github.com/carlory))
    - Removed GA'ed feature gate `DevicePlugins`. ([#117656](https://github.com/kubernetes/kubernetes/pull/117656), [@carlory](https://github.com/carlory))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 23:47:59 UTC 2024
    - 408.3K bytes
    - Viewed (1)
Back to top