Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ConstructBlockVolumeSpec (0.57 sec)

  1. pkg/volume/fc/fc.go

    	return volume.ReconstructedVolume{
    		Spec:                volume.NewSpecFromVolume(fcVolume),
    		SELinuxMountContext: mountContext,
    	}, nil
    }
    
    // ConstructBlockVolumeSpec creates a new volume.Spec with following steps.
    //   - Searches a file whose name is {pod uuid} under volume plugin directory.
    //   - If a file is found, then retrieves volumePluginDependentPath from globalMapPathUUID.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  2. pkg/volume/local/local_test.go

    	defer os.RemoveAll(tmpDir)
    
    	podPath := filepath.Join(tmpDir, testPodPath)
    	spec, err := plug.ConstructBlockVolumeSpec(types.UID("poduid"), testPVName, podPath)
    	if err != nil {
    		t.Errorf("ConstructBlockVolumeSpec() failed: %v", err)
    	}
    	if spec == nil {
    		t.Fatalf("ConstructBlockVolumeSpec() returned nil")
    	}
    
    	volName := spec.Name()
    	if volName != testPVName {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 10:53:39 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  3. pkg/volume/csi/csi_plugin.go

    	unmapper.csiClientGetter.driverName = unmapper.driverName
    
    	return unmapper, nil
    }
    
    func (p *csiPlugin) ConstructBlockVolumeSpec(podUID types.UID, specVolName, mapPath string) (*volume.Spec, error) {
    	klog.V(4).Infof("plugin.ConstructBlockVolumeSpec [podUID=%s, specVolName=%s, path=%s]", string(podUID), specVolName, mapPath)
    
    	dataDir := getVolumeDeviceDataDir(specVolName, p.host)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  4. pkg/volume/iscsi/iscsi.go

    		}
    	}
    
    	return volume.ReconstructedVolume{
    		Spec:                volume.NewSpecFromVolume(iscsiVolume),
    		SELinuxMountContext: mountContext,
    	}, nil
    }
    
    func (plugin *iscsiPlugin) ConstructBlockVolumeSpec(podUID types.UID, volumeName, mapPath string) (*volume.Spec, error) {
    	pluginDir := plugin.host.GetVolumeDevicePluginDir(iscsiPluginName)
    	blkutil := volumepathhandler.NewBlockVolumePathHandler()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  5. pkg/volume/plugins.go

    	// ConstructBlockVolumeSpec constructs a volume spec based on the given
    	// podUID, volume name and a pod device map path.
    	// The spec may have incomplete information due to limited information
    	// from input. This function is used by volume manager to reconstruct
    	// volume spec by reading the volume directories from disk.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 16:13:15 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  6. pkg/volume/local/local.go

    				},
    			},
    			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
    
    	localVolume := &v1.PersistentVolume{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: volumeName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  7. pkg/volume/csi/csi_plugin_test.go

    			}
    			if err := saveVolumeData(deviceDataDir, volDataFileName, tc.data); err != nil {
    				t.Fatal(err)
    			}
    		}
    
    		// rebuild spec
    		spec, err := plug.ConstructBlockVolumeSpec("test-podUID", tc.specVolID, getVolumeDevicePluginDir(tc.specVolID, plug.host))
    		if tc.shouldFail {
    			if err == nil {
    				t.Fatal("expecting ConstructVolumeSpec to fail, but got nil error")
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  8. pkg/volume/util/operationexecutor/operation_executor.go

    	// corresponding to raw block device.
    	// ex. volumePath: pods/{podUid}}/{DefaultKubeletVolumeDevicesDirName}/{escapeQualifiedPluginName}/{volumeName}
    	volumeSpec, err := mapperPlugin.ConstructBlockVolumeSpec(uid, volumeSpecName, volumePath)
    	if err != nil {
    		return volume.ReconstructedVolume{}, err
    	}
    	return volume.ReconstructedVolume{
    		Spec: volumeSpec,
    	}, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  9. pkg/volume/testing/testing.go

    	return volume.ReconstructedVolume{
    		Spec: &volume.Spec{
    			Volume: &v1.Volume{
    				Name: volumeName,
    			},
    		},
    	}, nil
    }
    
    // Block volume support
    func (plugin *FakeVolumePlugin) ConstructBlockVolumeSpec(podUID types.UID, volumeName, mountPath string) (*volume.Spec, error) {
    	return &volume.Spec{
    		Volume: &v1.Volume{
    			Name: volumeName,
    		},
    	}, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 53.3K bytes
    - Viewed (0)
Back to top