...
1
16
17 package flexvolume
18
19 import (
20 "time"
21
22 "k8s.io/klog/v2"
23 "k8s.io/mount-utils"
24
25 "k8s.io/apimachinery/pkg/types"
26 )
27
28 type detacherDefaults flexVolumeDetacher
29
30
31 func (d *detacherDefaults) Detach(volumeName string, hostName types.NodeName) error {
32 klog.Warning(logPrefix(d.plugin.flexVolumePlugin), "using default Detach for volume ", volumeName, ", host ", hostName)
33 return nil
34 }
35
36
37 func (d *detacherDefaults) WaitForDetach(devicePath string, timeout time.Duration) error {
38 klog.Warning(logPrefix(d.plugin.flexVolumePlugin), "using default WaitForDetach for device ", devicePath)
39 return nil
40 }
41
42
43 func (d *detacherDefaults) UnmountDevice(deviceMountPath string) error {
44 klog.Warning(logPrefix(d.plugin.flexVolumePlugin), "using default UnmountDevice for device mount path ", deviceMountPath)
45 return mount.CleanupMountPoint(deviceMountPath, d.plugin.host.GetMounter(d.plugin.GetPluginName()), false)
46 }
47
View as plain text