Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for deregisterPlugin (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top