Kubernetes: node autodiscover, add InternalIP (elastic#15930)

* use any node ip
fearful-symmetry · Jan 31, 2020 · 6273589 · 6273589
1 parent 2cde4ce
commit 6273589
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/libbeat/autodiscover/providers/kubernetes/node.go b/libbeat/autodiscover/providers/kubernetes/node.go
@@ -188,7 +188,6 @@ func (n *node) emit(node *kubernetes.Node, flag string) {
 		},
 	}
 	n.publish(event)
-
 }
 
 func getAddress(node *kubernetes.Node) string {
@@ -198,6 +197,12 @@ func getAddress(node *kubernetes.Node) string {
 		}
 	}
 
+	for _, address := range node.Status.Addresses {
+		if address.Type == v1.NodeInternalIP && address.Address != "" {
+			return address.Address
+		}
+	}
+
 	return ""
 }