github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-24 12:15:52 +00:00
Code Issues Projects Releases Wiki Activity

Remove resync period

Browse Source
This commit is contained in:
Jon Sabo 2019-03-22 16:40:40 -05:00
parent e739b55374
commit 445d711611
1 changed files with 3 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/controller/statefulset/stateful_set.go
View File

@ -44,11 +44,6 @@ import (
"k8s.io/klog" "k8s.io/klog"
) )
const (
// period to relist statefulsets and verify pets
statefulSetResyncPeriod = 30 * time.Second
)
// controllerKind contains the schema.GroupVersionKind for this controller type. // controllerKind contains the schema.GroupVersionKind for this controller type.
var controllerKind = apps.SchemeGroupVersion.WithKind("StatefulSet") var controllerKind = apps.SchemeGroupVersion.WithKind("StatefulSet")
@ -121,7 +116,7 @@ func NewStatefulSetController(
ssc.podLister = podInformer.Lister() ssc.podLister = podInformer.Lister()
ssc.podListerSynced = podInformer.Informer().HasSynced ssc.podListerSynced = podInformer.Informer().HasSynced
setInformer.Informer().AddEventHandlerWithResyncPeriod( setInformer.Informer().AddEventHandler(
cache.ResourceEventHandlerFuncs{ cache.ResourceEventHandlerFuncs{
AddFunc: ssc.enqueueStatefulSet, AddFunc: ssc.enqueueStatefulSet,
UpdateFunc: func(old, cur interface{}) { UpdateFunc: func(old, cur interface{}) {
@ -134,7 +129,6 @@ func NewStatefulSetController(
}, },
DeleteFunc: ssc.enqueueStatefulSet, DeleteFunc: ssc.enqueueStatefulSet,
}, },
statefulSetResyncPeriod,
) )
ssc.setLister = setInformer.Lister() ssc.setLister = setInformer.Lister()
ssc.setListerSynced = setInformer.Informer().HasSynced ssc.setListerSynced = setInformer.Informer().HasSynced
@ -201,7 +195,7 @@ func (ssc *StatefulSetController) updatePod(old, cur interface{}) {
curPod := cur.(*v1.Pod) curPod := cur.(*v1.Pod)
oldPod := old.(*v1.Pod) oldPod := old.(*v1.Pod)
if curPod.ResourceVersion == oldPod.ResourceVersion { if curPod.ResourceVersion == oldPod.ResourceVersion {
// Periodic resync will send update events for all known pods. // In the event of a re-list we may receive update events for all known pods.
// Two different versions of the same pod will always have different RVs. // Two different versions of the same pod will always have different RVs.
return return
} }
@ -249,8 +243,7 @@ func (ssc *StatefulSetController) deletePod(obj interface{}) {
// When a delete is dropped, the relist will notice a pod in the store not // When a delete is dropped, the relist will notice a pod in the store not
// in the list, leading to the insertion of a tombstone object which contains // in the list, leading to the insertion of a tombstone object which contains
// the deleted key/value. Note that this value might be stale. If the pod // the deleted key/value. Note that this value might be stale.
// changed labels the new StatefulSet will not be woken up till the periodic resync.
if !ok { if !ok {
tombstone, ok := obj.(cache.DeletedFinalStateUnknown) tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
if !ok { if !ok {