Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 14 of 14 for GetDeviceMountPath (0.38 sec)

  1. pkg/volume/local/local_test.go

    	}
    
    	pvSpec := getTestVolume(false, tmpBlockDir, false, nil)
    
    	expectedGlobalPath := filepath.Join(tmpBlockDir, testBlockFormattingToFSGlobalPath)
    	actualPath, err := dm.GetDeviceMountPath(pvSpec)
    	if err != nil {
    		t.Errorf("Failed to get device mount path: %v", err)
    	}
    	if expectedGlobalPath != actualPath {
    		t.Fatalf("Expected device mount global path:%s, got: %s", expectedGlobalPath, actualPath)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 10:53:39 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  2. pkg/volume/local/local.go

    		// the persistent-claim volume used to mount the PV
    		return spec.ReadOnly, nil
    	}
    
    	return false, fmt.Errorf("spec does not reference a Local volume type")
    }
    
    func (dm *deviceMounter) GetDeviceMountPath(spec *volume.Spec) (string, error) {
    	return dm.plugin.getGlobalLocalPath(spec)
    }
    
    func (plugin *localVolumePlugin) NewDeviceUnmounter() (volume.DeviceUnmounter, error) {
    	return &deviceMounter{
    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/csi/csi_attacher_test.go

    			if tc.skipPVCSISource {
    				spec.PersistentVolume.Spec.CSI = nil
    			}
    		}
    		// Run
    		mountPath, err := csiAttacher.GetDeviceMountPath(spec)
    
    		// Verify
    		if err != nil && !tc.shouldFail {
    			t.Errorf("test should not fail, but error occurred: %v", err)
    		} else if err == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 58.1K bytes
    - Viewed (0)
  4. pkg/volume/testing/testing.go

    	}
    	return "/dev/sdb", nil
    }
    
    func (fv *FakeVolume) GetWaitForAttachCallCount() int {
    	fv.RLock()
    	defer fv.RUnlock()
    	return fv.WaitForAttachCallCount
    }
    
    func (fv *FakeVolume) GetDeviceMountPath(spec *volume.Spec) (string, error) {
    	fv.Lock()
    	defer fv.Unlock()
    	fv.GetDeviceMountPathCallCount++
    	return "", 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