mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-25 20:53:33 +00:00
Merge pull request #22951 from derekwaynecarr/flake_ns
Auto commit by PR queue bot
This commit is contained in:
commit
a17a475317
@ -57,6 +57,18 @@ func (l *lifecycle) Admit(a admission.Attributes) (err error) {
|
|||||||
// if we're here, then the API server has found a route, which means that if we have a non-empty namespace
|
// if we're here, then the API server has found a route, which means that if we have a non-empty namespace
|
||||||
// its a namespaced resource.
|
// its a namespaced resource.
|
||||||
if len(a.GetNamespace()) == 0 || a.GetKind() == api.Kind("Namespace") {
|
if len(a.GetNamespace()) == 0 || a.GetKind() == api.Kind("Namespace") {
|
||||||
|
// if a namespace is deleted, we want to prevent all further creates into it
|
||||||
|
// while it is undergoing termination. to reduce incidences where the cache
|
||||||
|
// is slow to update, we forcefully remove the namespace from our local cache.
|
||||||
|
// this will cause a live lookup of the namespace to get its latest state even
|
||||||
|
// before the watch notification is received.
|
||||||
|
if a.GetOperation() == admission.Delete {
|
||||||
|
l.store.Delete(&api.Namespace{
|
||||||
|
ObjectMeta: api.ObjectMeta{
|
||||||
|
Name: a.GetName(),
|
||||||
|
},
|
||||||
|
})
|
||||||
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user