- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for UnmapPodDevice (0.26 sec)
-
pkg/volume/csi/csi_block.go
if err := removeall.RemoveAllOneFilesystem(mounter, volumeDir); err != nil { return err } return nil } // UnmapPodDevice unmaps the block device path. func (m *csiBlockMapper) UnmapPodDevice() error { publishPath := m.getPublishPath() csiClient, err := m.csiClientGetter.Get() if err != nil { // Treat the absence of the CSI driver as a transient error
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
// If the plugin is non-attachable, this method detaches the volume // from a node. TearDownDevice(mapPath string, devicePath string) error // UnmapPodDevice removes traces of the MapPodDevice procedure. UnmapPodDevice() error } // Provisioner is an interface that creates templates for PersistentVolumes // and can create the volume as a new resource in the infrastructure provider.
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/csi/csi_block_test.go
globalMapPath, err := csiUnmapper.GetGlobalMapPath(spec) if err != nil { t.Fatalf("unmapper failed to GetGlobalMapPath: %v", err) } err = csiUnmapper.UnmapPodDevice() if err != nil { t.Errorf("unmapper failed to call UnmapPodDevice: %v", err) } // GenerateUnmapDeviceFunc uses "" as pod UUID, it is global operation over all pods that used the volume
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/local/local_test.go
} if unmapper == nil { t.Fatalf("Got a nil Unmapper") } if customUnmapper, ok := unmapper.(volume.CustomBlockVolumeUnmapper); ok { if err := customUnmapper.UnmapPodDevice(); err != nil { t.Errorf("UnmapPodDevice failed, err: %v", err) } if err := customUnmapper.TearDownDevice(globalPath, devPath); err != nil { t.Errorf("TearDownDevice failed, err: %v", err) } } }
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/testing/testing.go
// Block volume support func (fv *FakeVolume) GetTearDownDeviceCallCount() int { fv.RLock() defer fv.RUnlock() return fv.TearDownDeviceCallCount } // Block volume support func (fv *FakeVolume) UnmapPodDevice() error { fv.Lock() defer fv.Unlock() fv.UnmapPodDeviceCallCount++ return nil } // Block volume support func (fv *FakeVolume) GetUnmapPodDeviceCallCount() int { fv.RLock()
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
} 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 } func (f *stubBlockVolume) SupportsMetrics() bool { return false } func (f *stubBlockVolume) GetMetrics() (*volume.Metrics, error) { return nil, 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/fc/fc.go
return fmt.Errorf("fc: failed to delete the directory: %s\nError: %v", mapPath, err) } klog.V(4).Infof("fc: successfully detached disk: %s", mapPath) return nil } func (c *fcDiskUnmapper) UnmapPodDevice() error { return nil } // GetGlobalMapPath returns global map path and error // path: plugins/kubernetes.io/{PluginName}/volumeDevices/{WWID}/{podUid}
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/volume/iscsi/iscsi.go
return fmt.Errorf("iscsi: failed to delete the directory: %s\nError: %v", mapPath, err) } klog.V(4).Infof("iscsi: successfully detached disk: %s", mapPath) return nil } func (c *iscsiDiskUnmapper) UnmapPodDevice() error { return nil } // GetGlobalMapPath returns global map path and error // path: plugins/kubernetes.io/{PluginName}/volumeDevices/{ifaceName}/{portal-some_iqn-lun-lun_id}
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/util/operationexecutor/operation_generator.go
return volumetypes.NewOperationContext(eventErr, detailedErr, migrated) } // Call UnmapPodDevice if blockVolumeUnmapper implements CustomBlockVolumeUnmapper if customBlockVolumeUnmapper, ok := blockVolumeUnmapper.(volume.CustomBlockVolumeUnmapper); ok { // Execute plugin specific unmap unmapErr = customBlockVolumeUnmapper.UnmapPodDevice() if unmapErr != 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)