Commit a0f96fc9 authored by nikhiljindal's avatar nikhiljindal

Adding namespaces to federation-apiserver

parent 524c5b53
...@@ -59,6 +59,8 @@ func AddToScheme(scheme *runtime.Scheme) { ...@@ -59,6 +59,8 @@ func AddToScheme(scheme *runtime.Scheme) {
scheme.AddKnownTypes(SchemeGroupVersion, scheme.AddKnownTypes(SchemeGroupVersion,
&api.ServiceList{}, &api.ServiceList{},
&api.Service{}, &api.Service{},
&api.Namespace{},
&api.NamespaceList{},
&api.ListOptions{}, &api.ListOptions{},
&api.DeleteOptions{}, &api.DeleteOptions{},
) )
......
...@@ -24,5 +24,6 @@ import ( ...@@ -24,5 +24,6 @@ import (
func addDefaultingFuncs(scheme *runtime.Scheme) { func addDefaultingFuncs(scheme *runtime.Scheme) {
scheme.AddDefaultingFuncs( scheme.AddDefaultingFuncs(
v1.SetDefaults_ServiceSpec, v1.SetDefaults_ServiceSpec,
v1.SetDefaults_NamespaceStatus,
) )
} }
...@@ -38,6 +38,8 @@ func AddToScheme(scheme *runtime.Scheme) { ...@@ -38,6 +38,8 @@ func AddToScheme(scheme *runtime.Scheme) {
func addKnownTypes(scheme *runtime.Scheme) { func addKnownTypes(scheme *runtime.Scheme) {
scheme.AddKnownTypes(SchemeGroupVersion, scheme.AddKnownTypes(SchemeGroupVersion,
&v1.Service{}, &v1.Service{},
&v1.Namespace{},
&v1.NamespaceList{},
&v1.ServiceList{}, &v1.ServiceList{},
&v1.ListOptions{}, &v1.ListOptions{},
&v1.DeleteOptions{}, &v1.DeleteOptions{},
......
...@@ -27,14 +27,18 @@ import ( ...@@ -27,14 +27,18 @@ import (
"k8s.io/kubernetes/federation/apis/core/v1" "k8s.io/kubernetes/federation/apis/core/v1"
"k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/api"
"k8s.io/kubernetes/pkg/api/rest" "k8s.io/kubernetes/pkg/api/rest"
namespaceetcd "k8s.io/kubernetes/pkg/registry/namespace/etcd"
serviceetcd "k8s.io/kubernetes/pkg/registry/service/etcd" serviceetcd "k8s.io/kubernetes/pkg/registry/service/etcd"
) )
func installCoreAPIs(s *genericoptions.ServerRunOptions, g *genericapiserver.GenericAPIServer, f genericapiserver.StorageFactory) { func installCoreAPIs(s *genericoptions.ServerRunOptions, g *genericapiserver.GenericAPIServer, f genericapiserver.StorageFactory) {
serviceStore, serviceStatusStorage := serviceetcd.NewREST(createRESTOptionsOrDie(s, g, f, api.Resource("service"))) serviceStore, serviceStatusStore := serviceetcd.NewREST(createRESTOptionsOrDie(s, g, f, api.Resource("service")))
namespaceStore, namespaceStatusStore, _ := namespaceetcd.NewREST(createRESTOptionsOrDie(s, g, f, api.Resource("namespaces")))
coreResources := map[string]rest.Storage{ coreResources := map[string]rest.Storage{
"services": serviceStore, "services": serviceStore,
"services/status": serviceStatusStorage, "services/status": serviceStatusStore,
"namespaces": namespaceStore,
"namespaces/status": namespaceStatusStore,
} }
coreGroupMeta := registered.GroupOrDie(core.GroupName) coreGroupMeta := registered.GroupOrDie(core.GroupName)
apiGroupInfo := genericapiserver.APIGroupInfo{ apiGroupInfo := genericapiserver.APIGroupInfo{
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment