Get Node object from APIServer cache

linxiulei · linxiulei · commit 7dd7c14868ea · 2024-02-20T14:23:13.000Z
diff --git a/pkg/exporters/k8sexporter/problemclient/problem_client.go b/pkg/exporters/k8sexporter/problemclient/problem_client.go
@@ -130,7 +130,9 @@ func (c *nodeProblemClient) Eventf(eventType, source, reason, messageFmt string,
 }
 
 func (c *nodeProblemClient) GetNode(ctx context.Context) (*v1.Node, error) {
-	return c.client.Nodes().Get(ctx, c.nodeName, metav1.GetOptions{})
+	// To reduce the load on APIServer & etcd, we are serving GET operations from
+	// apiserver cache (the data might be slightly delayed).
+	return c.client.Nodes().Get(ctx, c.nodeName, metav1.GetOptions{ResourceVersion: "0"})
 }
 
 // generatePatch generates condition patch

Original file line number	Diff line number	Diff line change
`@@ -130,7 +130,9 @@ func (c *nodeProblemClient) Eventf(eventType, source, reason, messageFmt string,`
`130`	`130`	`}`
`131`	`131`
`132`	`132`	`func (c nodeProblemClient) GetNode(ctx context.Context) (v1.Node, error) {`
`133`		`- return c.client.Nodes().Get(ctx, c.nodeName, metav1.GetOptions{})`
	`133`	`+ // To reduce the load on APIServer & etcd, we are serving GET operations from`
	`134`	`+ // apiserver cache (the data might be slightly delayed).`
	`135`	`+ return c.client.Nodes().Get(ctx, c.nodeName, metav1.GetOptions{ResourceVersion: "0"})`
`134`	`136`	`}`
`135`	`137`
`136`	`138`	`// generatePatch generates condition patch`