04d1fcc9f3
Automatic merge from submit-queue. If you want to cherry-pick this change to another branch, please follow the instructions <a href="https://github.com/kubernetes/community/blob/master/contributors/devel/cherry-picks.md">here</a>. Fix failure to load volume plugins for #52048 Currently we have two plugin managers. However one of them limits the cloud plugins it loads. This means that if cloud provider is set to external the plugins will not be loaded in *that* plugin manager. However they will be loaded in the other instance of the plugin manager. So it does not actually save us anything. It does hamper the efforts to actually get stage 1 separation working. **What this PR does / why we need it**: It allows the plugins be found for the cloud providers working on stage 1 separation. **Which issue this PR fixes** *(optional, in `fixes #<issue number>(, fixes #<issue_number>, ...)` format, will close that issue when PR gets merged)*: fixes #52048 **Special notes for your reviewer**: **Release note**: ```release-note NONE ```
188 lines
8.6 KiB
Go
188 lines
8.6 KiB
Go
/*
|
|
Copyright 2014 The Kubernetes Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package app
|
|
|
|
import (
|
|
// This file exists to force the desired plugin implementations to be linked.
|
|
// This should probably be part of some configuration fed into the build for a
|
|
// given binary target.
|
|
|
|
"fmt"
|
|
|
|
// Cloud providers
|
|
"k8s.io/kubernetes/pkg/apis/componentconfig"
|
|
_ "k8s.io/kubernetes/pkg/cloudprovider/providers"
|
|
|
|
// Volume plugins
|
|
"github.com/golang/glog"
|
|
"k8s.io/kubernetes/pkg/cloudprovider"
|
|
"k8s.io/kubernetes/pkg/volume"
|
|
"k8s.io/kubernetes/pkg/volume/aws_ebs"
|
|
"k8s.io/kubernetes/pkg/volume/azure_dd"
|
|
"k8s.io/kubernetes/pkg/volume/azure_file"
|
|
"k8s.io/kubernetes/pkg/volume/cinder"
|
|
"k8s.io/kubernetes/pkg/volume/csi"
|
|
"k8s.io/kubernetes/pkg/volume/fc"
|
|
"k8s.io/kubernetes/pkg/volume/flexvolume"
|
|
"k8s.io/kubernetes/pkg/volume/flocker"
|
|
"k8s.io/kubernetes/pkg/volume/gce_pd"
|
|
"k8s.io/kubernetes/pkg/volume/glusterfs"
|
|
"k8s.io/kubernetes/pkg/volume/host_path"
|
|
"k8s.io/kubernetes/pkg/volume/iscsi"
|
|
"k8s.io/kubernetes/pkg/volume/local"
|
|
"k8s.io/kubernetes/pkg/volume/nfs"
|
|
"k8s.io/kubernetes/pkg/volume/photon_pd"
|
|
"k8s.io/kubernetes/pkg/volume/portworx"
|
|
"k8s.io/kubernetes/pkg/volume/quobyte"
|
|
"k8s.io/kubernetes/pkg/volume/rbd"
|
|
"k8s.io/kubernetes/pkg/volume/scaleio"
|
|
"k8s.io/kubernetes/pkg/volume/storageos"
|
|
volumeutil "k8s.io/kubernetes/pkg/volume/util"
|
|
"k8s.io/kubernetes/pkg/volume/vsphere_volume"
|
|
|
|
utilfeature "k8s.io/apiserver/pkg/util/feature"
|
|
"k8s.io/kubernetes/pkg/features"
|
|
)
|
|
|
|
// ProbeAttachableVolumePlugins collects all volume plugins for the attach/
|
|
// detach controller.
|
|
// The list of plugins is manually compiled. This code and the plugin
|
|
// initialization code for kubelet really, really need a through refactor.
|
|
func ProbeAttachableVolumePlugins() []volume.VolumePlugin {
|
|
allPlugins := []volume.VolumePlugin{}
|
|
|
|
allPlugins = append(allPlugins, aws_ebs.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, gce_pd.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, cinder.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, portworx.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, vsphere_volume.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, azure_dd.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, photon_pd.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, scaleio.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, storageos.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, fc.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, iscsi.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, rbd.ProbeVolumePlugins()...)
|
|
if !utilfeature.DefaultFeatureGate.Enabled(features.CSIPersistentVolume) {
|
|
allPlugins = append(allPlugins, csi.ProbeVolumePlugins()...)
|
|
}
|
|
return allPlugins
|
|
}
|
|
|
|
// GetDynamicPluginProber gets the probers of dynamically discoverable plugins
|
|
// for the attach/detach controller.
|
|
// Currently only Flexvolume plugins are dynamically discoverable.
|
|
func GetDynamicPluginProber(config componentconfig.VolumeConfiguration) volume.DynamicPluginProber {
|
|
return flexvolume.GetDynamicPluginProber(config.FlexVolumePluginDir)
|
|
}
|
|
|
|
// ProbeExpandableVolumePlugins returns volume plugins which are expandable
|
|
func ProbeExpandableVolumePlugins(config componentconfig.VolumeConfiguration) []volume.VolumePlugin {
|
|
allPlugins := []volume.VolumePlugin{}
|
|
|
|
allPlugins = append(allPlugins, aws_ebs.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, gce_pd.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, cinder.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, portworx.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, vsphere_volume.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, glusterfs.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, rbd.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, azure_dd.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, photon_pd.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, scaleio.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, storageos.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, fc.ProbeVolumePlugins()...)
|
|
if !utilfeature.DefaultFeatureGate.Enabled(features.CSIPersistentVolume) {
|
|
allPlugins = append(allPlugins, csi.ProbeVolumePlugins()...)
|
|
}
|
|
return allPlugins
|
|
}
|
|
|
|
// ProbeControllerVolumePlugins collects all persistent volume plugins into an
|
|
// easy to use list. Only volume plugins that implement any of
|
|
// provisioner/recycler/deleter interface should be returned.
|
|
func ProbeControllerVolumePlugins(cloud cloudprovider.Interface, config componentconfig.VolumeConfiguration) []volume.VolumePlugin {
|
|
allPlugins := []volume.VolumePlugin{}
|
|
|
|
// The list of plugins to probe is decided by this binary, not
|
|
// by dynamic linking or other "magic". Plugins will be analyzed and
|
|
// initialized later.
|
|
|
|
// Each plugin can make use of VolumeConfig. The single arg to this func contains *all* enumerated
|
|
// options meant to configure volume plugins. From that single config, create an instance of volume.VolumeConfig
|
|
// for a specific plugin and pass that instance to the plugin's ProbeVolumePlugins(config) func.
|
|
|
|
// HostPath recycling is for testing and development purposes only!
|
|
hostPathConfig := volume.VolumeConfig{
|
|
RecyclerMinimumTimeout: int(config.PersistentVolumeRecyclerConfiguration.MinimumTimeoutHostPath),
|
|
RecyclerTimeoutIncrement: int(config.PersistentVolumeRecyclerConfiguration.IncrementTimeoutHostPath),
|
|
RecyclerPodTemplate: volume.NewPersistentVolumeRecyclerPodTemplate(),
|
|
ProvisioningEnabled: config.EnableHostPathProvisioning,
|
|
}
|
|
if err := AttemptToLoadRecycler(config.PersistentVolumeRecyclerConfiguration.PodTemplateFilePathHostPath, &hostPathConfig); err != nil {
|
|
glog.Fatalf("Could not create hostpath recycler pod from file %s: %+v", config.PersistentVolumeRecyclerConfiguration.PodTemplateFilePathHostPath, err)
|
|
}
|
|
allPlugins = append(allPlugins, host_path.ProbeVolumePlugins(hostPathConfig)...)
|
|
|
|
nfsConfig := volume.VolumeConfig{
|
|
RecyclerMinimumTimeout: int(config.PersistentVolumeRecyclerConfiguration.MinimumTimeoutNFS),
|
|
RecyclerTimeoutIncrement: int(config.PersistentVolumeRecyclerConfiguration.IncrementTimeoutNFS),
|
|
RecyclerPodTemplate: volume.NewPersistentVolumeRecyclerPodTemplate(),
|
|
}
|
|
if err := AttemptToLoadRecycler(config.PersistentVolumeRecyclerConfiguration.PodTemplateFilePathNFS, &nfsConfig); err != nil {
|
|
glog.Fatalf("Could not create NFS recycler pod from file %s: %+v", config.PersistentVolumeRecyclerConfiguration.PodTemplateFilePathNFS, err)
|
|
}
|
|
allPlugins = append(allPlugins, nfs.ProbeVolumePlugins(nfsConfig)...)
|
|
allPlugins = append(allPlugins, glusterfs.ProbeVolumePlugins()...)
|
|
// add rbd provisioner
|
|
allPlugins = append(allPlugins, rbd.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, quobyte.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, azure_file.ProbeVolumePlugins()...)
|
|
|
|
allPlugins = append(allPlugins, flocker.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, portworx.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, scaleio.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, local.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, storageos.ProbeVolumePlugins()...)
|
|
|
|
allPlugins = append(allPlugins, aws_ebs.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, gce_pd.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, cinder.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, vsphere_volume.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, azure_dd.ProbeVolumePlugins()...)
|
|
allPlugins = append(allPlugins, photon_pd.ProbeVolumePlugins()...)
|
|
|
|
return allPlugins
|
|
}
|
|
|
|
// AttemptToLoadRecycler tries decoding a pod from a filepath for use as a recycler for a volume.
|
|
// If successful, this method will set the recycler on the config.
|
|
// If unsuccessful, an error is returned. Function is exported for reuse downstream.
|
|
func AttemptToLoadRecycler(path string, config *volume.VolumeConfig) error {
|
|
if path != "" {
|
|
recyclerPod, err := volumeutil.LoadPodFromFile(path)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if err = volume.ValidateRecyclerPodTemplate(recyclerPod); err != nil {
|
|
return fmt.Errorf("Pod specification (%v): %v", path, err)
|
|
}
|
|
config.RecyclerPodTemplate = recyclerPod
|
|
}
|
|
return nil
|
|
}
|