- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for GetPodDeviceMapPath (0.6 sec)
-
pkg/volume/csi/csi_block.go
} // GetPodDeviceMapPath returns pod's device file which will be mapped to a volume // returns: pods/{podUID}/volumeDevices/kubernetes.io~csi, {specName} func (m *csiBlockMapper) GetPodDeviceMapPath() (string, string) { path := m.plugin.host.GetPodVolumeDeviceDir(m.podUID, utilstrings.EscapeQualifiedName(CSIPluginName)) klog.V(4).Infof(log("blockMapper.GetPodDeviceMapPath [path=%s; name=%s]", path, m.specName))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 20.1K bytes - Viewed (0) -
pkg/volume/volume.go
GetGlobalMapPath(spec *Spec) (string, error) // GetPodDeviceMapPath returns a pod device map path // and name of a symbolic link associated to a block device. // ex. pods/{podUid}/{DefaultKubeletVolumeDevicesDirName}/{escapeQualifiedPluginName}/, {volumeName} GetPodDeviceMapPath() (string, string) // SupportsMetrics should return true if the MetricsProvider is // initialized
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/volume/fc/fc.go
func (fc *fcDisk) GetGlobalMapPath(spec *volume.Spec) (string, error) { return fc.fcGlobalMapPath(spec) } // GetPodDeviceMapPath returns pod device map path and volume name // path: pods/{podUid}/volumeDevices/kubernetes.io~fc // volumeName: pv0001 func (fc *fcDisk) GetPodDeviceMapPath() (string, string) { return fc.fcPodDeviceMapPath() } func getVolumeSource(spec *volume.Spec) (*v1.FCVolumeSource, bool, error) {
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/kubelet/server/stats/volume_stat_calculator_test.go
var _ volume.BlockVolume = &fakeBlockVolume{} type fakeBlockVolume struct{} func (v *fakeBlockVolume) GetGlobalMapPath(*volume.Spec) (string, error) { return "", nil } func (v *fakeBlockVolume) GetPodDeviceMapPath() (string, string) { return "", "" } func (v *fakeBlockVolume) SupportsMetrics() bool { return true } func (v *fakeBlockVolume) GetMetrics() (*volume.Metrics, error) { return expectedBlockMetrics(), nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.6K bytes - Viewed (0) -
pkg/volume/local/local.go
l.volName), nil } // GetPodDeviceMapPath returns pod device map path and volume name. // path: pods/{podUid}/volumeDevices/kubernetes.io~local-volume // volName: local-pv-ff0d6d4 func (l *localVolume) GetPodDeviceMapPath() (string, string) { return l.plugin.host.GetPodVolumeDeviceDir(l.podUID,
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/iscsi/iscsi.go
func (iscsi *iscsiDisk) GetGlobalMapPath(spec *volume.Spec) (string, error) { return iscsi.iscsiGlobalMapPath(spec) } // GetPodDeviceMapPath returns pod device map path and volume name // path: pods/{podUid}/volumeDevices/kubernetes.io~iscsi // volumeName: pv0001 func (iscsi *iscsiDisk) GetPodDeviceMapPath() (string, string) { return iscsi.iscsiPodDeviceMapPath() } func portalMounter(portal string) string {
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/volume/testing/testing.go
return fv.GlobalMapPathCallCount } // Block volume support func (fv *FakeVolume) GetPodDeviceMapPath() (string, string) { fv.RLock() defer fv.RUnlock() fv.PodDeviceMapPathCallCount++ return fv.getPodDeviceMapPath() } // Block volume support func (fv *FakeVolume) getPodDeviceMapPath() (string, string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes_test.go
type stubBlockVolume struct { dirPath string volName string } func (f *stubBlockVolume) GetGlobalMapPath(spec *volume.Spec) (string, error) { return "", nil } func (f *stubBlockVolume) GetPodDeviceMapPath() (string, string) { return f.dirPath, f.volName } func (f *stubBlockVolume) SetUpDevice() (string, error) { return "", nil } func (f stubBlockVolume) MapPodDevice() error { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 17 16:53:28 UTC 2023 - 20.4K bytes - Viewed (0) -
pkg/volume/local/local_test.go
} if globalPath != expectedGlobalPath { t.Errorf("Got unexpected path: %s, expected %s", globalPath, expectedGlobalPath) } expectedPodPath := filepath.Join(tmpDir, testPodPath) podPath, volName := mapper.GetPodDeviceMapPath() if podPath != expectedPodPath { t.Errorf("Got unexpected pod path: %s, expected %s", podPath, expectedPodPath) } 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) -
pkg/volume/csi/csi_block_test.go
csiMapper, _, _, err := prepareBlockMapperTest(plug, tc.specVolumeName, t) if err != nil { t.Fatalf("Failed to make a new Mapper: %v", err) } path, volName := csiMapper.GetPodDeviceMapPath() if tc.path != path { t.Errorf("expecting path %s, got %s", tc.path, path) } if tc.specVolumeName != volName { t.Errorf("expecting volName %s, got %s", tc.specVolumeName, volName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 26.5K bytes - Viewed (0)