scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-04 04:08:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Externalize immortal namespaces

Browse Source
This commit is contained in:
Jordan Liggitt
2016-04-05 16:28:00 -04:00
parent b8d000853e
commit bef1d6e82e
2 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
plugin/pkg/admission/namespace/lifecycle/admission.go
View File

@@ -32,9 +32,11 @@ import (
"k8s.io/kubernetes/pkg/watch" "k8s.io/kubernetes/pkg/watch"
) )
const PluginName = "NamespaceLifecycle"
func init() { func init() {
admission.RegisterPlugin("NamespaceLifecycle", func(client clientset.Interface, config io.Reader) (admission.Interface, error) { admission.RegisterPlugin(PluginName, func(client clientset.Interface, config io.Reader) (admission.Interface, error) {
return NewLifecycle(client), nil return NewLifecycle(client, sets.NewString(api.NamespaceDefault)), nil
}) })
} }
@@ -109,7 +111,7 @@ func (l *lifecycle) Admit(a admission.Attributes) (err error) {
} }
// NewLifecycle creates a new namespace lifecycle admission control handler // NewLifecycle creates a new namespace lifecycle admission control handler
func NewLifecycle(c clientset.Interface) admission.Interface { func NewLifecycle(c clientset.Interface, immortalNamespaces sets.String) admission.Interface {
store := cache.NewStore(cache.MetaNamespaceKeyFunc) store := cache.NewStore(cache.MetaNamespaceKeyFunc)
reflector := cache.NewReflector( reflector := cache.NewReflector(
&cache.ListWatch{ &cache.ListWatch{
@@ -129,6 +131,6 @@ func NewLifecycle(c clientset.Interface) admission.Interface {
Handler: admission.NewHandler(admission.Create, admission.Update, admission.Delete), Handler: admission.NewHandler(admission.Create, admission.Update, admission.Delete),
client: c, client: c,
store: store, store: store,
immortalNamespaces: sets.NewString(api.NamespaceDefault), immortalNamespaces: immortalNamespaces,
} }
} }

3
plugin/pkg/admission/namespace/lifecycle/admission_test.go
View File

@@ -28,6 +28,7 @@ import (
"k8s.io/kubernetes/pkg/client/testing/core" "k8s.io/kubernetes/pkg/client/testing/core"
"k8s.io/kubernetes/pkg/client/unversioned/testclient" "k8s.io/kubernetes/pkg/client/unversioned/testclient"
"k8s.io/kubernetes/pkg/runtime" "k8s.io/kubernetes/pkg/runtime"
"k8s.io/kubernetes/pkg/util/sets"
) )
// TestAdmission // TestAdmission
@@ -60,7 +61,7 @@ func TestAdmission(t *testing.T) {
return true, &api.NamespaceList{Items: []api.Namespace{*namespaceObj}}, nil return true, &api.NamespaceList{Items: []api.Namespace{*namespaceObj}}, nil
}) })
lfhandler := NewLifecycle(mockClient).(*lifecycle) lfhandler := NewLifecycle(mockClient, sets.NewString("default")).(*lifecycle)
lfhandler.store = store lfhandler.store = store
handler := admission.NewChainHandler(lfhandler) handler := admission.NewChainHandler(lfhandler)
pod := api.Pod{ pod := api.Pod{