github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-25 04:33:26 +00:00
Code Issues Projects Releases Wiki Activity

Increase controller sync time for namespace cleanup

Browse Source
This commit is contained in:
derekwaynecarr 2015-03-24 10:44:34 -04:00
parent ee53dfc741
commit 84c9709299
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/kube-controller-manager/app/controllermanager.go
View File

@ -74,7 +74,7 @@ func NewCMServer() *CMServer {
Address: util.IP(net.ParseIP("127.0.0.1")), Address: util.IP(net.ParseIP("127.0.0.1")),
NodeSyncPeriod: 10 * time.Second, NodeSyncPeriod: 10 * time.Second,
ResourceQuotaSyncPeriod: 10 * time.Second, ResourceQuotaSyncPeriod: 10 * time.Second,
NamespaceSyncPeriod: 10 * time.Second, NamespaceSyncPeriod: 1 * time.Minute,
RegisterRetryCount: 10, RegisterRetryCount: 10,
PodEvictionTimeout: 5 * time.Minute, PodEvictionTimeout: 5 * time.Minute,
NodeMilliCPU: 1000, NodeMilliCPU: 1000,

2
pkg/namespace/namespace_controller.go
View File

@ -159,7 +159,7 @@ func (nm *NamespaceManager) syncNamespace(namespace api.Namespace) (err error) {
} }
// if there is a deletion timestamp, and the status is not terminating, then update status // if there is a deletion timestamp, and the status is not terminating, then update status
if namespace.DeletionTimestamp != nil && namespace.Status.Phase != api.NamespaceTerminating { if !namespace.DeletionTimestamp.IsZero() && namespace.Status.Phase != api.NamespaceTerminating {
newNamespace := api.Namespace{} newNamespace := api.Namespace{}
newNamespace.ObjectMeta = namespace.ObjectMeta newNamespace.ObjectMeta = namespace.ObjectMeta
newNamespace.Status = namespace.Status newNamespace.Status = namespace.Status

4
pkg/registry/namespace/etcd/etcd.go
View File

@ -105,7 +105,7 @@ func (r *REST) Delete(ctx api.Context, name string, options *api.DeleteOptions)
} }
func (r *StatusREST) New() runtime.Object { func (r *StatusREST) New() runtime.Object {
return &api.Namespace{} return r.store.New()
} }
// Update alters the status subset of an object. // Update alters the status subset of an object.
@ -114,7 +114,7 @@ func (r *StatusREST) Update(ctx api.Context, obj runtime.Object) (runtime.Object
} }
func (r *FinalizeREST) New() runtime.Object { func (r *FinalizeREST) New() runtime.Object {
return &api.Namespace{} return r.store.New()
} }
// Update alters the status finalizers subset of an object. // Update alters the status finalizers subset of an object.