- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for NewSpecFromPersistentVolume (0.33 sec)
-
pkg/volume/csi/csi_attacher_test.go
attachedSpecs: []attachedSpec{ {"vol0", volume.NewSpecFromPersistentVolume(makeTestPV("pv0", 10, testDriver, "vol0"), false), true}, {"vol1", volume.NewSpecFromPersistentVolume(makeTestPV("pv1", 20, testDriver, "vol1"), false), true}, {"vol2", volume.NewSpecFromPersistentVolume(makeTestPV("pv2", 10, testDriver, "vol2"), false), false}, {"vol3", volume.NewSpecFromPersistentVolume(makeTestPV("pv3", 10, testDriver, "vol3"), false), false},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
driverName: "testdr", volName: "testvol", spec: volume.NewSpecFromPersistentVolume(makeTestPV("test-pv", 10, "testdr", "testvol"), false), }, { name: "mixchar driver", driverName: "test.dr.cc", volName: "testvol", spec: volume.NewSpecFromPersistentVolume(makeTestPV("test-pv", 10, "test.dr.cc", "testvol"), false), }, { name: "mixchar volume",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.8K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
return volume.NewSpecFromPersistentVolume(pvSrc, false) }, }, { name: "setup with persistent source without unspecified fstype and options", podUID: types.UID(fmt.Sprintf("%08X", rand.Uint64())), mode: storage.VolumeLifecyclePersistent, spec: func(fsType string, options []string) *volume.Spec { return volume.NewSpecFromPersistentVolume(makeTestPV("pv1", 20, testDriver, "vol2"), false)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/node_expander_test.go
og := getTestOperationGenerator(volumePluginMgr, pvc, pv) vmt := VolumeToMount{ Pod: pod, VolumeName: v1.UniqueVolumeName(pv.Name), VolumeSpec: volume.NewSpecFromPersistentVolume(pv, false), } desiredSize := test.desiredSize if desiredSize == nil { desiredSize = pv.Spec.Capacity.Storage() } actualSize := test.actualSize if actualSize == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/volume/plugins_test.go
Spec: v1.PersistentVolumeSpec{ PersistentVolumeSource: v1.PersistentVolumeSource{AWSElasticBlockStore: &v1.AWSElasticBlockStoreVolumeSource{}}, }, } converted = NewSpecFromPersistentVolume(pv, false) if converted.PersistentVolume.Spec.AWSElasticBlockStore == nil { t.Errorf("Unexpected nil AWSElasticBlockStore: %#v", converted) } if pv.Name != converted.Name() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/volume/csi/csi_client_test.go
DeviceMountPath string } func TestVolumeHealthEnable(t *testing.T) { featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.CSIVolumeHealth, true) spec := volume.NewSpecFromPersistentVolume(makeTestPV("test-pv", 10, "metrics", "test-vol"), false) tests := []struct { name string volumeStatsSet bool volumeConditionSet bool volumeData VolumeStatsOptions
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.9K bytes - Viewed (0) -
pkg/volume/local/local.go
Local: &v1.LocalVolumeSource{ Path: path, }, }, VolumeMode: &fs, }, } return volume.ReconstructedVolume{ Spec: volume.NewSpecFromPersistentVolume(localVolume, false), }, nil } func (plugin *localVolumePlugin) ConstructBlockVolumeSpec(podUID types.UID, volumeName, mapPath string) (*volume.Spec, error) { block := v1.PersistentVolumeBlock
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator_test.go
og := getTestOperatorGeneratorWithPVPVC(volumePluginMgr, pvc, pv) vmt := VolumeToMount{ Pod: pod, VolumeName: v1.UniqueVolumeName(pv.Name), VolumeSpec: volume.NewSpecFromPersistentVolume(pv, false), } desiredSize := test.desiredSize if desiredSize == nil { desiredSize = pv.Spec.Capacity.Storage() } actualSize := test.actualSize if actualSize == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
CSI: &api.CSIPersistentVolumeSource{ Driver: driverName, VolumeHandle: volumeHandle, }, }, VolumeMode: &fsMode, }, } return volume.NewSpecFromPersistentVolume(pv, false) } func (p *csiPlugin) SupportsMountOption() bool { // TODO (vladimirvivien) use CSI VolumeCapability.MountVolume.mount_flags // to probe for the result for this method
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
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)