Merge pull request #1024 from aledbf/fix-code-removal
GCE: Revert node handlers removal
This commit is contained in:
commit
f9ce8d799a
1 changed files with 7 additions and 1 deletions
|
@ -170,11 +170,17 @@ func NewLoadBalancerController(kubeClient kubernetes.Interface, clusterManager *
|
||||||
)
|
)
|
||||||
|
|
||||||
// Node watch handlers
|
// Node watch handlers
|
||||||
|
nodeHandlers := cache.ResourceEventHandlerFuncs{
|
||||||
|
AddFunc: lbc.nodeQueue.enqueue,
|
||||||
|
DeleteFunc: lbc.nodeQueue.enqueue,
|
||||||
|
// Nodes are updated every 10s and we don't care, so no update handler.
|
||||||
|
}
|
||||||
|
|
||||||
lbc.nodeLister.Indexer, lbc.nodeController = cache.NewIndexerInformer(
|
lbc.nodeLister.Indexer, lbc.nodeController = cache.NewIndexerInformer(
|
||||||
cache.NewListWatchFromClient(lbc.client.Core().RESTClient(), "nodes", api_v1.NamespaceAll, fields.Everything()),
|
cache.NewListWatchFromClient(lbc.client.Core().RESTClient(), "nodes", api_v1.NamespaceAll, fields.Everything()),
|
||||||
&api_v1.Node{},
|
&api_v1.Node{},
|
||||||
resyncPeriod,
|
resyncPeriod,
|
||||||
cache.ResourceEventHandlerFuncs{},
|
nodeHandlers,
|
||||||
cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc},
|
cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc},
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue