Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for MapPodDevice (0.18 sec)

  1. pkg/volume/volume.go

    	SetUpDevice() (stagingPath string, err error)
    
    	// MapPodDevice maps the block device to a path and return the path.
    	// Unique device path across kubelet node reboot is required to avoid
    	// unexpected block volume destruction.
    	// If empty string is returned, the path returned by attacher.Attach() and
    	// attacher.WaitForAttach() will be used.
    	MapPodDevice() (publishPath string, err error)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. pkg/volume/local/local.go

    func (m *localVolumeMapper) SetUpDevice() (string, error) {
    	return "", nil
    }
    
    // MapPodDevice provides physical device path for the local PV.
    func (m *localVolumeMapper) MapPodDevice() (string, error) {
    	globalPath := util.MakeAbsolutePath(runtime.GOOS, m.globalPath)
    	klog.V(4).Infof("MapPodDevice returning path %s", globalPath)
    	return globalPath, nil
    }
    
    // GetStagingPath returns
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  3. pkg/volume/util/operationexecutor/operation_generator.go

    			VolumeMountState:    VolumeMounted,
    		}
    
    		// Call MapPodDevice if blockVolumeMapper implements CustomBlockVolumeMapper
    		if customBlockVolumeMapper, ok := blockVolumeMapper.(volume.CustomBlockVolumeMapper); ok {
    			// Execute driver specific map
    			pluginDevicePath, mapErr := customBlockVolumeMapper.MapPodDevice()
    			if mapErr != nil {
    				// On failure, return error. Caller will log and retry.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
  4. pkg/volume/testing/testing.go

    // Block volume support
    func (fv *FakeVolume) GetUnmapPodDeviceCallCount() int {
    	fv.RLock()
    	defer fv.RUnlock()
    	return fv.UnmapPodDeviceCallCount
    }
    
    // Block volume support
    func (fv *FakeVolume) MapPodDevice() (string, error) {
    	fv.Lock()
    	defer fv.Unlock()
    
    	if fv.VolName == TimeoutOnSetupVolumeName {
    		fv.VolumeMountState[fv.VolName] = volumeMountUncertain
    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