Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for IsMigrationEnabledForPlugin (0.89 sec)

  1. pkg/volume/csimigration/plugin_manager.go

    		return pm.featureGate.Enabled(features.InTreePluginPortworxUnregister)
    	default:
    		return false
    	}
    }
    
    // IsMigrationEnabledForPlugin indicates whether CSI migration has been enabled
    // for a particular storage plugin
    func (pm PluginManager) IsMigrationEnabledForPlugin(pluginName string) bool {
    	// CSIMigration feature should be enabled along with the plugin-specific one
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 14:55:34 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. pkg/volume/csimigration/plugin_manager_test.go

    			}
    			featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, test.inTreePluginUnregister, test.inTreePluginUnregisterEnabled)
    
    			csiMigrationResult := pm.IsMigrationEnabledForPlugin(test.pluginName)
    			if csiMigrationResult != test.csiMigrationResult {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 14:55:34 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. pkg/controller/volume/persistentvolume/pv_controller_base.go

    	}
    	if volume.Finalizers != nil {
    		outFinalizers = append(outFinalizers, volume.Finalizers...)
    	}
    	provisioner := volume.Annotations[storagehelpers.AnnDynamicallyProvisioned]
    	if cmpm.IsMigrationEnabledForPlugin(provisioner) {
    		// Remove in-tree delete finalizer on the PV as migration is enabled.
    		if slice.ContainsString(outFinalizers, storagehelpers.PVDeletionInTreeProtectionFinalizer, nil) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 29.5K bytes
    - Viewed (0)
  4. pkg/controller/volume/persistentvolume/pv_controller.go

    	GetCSINameFromInTreeName(pluginName string) (string, error)
    }
    
    // CSIMigratedPluginManager keeps track of CSI migration status of a plugin
    type CSIMigratedPluginManager interface {
    	IsMigrationEnabledForPlugin(pluginName string) bool
    }
    
    // PersistentVolumeController is a controller that synchronizes
    // PersistentVolumeClaims and PersistentVolumes. It starts two
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 89.2K bytes
    - Viewed (0)
  5. pkg/controller/volume/attachdetach/attach_detach_controller.go

    		// feature gate is enabled.
    		if inTreePluginName, err := adc.csiMigratedPluginManager.GetInTreePluginNameFromSpec(pv, nil); err == nil {
    			if adc.csiMigratedPluginManager.IsMigrationEnabledForPlugin(inTreePluginName) {
    				// PV is migrated and should be handled by the CSI plugin instead of the in-tree one
    				plugin, _ = adc.volumePluginMgr.FindAttachablePluginByName(csi.CSIPluginName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  6. pkg/controller/volume/persistentvolume/framework_test.go

    	return "vendor.com/MockCSIDriver", nil
    }
    
    type fakeCSIMigratedPluginManager struct{}
    
    func (t fakeCSIMigratedPluginManager) IsMigrationEnabledForPlugin(pluginName string) bool {
    	return true
    }
    
    // wrapTestWithCSIMigrationProvisionCalls returns a testCall that:
    // - configures controller with a volume plugin that emulates CSI migration
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 09:54:00 UTC 2023
    - 38.3K bytes
    - Viewed (0)
Back to top