Skip to content

Commit

Permalink
apiextensions,kube-aggregator: unify scheme setup code
Browse files Browse the repository at this point in the history
  • Loading branch information
sttts committed Aug 23, 2019
1 parent 030f0d0 commit c7ca6d0
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 42 deletions.
Expand Up @@ -57,26 +57,14 @@ import (
var (
Scheme = runtime.NewScheme()
Codecs = serializer.NewCodecFactory(Scheme)

// if you modify this, make sure you update the crEncoder
unversionedVersion = schema.GroupVersion{Group: "", Version: "v1"}
unversionedTypes = []runtime.Object{
&metav1.Status{},
&metav1.WatchEvent{},
&metav1.APIVersions{},
&metav1.APIGroupList{},
&metav1.APIGroup{},
&metav1.APIResourceList{},
}
)

func init() {
install.Install(Scheme)

// we need to add the options to empty v1
metav1.AddToGroupVersion(Scheme, schema.GroupVersion{Group: "", Version: "v1"})

Scheme.AddUnversionedTypes(unversionedVersion, unversionedTypes...)
// register unversioned types that must be available on CR endpoints
Scheme.AddUnversionedTypes(schema.GroupVersion{Group: "", Version: "v1"}, &metav1.Status{}, &metav1.WatchEvent{})
}

type ExtraConfig struct {
Expand Down
16 changes: 0 additions & 16 deletions staging/src/k8s.io/kube-aggregator/pkg/apiserver/apiserver.go
Expand Up @@ -20,8 +20,6 @@ import (
"net/http"
"time"

metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/apimachinery/pkg/util/sets"
"k8s.io/apiserver/pkg/endpoints/openapi"
genericapiserver "k8s.io/apiserver/pkg/server"
Expand All @@ -43,20 +41,6 @@ import (
apiservicerest "k8s.io/kube-aggregator/pkg/registry/apiservice/rest"
)

func init() {
// we need to add the options (like ListOptions) to empty v1
metav1.AddToGroupVersion(aggregatorscheme.Scheme, schema.GroupVersion{Group: "", Version: "v1"})

unversioned := schema.GroupVersion{Group: "", Version: "v1"}
aggregatorscheme.Scheme.AddUnversionedTypes(unversioned,
&metav1.Status{},
&metav1.APIVersions{},
&metav1.APIGroupList{},
&metav1.APIGroup{},
&metav1.APIResourceList{},
)
}

// legacyAPIServiceName is the fixed name of the only non-groupified API version
const legacyAPIServiceName = "v1."

Expand Down
15 changes: 3 additions & 12 deletions staging/src/k8s.io/kube-aggregator/pkg/apiserver/scheme/scheme.go
Expand Up @@ -17,14 +17,12 @@ limitations under the License.
package scheme

import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/apimachinery/pkg/runtime/serializer"
utilruntime "k8s.io/apimachinery/pkg/util/runtime"

"k8s.io/kube-aggregator/pkg/apis/apiregistration"
"k8s.io/kube-aggregator/pkg/apis/apiregistration/install"
"k8s.io/kube-aggregator/pkg/apis/apiregistration/v1"
"k8s.io/kube-aggregator/pkg/apis/apiregistration/v1beta1"
)

var (
Expand All @@ -36,13 +34,6 @@ var (
)

func init() {
AddToScheme(Scheme)
install.Install(Scheme)
}

// AddToScheme adds the types of this group into the given scheme.
func AddToScheme(scheme *runtime.Scheme) {
utilruntime.Must(v1beta1.AddToScheme(scheme))
utilruntime.Must(v1.AddToScheme(scheme))
utilruntime.Must(apiregistration.AddToScheme(scheme))
metav1.AddToGroupVersion(Scheme, schema.GroupVersion{Group: "", Version: "v1"})
}

0 comments on commit c7ca6d0

Please sign in to comment.