Merge pull request kubernetes-retired#781 from mwielgus/relists-in-watch

Refresh pods and nodes every 1 hour
jcookeee · Dec 11, 2015 · b9ab6fe · b9ab6fe
2 parents 6a743e0 + a3f2c4a
commit b9ab6fe
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/sources/nodes/kube.go b/sources/nodes/kube.go
@@ -18,6 +18,7 @@ import (
 	"fmt"
 	"net"
 	"sync"
+	"time"
 
 	"github.com/golang/glog"
 	api "k8s.io/kubernetes/pkg/api"
@@ -153,7 +154,7 @@ func NewKubeNodes(client *client.Client) (NodesApi, error) {
 
 	lw := cache.NewListWatchFromClient(client, "nodes", api.NamespaceAll, fields.Everything())
 	nodeLister := &cache.StoreToNodeLister{Store: cache.NewStore(cache.MetaNamespaceKeyFunc)}
-	reflector := cache.NewReflector(lw, &api.Node{}, nodeLister.Store, 0)
+	reflector := cache.NewReflector(lw, &api.Node{}, nodeLister.Store, time.Hour)
 	stopChan := make(chan struct{})
 	reflector.RunUntil(stopChan)
 

diff --git a/sources/pods.go b/sources/pods.go
@@ -175,7 +175,7 @@ func newPodsApi(client *kclient.Client) podsApi {
 	lw := kcache.NewListWatchFromClient(client, "pods", kapi.NamespaceAll, selector)
 	podLister := &kcache.StoreToPodLister{Store: kcache.NewStore(kcache.MetaNamespaceKeyFunc)}
 	// Watch and cache all running pods.
-	reflector := kcache.NewReflector(lw, &kapi.Pod{}, podLister.Store, 0)
+	reflector := kcache.NewReflector(lw, &kapi.Pod{}, podLister.Store, time.Hour)
 	stopChan := make(chan struct{})
 	reflector.RunUntil(stopChan)
 	nStore, nController := kframework.NewInformer(