- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for IsMigrationEnabledForPlugin (0.89 sec)
-
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) -
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) -
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) -
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) -
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) -
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)