Remove ability to re-enable serving deprecated autoscalingapiv2beta APIs
This commit is contained in:
		@@ -35,8 +35,6 @@ import (
 | 
			
		||||
	authorizationapiv1 "k8s.io/api/authorization/v1"
 | 
			
		||||
	autoscalingapiv1 "k8s.io/api/autoscaling/v1"
 | 
			
		||||
	autoscalingapiv2 "k8s.io/api/autoscaling/v2"
 | 
			
		||||
	autoscalingapiv2beta1 "k8s.io/api/autoscaling/v2beta1"
 | 
			
		||||
	autoscalingapiv2beta2 "k8s.io/api/autoscaling/v2beta2"
 | 
			
		||||
	batchapiv1 "k8s.io/api/batch/v1"
 | 
			
		||||
	certificatesapiv1 "k8s.io/api/certificates/v1"
 | 
			
		||||
	certificatesv1alpha1 "k8s.io/api/certificates/v1alpha1"
 | 
			
		||||
@@ -714,8 +712,6 @@ var (
 | 
			
		||||
	// betaAPIGroupVersionsDisabledByDefault is for all future beta groupVersions.
 | 
			
		||||
	betaAPIGroupVersionsDisabledByDefault = []schema.GroupVersion{
 | 
			
		||||
		authenticationv1beta1.SchemeGroupVersion,
 | 
			
		||||
		autoscalingapiv2beta1.SchemeGroupVersion,
 | 
			
		||||
		autoscalingapiv2beta2.SchemeGroupVersion,
 | 
			
		||||
		discoveryv1beta1.SchemeGroupVersion,
 | 
			
		||||
		nodev1beta1.SchemeGroupVersion, // remove in 1.26
 | 
			
		||||
		policyapiv1beta1.SchemeGroupVersion,
 | 
			
		||||
 
 | 
			
		||||
@@ -18,7 +18,6 @@ package rest
 | 
			
		||||
 | 
			
		||||
import (
 | 
			
		||||
	autoscalingapiv1 "k8s.io/api/autoscaling/v1"
 | 
			
		||||
	autoscalingapiv2beta1 "k8s.io/api/autoscaling/v2beta1"
 | 
			
		||||
	"k8s.io/apiserver/pkg/registry/generic"
 | 
			
		||||
	"k8s.io/apiserver/pkg/registry/rest"
 | 
			
		||||
	genericapiserver "k8s.io/apiserver/pkg/server"
 | 
			
		||||
@@ -26,7 +25,6 @@ import (
 | 
			
		||||
	"k8s.io/kubernetes/pkg/api/legacyscheme"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/apis/autoscaling"
 | 
			
		||||
	autoscalingapiv2 "k8s.io/kubernetes/pkg/apis/autoscaling/v2"
 | 
			
		||||
	autoscalingapiv2beta2 "k8s.io/kubernetes/pkg/apis/autoscaling/v2beta2"
 | 
			
		||||
	horizontalpodautoscalerstore "k8s.io/kubernetes/pkg/registry/autoscaling/horizontalpodautoscaler/storage"
 | 
			
		||||
)
 | 
			
		||||
 | 
			
		||||
@@ -37,24 +35,12 @@ func (p RESTStorageProvider) NewRESTStorage(apiResourceConfigSource serverstorag
 | 
			
		||||
	// If you add a version here, be sure to add an entry in `k8s.io/kubernetes/cmd/kube-apiserver/app/aggregator.go with specific priorities.
 | 
			
		||||
	// TODO refactor the plumbing to provide the information in the APIGroupInfo
 | 
			
		||||
 | 
			
		||||
	if storageMap, err := p.v2beta2Storage(apiResourceConfigSource, restOptionsGetter); err != nil {
 | 
			
		||||
		return genericapiserver.APIGroupInfo{}, err
 | 
			
		||||
	} else if len(storageMap) > 0 {
 | 
			
		||||
		apiGroupInfo.VersionedResourcesStorageMap[autoscalingapiv2beta2.SchemeGroupVersion.Version] = storageMap
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	if storageMap, err := p.v2Storage(apiResourceConfigSource, restOptionsGetter); err != nil {
 | 
			
		||||
		return genericapiserver.APIGroupInfo{}, err
 | 
			
		||||
	} else if len(storageMap) > 0 {
 | 
			
		||||
		apiGroupInfo.VersionedResourcesStorageMap[autoscalingapiv2.SchemeGroupVersion.Version] = storageMap
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	if storageMap, err := p.v2beta1Storage(apiResourceConfigSource, restOptionsGetter); err != nil {
 | 
			
		||||
		return genericapiserver.APIGroupInfo{}, err
 | 
			
		||||
	} else if len(storageMap) > 0 {
 | 
			
		||||
		apiGroupInfo.VersionedResourcesStorageMap[autoscalingapiv2beta1.SchemeGroupVersion.Version] = storageMap
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	if storageMap, err := p.v1Storage(apiResourceConfigSource, restOptionsGetter); err != nil {
 | 
			
		||||
		return genericapiserver.APIGroupInfo{}, err
 | 
			
		||||
	} else if len(storageMap) > 0 {
 | 
			
		||||
@@ -80,37 +66,6 @@ func (p RESTStorageProvider) v1Storage(apiResourceConfigSource serverstorage.API
 | 
			
		||||
	return storage, nil
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (p RESTStorageProvider) v2beta1Storage(apiResourceConfigSource serverstorage.APIResourceConfigSource, restOptionsGetter generic.RESTOptionsGetter) (map[string]rest.Storage, error) {
 | 
			
		||||
	storage := map[string]rest.Storage{}
 | 
			
		||||
 | 
			
		||||
	// horizontalpodautoscalers
 | 
			
		||||
	if resource := "horizontalpodautoscalers"; apiResourceConfigSource.ResourceEnabled(autoscalingapiv2beta1.SchemeGroupVersion.WithResource(resource)) {
 | 
			
		||||
		hpaStorage, hpaStatusStorage, err := horizontalpodautoscalerstore.NewREST(restOptionsGetter)
 | 
			
		||||
		if err != nil {
 | 
			
		||||
			return storage, err
 | 
			
		||||
		}
 | 
			
		||||
		storage[resource] = hpaStorage
 | 
			
		||||
		storage[resource+"/status"] = hpaStatusStorage
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	return storage, nil
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (p RESTStorageProvider) v2beta2Storage(apiResourceConfigSource serverstorage.APIResourceConfigSource, restOptionsGetter generic.RESTOptionsGetter) (map[string]rest.Storage, error) {
 | 
			
		||||
	storage := map[string]rest.Storage{}
 | 
			
		||||
 | 
			
		||||
	// horizontalpodautoscalers
 | 
			
		||||
	if resource := "horizontalpodautoscalers"; apiResourceConfigSource.ResourceEnabled(autoscalingapiv2beta2.SchemeGroupVersion.WithResource(resource)) {
 | 
			
		||||
		hpaStorage, hpaStatusStorage, err := horizontalpodautoscalerstore.NewREST(restOptionsGetter)
 | 
			
		||||
		if err != nil {
 | 
			
		||||
			return storage, err
 | 
			
		||||
		}
 | 
			
		||||
		storage[resource] = hpaStorage
 | 
			
		||||
		storage[resource+"/status"] = hpaStatusStorage
 | 
			
		||||
	}
 | 
			
		||||
	return storage, nil
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (p RESTStorageProvider) v2Storage(apiResourceConfigSource serverstorage.APIResourceConfigSource, restOptionsGetter generic.RESTOptionsGetter) (map[string]rest.Storage, error) {
 | 
			
		||||
	storage := map[string]rest.Storage{}
 | 
			
		||||
 | 
			
		||||
 
 | 
			
		||||
@@ -140,22 +140,6 @@ func GetEtcdStorageDataForNamespace(namespace string) map[schema.GroupVersionRes
 | 
			
		||||
		},
 | 
			
		||||
		// --
 | 
			
		||||
 | 
			
		||||
		// k8s.io/kubernetes/pkg/apis/autoscaling/v2beta1
 | 
			
		||||
		gvr("autoscaling", "v2beta1", "horizontalpodautoscalers"): {
 | 
			
		||||
			Stub:             `{"metadata": {"name": "hpa1"}, "spec": {"maxReplicas": 3, "scaleTargetRef": {"kind": "something", "name": "cross"}}}`,
 | 
			
		||||
			ExpectedEtcdPath: "/registry/horizontalpodautoscalers/" + namespace + "/hpa1",
 | 
			
		||||
			ExpectedGVK:      gvkP("autoscaling", "v2", "HorizontalPodAutoscaler"),
 | 
			
		||||
		},
 | 
			
		||||
		// --
 | 
			
		||||
 | 
			
		||||
		// k8s.io/kubernetes/pkg/apis/autoscaling/v2beta2
 | 
			
		||||
		gvr("autoscaling", "v2beta2", "horizontalpodautoscalers"): {
 | 
			
		||||
			Stub:             `{"metadata": {"name": "hpa3"}, "spec": {"maxReplicas": 3, "scaleTargetRef": {"kind": "something", "name": "cross"}}}`,
 | 
			
		||||
			ExpectedEtcdPath: "/registry/horizontalpodautoscalers/" + namespace + "/hpa3",
 | 
			
		||||
			ExpectedGVK:      gvkP("autoscaling", "v2", "HorizontalPodAutoscaler"),
 | 
			
		||||
		},
 | 
			
		||||
		// --
 | 
			
		||||
 | 
			
		||||
		// k8s.io/kubernetes/pkg/apis/batch/v1
 | 
			
		||||
		gvr("batch", "v1", "jobs"): {
 | 
			
		||||
			Stub:             `{"metadata": {"name": "job1"}, "spec": {"manualSelector": true, "selector": {"matchLabels": {"controller-uid": "uid1"}}, "template": {"metadata": {"labels": {"controller-uid": "uid1"}}, "spec": {"containers": [{"image": "` + image + `", "name": "container1"}], "dnsPolicy": "ClusterFirst", "restartPolicy": "Never"}}}}`,
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user