- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for PluginHandler (0.39 sec)
-
pkg/kubelet/pluginmanager/operationexecutor/operation_executor_test.go
ch: ch, quit: quit, } } func (fopg *fakeOperationGenerator) GenerateRegisterPluginFunc( socketPath string, timestamp time.Time, pluginHandlers map[string]cache.PluginHandler, actualStateOfWorldUpdater ActualStateOfWorldUpdater) func() error { opFunc := func() error { startOperationAndBlock(fopg.ch, fopg.quit) return nil } return opFunc }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 30 03:35:26 UTC 2022 - 4.8K bytes - Viewed (0) -
pkg/kubelet/cm/fake_container_manager.go
c := v1.ResourceList{ v1.ResourceEphemeralStorage: *resource.NewQuantity( int64(0), resource.BinarySI), } return c } func (cm *FakeContainerManager) GetPluginRegistrationHandler() cache.PluginHandler { cm.Lock() defer cm.Unlock() cm.CalledFunctions = append(cm.CalledFunctions, "GetPluginRegistrationHandler") return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 17:33:04 UTC 2023 - 7.4K bytes - Viewed (0) -
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) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/server.go
"k8s.io/kubernetes/pkg/kubelet/metrics" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/cache" ) // Server interface provides methods for Device plugin registration server. type Server interface { cache.PluginHandler Start() error Stop() error SocketPath() string } type server struct { socketName string socketDir string mutex sync.Mutex wg sync.WaitGroup grpc *grpc.Server
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_windows.go
return result } func (cm *containerManagerImpl) GetCapacity(localStorageCapacityIsolation bool) v1.ResourceList { 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) -
pkg/kubelet/cm/container_manager.go
// GetPluginRegistrationHandler returns a plugin registration handler // The pluginwatcher's Handlers allow to have a single module for handling // registration. GetPluginRegistrationHandler() cache.PluginHandler // ShouldResetExtendedResourceCapacity returns whether or not the extended resources should be zeroed, // due to node recreation. ShouldResetExtendedResourceCapacity() bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:13 UTC 2024 - 9K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
// corresponding sockets var csiDrivers = &DriversStore{} var nim nodeinfomanager.Interface // PluginHandler is the plugin registration handler interface passed to the // pluginwatcher module in kubelet var PluginHandler = &RegistrationHandler{} // ValidatePlugin is called by kubelet's plugin watcher upon detection // of a new registration socket opened by CSI Driver registrar side car.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
versions: []string{"var", "boo", "foo"}, shouldFail: true, }, } for _, tc := range testCases { // Arrange & Act err := PluginHandler.ValidatePlugin(tc.pluginName, tc.endpoint, tc.versions) // Assert if tc.shouldFail && err == nil { t.Fatalf("expecting ValidatePlugin to fail, but got nil error for testcase: %#v", tc) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.8K bytes - Viewed (0) -
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.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
kl.pluginManager.AddHandler(pluginwatcherapi.CSIPlugin, plugincache.PluginHandler(csi.PluginHandler)) // Adding Registration Callback function for DRA Plugin if utilfeature.DefaultFeatureGate.Enabled(features.DynamicResourceAllocation) { kl.pluginManager.AddHandler(pluginwatcherapi.DRAPlugin, plugincache.PluginHandler(draplugin.NewRegistrationHandler(kl.kubeClient, kl.getNodeAnyWay))) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)