- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for NewSpecFromPersistentVolume (0.34 sec)
-
pkg/controller/volume/expand/expand_controller.go
// 2. pv has an pre-resize capacity annotation if pvcRequestSize.Cmp(pvcStatusSize) <= 0 && !metav1.HasAnnotation(pv.ObjectMeta, util.AnnPreResizeCapacity) { return nil } volumeSpec := volume.NewSpecFromPersistentVolume(pv, false) migratable, err := expc.csiMigratedPluginManager.IsMigratable(volumeSpec) if err != nil { logger.V(4).Info("Failed to check CSI migration status for PVC with error", "pvcKey", key, "err", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/volume/plugins.go
} // NewSpecFromVolume creates an Spec from an v1.Volume func NewSpecFromVolume(vs *v1.Volume) *Spec { return &Spec{ Volume: vs, } } // NewSpecFromPersistentVolume creates an Spec from an v1.PersistentVolume func NewSpecFromPersistentVolume(pv *v1.PersistentVolume, readOnly bool) *Spec { return &Spec{ PersistentVolume: pv, ReadOnly: readOnly, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/volume/fc/fc.go
fcPV.Spec.PersistentVolumeSource.FC.TargetWWNs, *fcPV.Spec.PersistentVolumeSource.FC.Lun, fcPV.Spec.PersistentVolumeSource.FC.WWIDs) return volume.NewSpecFromPersistentVolume(fcPV, false), nil } type fcDisk struct { volName string podUID types.UID wwns []string lun string wwids []string plugin *fcPlugin
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
iscsiPV.Spec.PersistentVolumeSource.ISCSI.IQN, iscsiPV.Spec.PersistentVolumeSource.ISCSI.Lun, iscsiPV.Spec.PersistentVolumeSource.ISCSI.ISCSIInterface, ) return volume.NewSpecFromPersistentVolume(iscsiPV, false), nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
name, pv.Spec.ClaimRef.UID, expectedClaimUID) } volumeGidValue := getPVVolumeGidAnnotationValue(pv) return volume.NewSpecFromPersistentVolume(pv, pvcReadOnly), volumeGidValue, nil } func getPVVolumeGidAnnotationValue(pv *v1.PersistentVolume) string { if volumeGid, ok := pv.Annotations[util.VolumeGidAnnotationKey]; ok { return volumeGid }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
return } // Use the newest volume copy, this will save us from version conflicts on // saving. volume = newVolume // Find a plugin. spec := vol.NewSpecFromPersistentVolume(volume, false) plugin, err := ctrl.volumePluginMgr.FindRecyclablePluginBySpec(spec) if err != nil { // No recycler found. Emit an event and mark the volume Failed.
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
if err != nil { logger.Error(err, "Unable to lookup pv object", "PV", klog.KRef("", *pvName)) continue } var plugin volume.AttachableVolumePlugin volumeSpec := volume.NewSpecFromPersistentVolume(pv, false) // Consult csiMigratedPluginManager first before querying the plugins registered during runtime in volumePluginMgr.
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/volume/util/operationexecutor/operation_generator.go
} func (og *operationGenerator) GenerateExpandVolumeFunc( pvc *v1.PersistentVolumeClaim, pv *v1.PersistentVolume) (volumetypes.GeneratedOperations, error) { volumeSpec := volume.NewSpecFromPersistentVolume(pv, false) volumePlugin, err := og.volumePluginMgr.FindExpandablePluginBySpec(volumeSpec) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
PodUID: pod.UID, VolumeName: expectedVolumeName, OuterVolumeSpecName: "dswp-test-volume-name", VolumeGidVolume: "", VolumeSpec: volume.NewSpecFromPersistentVolume(pv, false), VolumeMountState: operationexecutor.VolumeMountUncertain, } err := dswp.actualStateOfWorld.MarkVolumeMountAsUncertain(opts) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0)