- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for MapPodDevice (0.18 sec)
-
pkg/volume/csi/csi_block_test.go
if err != nil { t.Fatalf("failed to setup VolumeAttachment: %v", err) } t.Log("created attachment ", attachID) // Map device to global and pod device map path path, err := csiMapper.MapPodDevice() if err != nil { t.Fatalf("mapper failed to GetGlobalMapPath: %v", err) } // Check if NodePublishVolume published to the right path
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 26.5K bytes - Viewed (0) -
pkg/volume/csi/csi_block.go
} func (m *csiBlockMapper) MapPodDevice() (string, error) { klog.V(4).Infof(log("blockMapper.MapPodDevice called")) // Get csiSource from spec if m.spec == nil { return "", errors.New(log("blockMapper.MapPodDevice spec is nil")) } csiSource, err := getCSISourceFromSpec(m.spec) if err != nil { return "", errors.New(log("blockMapper.MapPodDevice failed to get CSI persistent source: %v", err)) }
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
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) -
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) -
pkg/volume/local/local_test.go
_, err = customMapper.SetUpDevice() if err != nil { t.Errorf("Failed to SetUpDevice, err: %v", err) } devPath, err = customMapper.MapPodDevice() if err != nil { t.Errorf("Failed to MapPodDevice, err: %v", err) } } if _, err := os.Stat(devPath); err != nil { if os.IsNotExist(err) { t.Errorf("SetUpDevice() failed, volume path not created: %s", devPath)
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/kubelet/kubelet_volumes_test.go
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 } func (f *stubBlockVolume) TearDownDevice(mapPath string, devicePath string) error { return nil } func (f *stubBlockVolume) UnmapPodDevice() 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)