- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for TearDownDevice (0.21 sec)
-
pkg/volume/csi/csi_block.go
return errors.New(log("blockMapper.unstageVolumeForBlock failed to remove staging path after NodeUnstageVolume() error [%s]: %v", stagingPath, err)) } return nil } // TearDownDevice removes traces of the SetUpDevice. func (m *csiBlockMapper) TearDownDevice(globalMapPath, devicePath string) error { ctx, cancel := createCSIOperationContext(m.spec, csiTimeout) defer cancel() csiClient, err := m.csiClientGetter.Get()
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
type CustomBlockVolumeUnmapper interface { BlockVolumeUnmapper // TearDownDevice removes traces of the SetUpDevice procedure. // 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 }
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
csiUnmapper.csiClient = setupClient(t, true) globalMapPath, err := csiUnmapper.GetGlobalMapPath(spec) if err != nil { t.Fatalf("unmapper failed to GetGlobalMapPath: %v", err) } err = csiUnmapper.TearDownDevice(globalMapPath, "/dev/test") if err != nil { t.Fatal(err) } // ensure csi client call and node unpblished pubs := csiUnmapper.csiClient.(*fakeCsiDriverClient).nodeClient.GetNodePublishedVolumes()
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/iscsi/iscsi.go
// Even though iSCSI plugin has attacher/detacher implementation, iSCSI plugin // needs volume detach operation during TearDownDevice(). This method is only // chance that operations are done on kubelet node during volume teardown sequences. func (c *iscsiDiskUnmapper) TearDownDevice(mapPath, _ string) error { err := c.manager.DetachBlockISCSIDisk(*c, mapPath) if err != nil {
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/kubelet/volumemanager/reconciler/reconciler_test.go
// Populates desiredStateOfWorld cache with one volume/pod. // Enables controllerAttachDetachEnabled. // Calls Run() // Verifies two map path calls are made and no teardownDevice/detach calls. // Deletes volume/pod from desired state of world. // Verifies one teardownDevice call is made. // Verifies there are no attach/detach calls made. func Test_Run_Positive_VolumeUnmapControllerAttachEnabled(t *testing.T) { pod := &v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
// If symbolic link isn't there, the device isn't referenced from Pods. // Call plugin TearDownDevice to clean-up device connection, stored data under // globalMapPath, these operations depend on plugin implementation. // Once TearDownDevice is completed, remove globalMapPath dir. // After globalMapPath is removed, fd lock by loopback for the device can
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pkg/volume/local/local_test.go
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) } } } func testFSGroupMount(plug volume.VolumePlugin, pod *v1.Pod, tmpDir string, fsGroup int64) error {
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) 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 } func (f *stubBlockVolume) SupportsMetrics() bool { return false }
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
deviceUtil util.DeviceUtil exec utilexec.Interface } var _ volume.BlockVolumeUnmapper = &fcDiskUnmapper{} var _ volume.CustomBlockVolumeUnmapper = &fcDiskUnmapper{} func (c *fcDiskUnmapper) TearDownDevice(mapPath, devicePath string) error { err := c.manager.DetachBlockFCDisk(*c, mapPath, devicePath) if err != nil { return fmt.Errorf("fc: failed to detach disk: %s\nError: %v", mapPath, err) }
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/testing/testing.go
// Block volume support func (fv *FakeVolume) GetPodDeviceMapPathCallCount() int { fv.RLock() defer fv.RUnlock() return fv.PodDeviceMapPathCallCount } // Block volume support func (fv *FakeVolume) TearDownDevice(mapPath string, devicePath string) error { fv.Lock() defer fv.Unlock() fv.TearDownDeviceCallCount++ return nil } // Block volume support func (fv *FakeVolume) GetTearDownDeviceCallCount() int {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0)