...
1
16
17 package flexvolume
18
19 import (
20 "k8s.io/klog/v2"
21
22 "k8s.io/kubernetes/pkg/volume"
23 )
24
25 type mounterDefaults flexVolumeMounter
26
27
28
29 func (f *mounterDefaults) SetUpAt(dir string, mounterArgs volume.MounterArgs) error {
30 klog.Warning(logPrefix(f.plugin), "using default SetUpAt to ", dir)
31
32 src, err := f.plugin.getDeviceMountPath(f.spec)
33 if err != nil {
34 return err
35 }
36
37 if err := doMount(f.mounter, src, dir, "auto", []string{"bind"}); err != nil {
38 return err
39 }
40
41 return nil
42 }
43
44
45 func (f *mounterDefaults) GetAttributes() volume.Attributes {
46 klog.V(5).Info(logPrefix(f.plugin), "using default GetAttributes")
47 return volume.Attributes{
48 ReadOnly: f.readOnly,
49 Managed: !f.readOnly,
50 SELinuxRelabel: f.flexVolume.plugin.capabilities.SELinuxRelabel,
51 }
52 }
53
View as plain text