Skip to content

Commit d1d05d3

Browse files
committed
remove IsDeprecatedInternal from cloudprovider.plugins
The internal cloud controller loops are disabled at this point, this function should not be used as it does not return accurate information. In its place we check for the presence of the external cloud provider as that is the only acceptable value.
1 parent ff391ce commit d1d05d3

File tree

4 files changed

+3
-15
lines changed

4 files changed

+3
-15
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ func createCloudProvider(logger klog.Logger, cloudProvider string, externalCloud
3535
var loopMode ControllerLoopMode
3636
var err error
3737

38-
if utilfeature.DefaultFeatureGate.Enabled(features.DisableCloudProviders) && cloudprovider.IsDeprecatedInternal(cloudProvider) {
38+
if utilfeature.DefaultFeatureGate.Enabled(features.DisableCloudProviders) && !cloudprovider.IsExternal(cloudProvider) {
3939
cloudprovider.DisableWarningForProvider(cloudProvider)
4040
return nil, ExternalLoops, fmt.Errorf(
4141
"cloud provider %q was specified, but built-in cloud providers are disabled. Please set --cloud-provider=external and migrate to an external cloud provider",

pkg/kubeapiserver/options/cloudprovider.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ func (opts *CloudProviderOptions) Validate() []error {
5151
errs = append(errs, fmt.Errorf("when using --cloud-provider set to '%s', "+
5252
"please set DisableKubeletCloudCredentialProviders feature to true", opts.CloudProvider))
5353
}
54-
case cloudprovider.IsDeprecatedInternal(opts.CloudProvider):
54+
case !cloudprovider.IsExternal(opts.CloudProvider):
5555
if utilfeature.DefaultFeatureGate.Enabled(features.DisableCloudProviders) {
5656
errs = append(errs, fmt.Errorf("when using --cloud-provider set to '%s', "+
5757
"please set DisableCloudProviders feature to false", opts.CloudProvider))

pkg/kubelet/kubelet.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -386,7 +386,7 @@ func NewMainKubelet(kubeCfg *kubeletconfiginternal.KubeletConfiguration,
386386
return nil, fmt.Errorf("invalid sync frequency %d", kubeCfg.SyncFrequency.Duration)
387387
}
388388

389-
if utilfeature.DefaultFeatureGate.Enabled(features.DisableCloudProviders) && cloudprovider.IsDeprecatedInternal(cloudProvider) {
389+
if utilfeature.DefaultFeatureGate.Enabled(features.DisableCloudProviders) && !cloudprovider.IsExternal(cloudProvider) {
390390
cloudprovider.DisableWarningForProvider(cloudProvider)
391391
return nil, fmt.Errorf("cloud provider %q was specified, but built-in cloud providers are disabled. Please set --cloud-provider=external and migrate to an external cloud provider", cloudProvider)
392392
}

staging/src/k8s.io/cloud-provider/plugins.go

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -85,18 +85,6 @@ func IsExternal(name string) bool {
8585
return name == externalCloudProvider
8686
}
8787

88-
// IsDeprecatedInternal is responsible for preventing cloud.Interface
89-
// from being initialized in kubelet, kube-controller-manager or kube-api-server
90-
func IsDeprecatedInternal(name string) bool {
91-
for _, provider := range deprecatedCloudProviders {
92-
if provider.name == name {
93-
return true
94-
}
95-
}
96-
97-
return false
98-
}
99-
10088
// DisableWarningForProvider logs information about disabled cloud provider state
10189
func DisableWarningForProvider(providerName string) {
10290
for _, provider := range deprecatedCloudProviders {

0 commit comments

Comments
 (0)