Skip to content

Commit cba5a93

Browse files
committed
Remove portworx from attachable volume plugins
The volume plugin does not implement AttachableVolumePlugin interface.
1 parent 0ecbdf3 commit cba5a93

File tree

3 files changed

+2
-15
lines changed

3 files changed

+2
-15
lines changed

cmd/kube-controller-manager/app/plugins.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -45,12 +45,7 @@ import (
4545
// The list of plugins is manually compiled. This code and the plugin
4646
// initialization code for kubelet really, really need a through refactor.
4747
func ProbeAttachableVolumePlugins(logger klog.Logger) ([]volume.VolumePlugin, error) {
48-
var err error
4948
allPlugins := []volume.VolumePlugin{}
50-
allPlugins, err = appendAttachableLegacyProviderVolumes(logger, allPlugins, utilfeature.DefaultFeatureGate)
51-
if err != nil {
52-
return allPlugins, err
53-
}
5449
allPlugins = append(allPlugins, fc.ProbeVolumePlugins()...)
5550
allPlugins = append(allPlugins, iscsi.ProbeVolumePlugins()...)
5651
allPlugins = append(allPlugins, csi.ProbeVolumePlugins()...)

cmd/kube-controller-manager/app/plugins_providers.go

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ type pluginInfo struct {
5353
pluginProbeFunction probeFn
5454
}
5555

56-
func appendAttachableLegacyProviderVolumes(logger klog.Logger, allPlugins []volume.VolumePlugin, featureGate featuregate.FeatureGate) ([]volume.VolumePlugin, error) {
56+
func appendExpandableLegacyProviderVolumes(logger klog.Logger, allPlugins []volume.VolumePlugin, featureGate featuregate.FeatureGate) ([]volume.VolumePlugin, error) {
5757
pluginMigrationStatus := make(map[string]pluginInfo)
5858
pluginMigrationStatus[plugins.PortworxVolumePluginName] = pluginInfo{pluginMigrationFeature: features.CSIMigrationPortworx, pluginUnregisterFeature: features.InTreePluginPortworxUnregister, pluginProbeFunction: portworx.ProbeVolumePlugins}
5959
var err error
@@ -65,11 +65,3 @@ func appendAttachableLegacyProviderVolumes(logger klog.Logger, allPlugins []volu
6565
}
6666
return allPlugins, nil
6767
}
68-
69-
func appendExpandableLegacyProviderVolumes(logger klog.Logger, allPlugins []volume.VolumePlugin, featureGate featuregate.FeatureGate) ([]volume.VolumePlugin, error) {
70-
return appendLegacyProviderVolumes(logger, allPlugins, featureGate)
71-
}
72-
73-
func appendLegacyProviderVolumes(logger klog.Logger, allPlugins []volume.VolumePlugin, featureGate featuregate.FeatureGate) ([]volume.VolumePlugin, error) {
74-
return appendAttachableLegacyProviderVolumes(logger, allPlugins, featureGate)
75-
}

cmd/kube-controller-manager/app/plugins_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ func TestProbeAttachableVolumePlugins(t *testing.T) {
4444
if err != nil {
4545
t.Fatalf("ProbeAttachableVolumePlugins failed: %s", err)
4646
}
47-
checkPlugins(t, plugins, []string{"kubernetes.io/csi", "kubernetes.io/fc", "kubernetes.io/iscsi", "kubernetes.io/portworx-volume"})
47+
checkPlugins(t, plugins, []string{"kubernetes.io/csi", "kubernetes.io/fc", "kubernetes.io/iscsi"})
4848
}
4949

5050
func TestProbeExpandableVolumePlugins(t *testing.T) {

0 commit comments

Comments
 (0)