Get node info from listerv1.NodeLister(index)

Get node info from informer index rather than real API, it will reduce the pressure for kube api
kubeovn · May 9, 2021 · 4458a4d · 4458a4d
1 parent 47ef2ec
commit 4458a4d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/daemon/gateway.go b/pkg/daemon/gateway.go
@@ -251,7 +251,7 @@ func (c *Controller) setIptables() error {
 }
 
 func (c *Controller) setGatewayBandwidth() error {
-	node, err := c.config.KubeClient.CoreV1().Nodes().Get(context.Background(), c.config.NodeName, metav1.GetOptions{})
+	node, err := c.nodesLister.Get(c.config.NodeName)
 	if err != nil {
 		klog.Errorf("failed to get node, %v", err)
 		return err
@@ -262,7 +262,7 @@ func (c *Controller) setGatewayBandwidth() error {
 }
 
 func (c *Controller) setICGateway() error {
-	node, err := c.config.KubeClient.CoreV1().Nodes().Get(context.Background(), c.config.NodeName, metav1.GetOptions{})
+	node, err := c.nodesLister.Get(c.config.NodeName)
 	if err != nil {
 		klog.Errorf("failed to get node, %v", err)
 		return err
@@ -291,7 +291,7 @@ func (c *Controller) setICGateway() error {
 }
 
 func (c *Controller) setExGateway() error {
-	node, err := c.config.KubeClient.CoreV1().Nodes().Get(context.Background(), c.config.NodeName, metav1.GetOptions{})
+	node, err := c.nodesLister.Get(c.config.NodeName)
 	if err != nil {
 		klog.Errorf("failed to get node, %v", err)
 		return err