@@ -34,6 +34,8 @@ import (
34
34
"k8s.io/client-go/tools/cache"
35
35
"k8s.io/client-go/tools/record"
36
36
cloudprovider "k8s.io/cloud-provider"
37
+ utilexec "k8s.io/utils/exec"
38
+
37
39
"k8s.io/kubernetes/pkg/features"
38
40
"k8s.io/kubernetes/pkg/kubelet/configmap"
39
41
"k8s.io/kubernetes/pkg/kubelet/secret"
@@ -86,7 +88,7 @@ func NewInitializedVolumePluginMgr(
86
88
informerFactory : informerFactory ,
87
89
csiDriverLister : csiDriverLister ,
88
90
csiDriversSynced : csiDriversSynced ,
89
- exec : mount . NewOSExec (),
91
+ exec : utilexec . New (),
90
92
}
91
93
92
94
if err := kvh .volumePluginMgr .InitPlugins (plugins , prober , kvh ); err != nil {
@@ -115,7 +117,7 @@ type kubeletVolumeHost struct {
115
117
informerFactory informers.SharedInformerFactory
116
118
csiDriverLister storagelisters.CSIDriverLister
117
119
csiDriversSynced cache.InformerSynced
118
- exec mount. Exec
120
+ exec utilexec. Interface
119
121
}
120
122
121
123
func (kvh * kubeletVolumeHost ) SetKubeletError (err error ) {
@@ -271,6 +273,6 @@ func (kvh *kubeletVolumeHost) GetEventRecorder() record.EventRecorder {
271
273
return kvh .kubelet .recorder
272
274
}
273
275
274
- func (kvh * kubeletVolumeHost ) GetExec (pluginName string ) mount. Exec {
276
+ func (kvh * kubeletVolumeHost ) GetExec (pluginName string ) utilexec. Interface {
275
277
return kvh .exec
276
278
}
0 commit comments