Merge pull request #32166 from nikhiljindal/removeVar

Automatic merge from submit-queue

Remove DeprecatedStorageVersion

Its not used anymore.
Ref https://github.com/kubernetes/kubernetes/pull/24787#discussion_r61513902

cc @lavalamp @smarterclayton @deads2k
This commit is contained in:
Kubernetes Submit Queue 2016-09-11 04:27:11 -07:00 committed by GitHub
commit d06321f7fe
2 changed files with 15 additions and 30 deletions

View File

@ -25,7 +25,6 @@ import (
"k8s.io/kubernetes/pkg/admission" "k8s.io/kubernetes/pkg/admission"
"k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/api"
"k8s.io/kubernetes/pkg/api/unversioned" "k8s.io/kubernetes/pkg/api/unversioned"
apiutil "k8s.io/kubernetes/pkg/api/util"
"k8s.io/kubernetes/pkg/apimachinery/registered" "k8s.io/kubernetes/pkg/apimachinery/registered"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
"k8s.io/kubernetes/pkg/client/restclient" "k8s.io/kubernetes/pkg/client/restclient"
@ -33,7 +32,6 @@ import (
"k8s.io/kubernetes/pkg/util/config" "k8s.io/kubernetes/pkg/util/config"
utilnet "k8s.io/kubernetes/pkg/util/net" utilnet "k8s.io/kubernetes/pkg/util/net"
"github.com/golang/glog"
"github.com/spf13/pflag" "github.com/spf13/pflag"
) )
@ -72,17 +70,15 @@ type ServerRunOptions struct {
AuthorizationWebhookCacheUnauthorizedTTL time.Duration AuthorizationWebhookCacheUnauthorizedTTL time.Duration
AuthorizationRBACSuperUser string AuthorizationRBACSuperUser string
BasicAuthFile string BasicAuthFile string
BindAddress net.IP BindAddress net.IP
CertDirectory string CertDirectory string
ClientCAFile string ClientCAFile string
CloudConfigFile string CloudConfigFile string
CloudProvider string CloudProvider string
CorsAllowedOriginList []string CorsAllowedOriginList []string
DefaultStorageMediaType string DefaultStorageMediaType string
DeleteCollectionWorkers int DeleteCollectionWorkers int
// Used to specify the storage version that should be used for the legacy v1 api group.
DeprecatedStorageVersion string
AuditLogPath string AuditLogPath string
AuditLogMaxAge int AuditLogMaxAge int
AuditLogMaxBackups int AuditLogMaxBackups int
@ -163,12 +159,9 @@ func (o *ServerRunOptions) WithEtcdOptions() *ServerRunOptions {
} }
// StorageGroupsToEncodingVersion returns a map from group name to group version, // StorageGroupsToEncodingVersion returns a map from group name to group version,
// computed from the s.DeprecatedStorageVersion and s.StorageVersions flags. // computed from s.StorageVersions flag.
func (s *ServerRunOptions) StorageGroupsToEncodingVersion() (map[string]unversioned.GroupVersion, error) { func (s *ServerRunOptions) StorageGroupsToEncodingVersion() (map[string]unversioned.GroupVersion, error) {
storageVersionMap := map[string]unversioned.GroupVersion{} storageVersionMap := map[string]unversioned.GroupVersion{}
if s.DeprecatedStorageVersion != "" {
storageVersionMap[""] = unversioned.GroupVersion{Group: apiutil.GetGroup(s.DeprecatedStorageVersion), Version: apiutil.GetVersion(s.DeprecatedStorageVersion)}
}
// First, get the defaults. // First, get the defaults.
if err := mergeGroupVersionIntoMap(s.DefaultStorageVersions, storageVersionMap); err != nil { if err := mergeGroupVersionIntoMap(s.DefaultStorageVersions, storageVersionMap); err != nil {
@ -221,14 +214,6 @@ func (s *ServerRunOptions) NewSelfClient() (clientset.Interface, error) {
QPS: 50, QPS: 50,
Burst: 100, Burst: 100,
} }
if len(s.DeprecatedStorageVersion) != 0 {
gv, err := unversioned.ParseGroupVersion(s.DeprecatedStorageVersion)
if err != nil {
glog.Fatalf("error in parsing group version: %s", err)
}
clientConfig.GroupVersion = &gv
}
return clientset.NewForConfig(clientConfig) return clientset.NewForConfig(clientConfig)
} }
@ -434,10 +419,11 @@ func (s *ServerRunOptions) AddUniversalFlags(fs *pflag.FlagSet) {
fs.IntVar(&s.StorageConfig.DeserializationCacheSize, "deserialization-cache-size", s.StorageConfig.DeserializationCacheSize, fs.IntVar(&s.StorageConfig.DeserializationCacheSize, "deserialization-cache-size", s.StorageConfig.DeserializationCacheSize,
"Number of deserialized json objects to cache in memory.") "Number of deserialized json objects to cache in memory.")
fs.StringVar(&s.DeprecatedStorageVersion, "storage-version", s.DeprecatedStorageVersion, deprecatedStorageVersion := ""
fs.StringVar(&deprecatedStorageVersion, "storage-version", deprecatedStorageVersion,
"DEPRECATED: the version to store the legacy v1 resources with. Defaults to server preferred.") "DEPRECATED: the version to store the legacy v1 resources with. Defaults to server preferred.")
fs.MarkDeprecated("storage-version", "--storage-version is deprecated and will be removed when the v1 API "+ fs.MarkDeprecated("storage-version", "--storage-version is deprecated and will be removed when the v1 API "+
"is retired. See --storage-versions instead.") "is retired. Setting this has no effect. See --storage-versions instead.")
fs.StringVar(&s.StorageVersions, "storage-versions", s.StorageVersions, ""+ fs.StringVar(&s.StorageVersions, "storage-versions", s.StorageVersions, ""+
"The per-group version to store resources in. "+ "The per-group version to store resources in. "+

View File

@ -68,9 +68,8 @@ func TestGenerateStorageVersionMap(t *testing.T) {
} }
for i, test := range testCases { for i, test := range testCases {
s := options.ServerRunOptions{ s := options.ServerRunOptions{
DeprecatedStorageVersion: test.legacyVersion, StorageVersions: test.storageVersions,
StorageVersions: test.storageVersions, DefaultStorageVersions: test.defaultVersions,
DefaultStorageVersions: test.defaultVersions,
} }
output, err := s.StorageGroupsToEncodingVersion() output, err := s.StorageGroupsToEncodingVersion()
if err != nil { if err != nil {