Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GenerateUnregisterPluginFunc (0.51 sec)

  1. pkg/kubelet/pluginmanager/operationexecutor/operation_generator.go

    		pluginHandlers map[string]cache.PluginHandler,
    		actualStateOfWorldUpdater ActualStateOfWorldUpdater) func() error
    
    	// Generates the UnregisterPlugin function needed to perform the unregistration of a plugin
    	GenerateUnregisterPluginFunc(
    		pluginInfo cache.PluginInfo,
    		actualStateOfWorldUpdater ActualStateOfWorldUpdater) func() error
    }
    
    func (og *operationGenerator) GenerateRegisterPluginFunc(
    	socketPath string,
    	timestamp time.Time,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:21:15 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. pkg/kubelet/pluginmanager/operationexecutor/operation_executor.go

    }
    
    func (oe *operationExecutor) UnregisterPlugin(
    	pluginInfo cache.PluginInfo,
    	actualStateOfWorld ActualStateOfWorldUpdater) error {
    	generatedOperation :=
    		oe.operationGenerator.GenerateUnregisterPluginFunc(pluginInfo, actualStateOfWorld)
    
    	return oe.pendingOperations.Run(
    		pluginInfo.SocketPath, generatedOperation)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 04 06:56:50 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  3. pkg/kubelet/pluginmanager/operationexecutor/operation_executor_test.go

    	opFunc := func() error {
    		startOperationAndBlock(fopg.ch, fopg.quit)
    		return nil
    	}
    	return opFunc
    }
    
    func (fopg *fakeOperationGenerator) GenerateUnregisterPluginFunc(
    	pluginInfo cache.PluginInfo,
    	actualStateOfWorldUpdater ActualStateOfWorldUpdater) func() error {
    	opFunc := func() error {
    		startOperationAndBlock(fopg.ch, fopg.quit)
    		return nil
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 30 03:35:26 UTC 2022
    - 4.8K bytes
    - Viewed (0)
Back to top