fix: kubernetes node pod relationship

flanksource · Oct 17, 2024 · ac017ac · ac017ac
1 parent 8be764c
commit ac017ac
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/scrapers/kubernetes/hook_aws.go b/scrapers/kubernetes/hook_aws.go
@@ -41,7 +41,7 @@ func (aws AWS) OnObject(ctx *KubernetesContext, obj *unstructured.Unstructured)
 		}
 	}
 	if obj.GetKind() == "Pod" && obj.GetLabels()["app.kubernetes.io/name"] == "aws-node" {
-		nodeName := getString(obj, "spec.nodeName")
+		nodeName := getString(obj, "spec", "nodeName")
 		spec := obj.Object["spec"].(map[string]interface{})
 		for _, ownerRef := range obj.GetOwnerReferences() {
 			if ownerRef.Kind == "DaemonSet" && ownerRef.Name == "aws-node" {

diff --git a/scrapers/kubernetes/kubernetes.go b/scrapers/kubernetes/kubernetes.go
@@ -42,8 +42,7 @@ func getConfigTypePrefix(apiVersion string) string {
 	return ConfigTypePrefix
 }
 
-type KubernetesScraper struct {
-}
+type KubernetesScraper struct{}
 
 func (kubernetes KubernetesScraper) CanScrape(configs v1.ScraperSpec) bool {
 	return len(configs.Kubernetes) > 0
@@ -298,7 +297,7 @@ func ExtractResults(ctx *KubernetesContext, objs []*unstructured.Unstructured) v
 		}
 
 		if obj.GetKind() == "Pod" {
-			nodeName := getString(obj, "spec.nodeName")
+			nodeName := getString(obj, "spec", "nodeName")
 
 			if nodeName != "" {
 				nodeID := ctx.GetID("", "Node", nodeName)