diff --git a/pkg/volume/plugins.go b/pkg/volume/plugins.go index 6de244f3728bb..c1944945fd8eb 100644 --- a/pkg/volume/plugins.go +++ b/pkg/volume/plugins.go @@ -662,34 +662,33 @@ func (pm *VolumePluginMgr) FindPluginBySpec(spec *Spec) (VolumePlugin, error) { return nil, fmt.Errorf("could not find plugin because volume spec is nil") } - matches := []VolumePlugin{} + var match VolumePlugin + matchedPluginNames := []string{} for _, v := range pm.plugins { if v.CanSupport(spec) { - matches = append(matches, v) + match = v + matchedPluginNames = append(matchedPluginNames, v.GetPluginName()) } } pm.refreshProbedPlugins() for _, plugin := range pm.probedPlugins { if plugin.CanSupport(spec) { - matches = append(matches, plugin) + match = plugin + matchedPluginNames = append(matchedPluginNames, plugin.GetPluginName()) } } - if len(matches) == 0 { + if len(matchedPluginNames) == 0 { return nil, fmt.Errorf("no volume plugin matched") } - if len(matches) > 1 { - matchedPluginNames := []string{} - for _, plugin := range matches { - matchedPluginNames = append(matchedPluginNames, plugin.GetPluginName()) - } + if len(matchedPluginNames) > 1 { return nil, fmt.Errorf("multiple volume plugins matched: %s", strings.Join(matchedPluginNames, ",")) } // Issue warning if the matched provider is deprecated - pm.logDeprecation(matches[0].GetPluginName()) - return matches[0], nil + pm.logDeprecation(match.GetPluginName()) + return match, nil } // FindPluginByName fetches a plugin by name or by legacy name. If no plugin