- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for DeRegisterPlugin (0.22 sec)
-
pkg/kubelet/pluginmanager/cache/types.go
// Error encountered here can still be Notified to the plugin. RegisterPlugin(pluginName, endpoint string, versions []string, pluginClientTimeout *time.Duration) error // DeRegisterPlugin is called once the pluginwatcher observes that the socket has // been deleted. DeRegisterPlugin(pluginName string)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/plugin.go
), ) } func deregisterPlugin(pluginName string) { draPlugins.delete(pluginName) } // DeRegisterPlugin is called when a plugin has removed its socket, // signaling it is no longer available. func (h *RegistrationHandler) DeRegisterPlugin(pluginName string) { klog.InfoS("DeRegister DRA plugin", "name", pluginName) deregisterPlugin(pluginName) h.controller.removePlugin(pluginName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/plugin_test.go
assert.Error(t, err) } else { assert.Nil(t, err) } }) } t.Cleanup(func() { handler := newRegistrationHandler() handler.DeRegisterPlugin("this-plugin-already-exists-and-has-a-long-name-so-it-doesnt-collide") handler.DeRegisterPlugin("this-is-a-dummy-plugin-with-a-long-name-so-it-doesnt-collide") })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 2.6K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager_test.go
f.Lock() defer f.Unlock() f.events = append(f.events, "register "+pluginName) return nil } // DeRegisterPlugin is a fake method func (f *fakePluginHandler) DeRegisterPlugin(pluginName string) { f.Lock() defer f.Unlock() f.events = append(f.events, "deregister "+pluginName) } func (f *fakePluginHandler) Reset() { f.Lock() defer f.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 4.4K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/operationexecutor/operation_generator.go
// so that if we receive a register event during Register Plugin, we can process it as a Register call. actualStateOfWorldUpdater.RemovePlugin(pluginInfo.SocketPath) pluginInfo.Handler.DeRegisterPlugin(pluginInfo.Name) klog.V(4).InfoS("DeRegisterPlugin called", "pluginName", pluginInfo.Name, "pluginHandler", pluginInfo.Handler) return nil } return unregisterPluginFunc }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/example_handler.go
if err != nil { return fmt.Errorf("failed GetExampleInfo for v1beta2Client(%s): %v", endpoint, err) } return nil } func (p *exampleHandler) DeRegisterPlugin(pluginName string) { p.SendEvent(pluginName, exampleEventDeRegister) } func (p *exampleHandler) SendEvent(pluginName string, event examplePluginEvent) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 12:00:49 UTC 2023 - 4.6K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/handler.go
klog.V(2).InfoS("Registering plugin at endpoint", "plugin", pluginName, "endpoint", endpoint) return s.connectClient(pluginName, endpoint) } func (s *server) DeRegisterPlugin(pluginName string) { klog.V(2).InfoS("Deregistering plugin", "plugin", pluginName) client := s.getClient(pluginName) if client != nil { s.disconnectClient(pluginName, client) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler_test.go
func (d *DummyImpl) RegisterPlugin(pluginName string, endpoint string, versions []string, pluginClientTimeout *time.Duration) error { return nil } // DeRegisterPlugin is a dummy implementation func (d *DummyImpl) DeRegisterPlugin(pluginName string) { } // Calls Run() // Verifies that asw and dsw have no plugins func Test_Run_Positive_DoNothing(t *testing.T) { defer cleanup(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
} // DeRegisterPlugin is called when a plugin removed its socket, signaling // it is no longer available func (h *RegistrationHandler) DeRegisterPlugin(pluginName string) { klog.Info(log("registrationHandler.DeRegisterPlugin request for plugin %s", pluginName)) if err := unregisterDriver(pluginName); err != nil { klog.Error(log("registrationHandler.DeRegisterPlugin failed: %v", err)) } }
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/kubelet/cm/dra/manager_test.go
if err := plg.RegisterPlugin(test.driverName, draServerInfo.socketName, []string{"1.27"}, pluginClientTimeout); err != nil { t.Fatalf("failed to register plugin %s, err: %v", test.driverName, err) } defer plg.DeRegisterPlugin(test.driverName) // for sake of next tests if test.claimInfo != nil { manager.cache.add(test.claimInfo) } err = manager.PrepareResources(test.pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:29 UTC 2024 - 42K bytes - Viewed (0)