github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-02 08:17:26 +00:00
Code Issues Projects Releases Wiki Activity

fibre channel: Remove unused exe interface

Browse Source
This commit is contained in:
Jan Safranek 2017-08-22 14:28:10 +02:00
parent 07dea6b447
commit f744b12ee9
3 changed files with 1 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/volume/fc/BUILD
View File

@ -24,7 +24,6 @@ go_library(
"//vendor/github.com/golang/glog:go_default_library", "//vendor/github.com/golang/glog:go_default_library",
"//vendor/k8s.io/api/core/v1:go_default_library", "//vendor/k8s.io/api/core/v1:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/types:go_default_library", "//vendor/k8s.io/apimachinery/pkg/types:go_default_library",
"//vendor/k8s.io/utils/exec:go_default_library",
], ],
) )

5
pkg/volume/fc/attacher.go
View File

@ -29,13 +29,11 @@ import (
"k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume"
volumeutil "k8s.io/kubernetes/pkg/volume/util" volumeutil "k8s.io/kubernetes/pkg/volume/util"
"k8s.io/kubernetes/pkg/volume/util/volumehelper" "k8s.io/kubernetes/pkg/volume/util/volumehelper"
"k8s.io/utils/exec"
) )
type fcAttacher struct { type fcAttacher struct {
host volume.VolumeHost host volume.VolumeHost
manager diskManager manager diskManager
exe exec.Interface
} }
var _ volume.Attacher = &fcAttacher{} var _ volume.Attacher = &fcAttacher{}
@ -46,7 +44,6 @@ func (plugin *fcPlugin) NewAttacher() (volume.Attacher, error) {
return &fcAttacher{ return &fcAttacher{
host: plugin.host, host: plugin.host,
manager: &FCUtil{}, manager: &FCUtil{},
exe: exec.New(),
}, nil }, nil
} }
@ -126,7 +123,6 @@ func (attacher *fcAttacher) MountDevice(spec *volume.Spec, devicePath string, de
type fcDetacher struct { type fcDetacher struct {
mounter mount.Interface mounter mount.Interface
manager diskManager manager diskManager
exe exec.Interface
} }
var _ volume.Detacher = &fcDetacher{} var _ volume.Detacher = &fcDetacher{}
@ -135,7 +131,6 @@ func (plugin *fcPlugin) NewDetacher() (volume.Detacher, error) {
return &fcDetacher{ return &fcDetacher{
mounter: plugin.host.GetMounter(plugin.GetPluginName()), mounter: plugin.host.GetMounter(plugin.GetPluginName()),
manager: &FCUtil{}, manager: &FCUtil{},
exe: exec.New(),
}, nil }, nil
} }

9
pkg/volume/fc/fc.go
View File

@ -28,17 +28,15 @@ import (
utilstrings "k8s.io/kubernetes/pkg/util/strings" utilstrings "k8s.io/kubernetes/pkg/util/strings"
"k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume"
"k8s.io/kubernetes/pkg/volume/util" "k8s.io/kubernetes/pkg/volume/util"
"k8s.io/utils/exec"
) )
// This is the primary entrypoint for volume plugins. // This is the primary entrypoint for volume plugins.
func ProbeVolumePlugins() []volume.VolumePlugin { func ProbeVolumePlugins() []volume.VolumePlugin {
return []volume.VolumePlugin{&fcPlugin{nil, exec.New()}} return []volume.VolumePlugin{&fcPlugin{nil}}
} }
type fcPlugin struct { type fcPlugin struct {
host volume.VolumeHost host volume.VolumeHost
exe exec.Interface
} }
var _ volume.VolumePlugin = &fcPlugin{} var _ volume.VolumePlugin = &fcPlugin{}
@ -160,11 +158,6 @@ func (plugin *fcPlugin) newUnmounterInternal(volName string, podUID types.UID, m
}, nil }, nil
} }
func (plugin *fcPlugin) execCommand(command string, args []string) ([]byte, error) {
cmd := plugin.exe.Command(command, args...)
return cmd.CombinedOutput()
}
func (plugin *fcPlugin) ConstructVolumeSpec(volumeName, mountPath string) (*volume.Spec, error) { func (plugin *fcPlugin) ConstructVolumeSpec(volumeName, mountPath string) (*volume.Spec, error) {
fcVolume := &v1.Volume{ fcVolume := &v1.Volume{
Name: volumeName, Name: volumeName,