in kubernetes/util.go [197:217]
func discoverByMachineID(nd *DiscoverKubernetesNodeParams, ctx context.Context) (nodeName string, errorMsg error) {
mid := nd.HostUtils.GetMachineID()
if mid == "" {
errorMsg = errors.New("kubernetes: Couldn't collect info from any of the files in /etc/machine-id /var/lib/dbus/machine-id")
return
}
nodes, err := nd.Client.CoreV1().Nodes().List(ctx, metav1.ListOptions{})
if err != nil {
errorMsg = fmt.Errorf("kubernetes: Querying for nodes failed with error: %w", err)
return
}
for _, n := range nodes.Items {
if n.Status.NodeInfo.MachineID == mid {
nodeName = n.GetObjectMeta().GetName()
return nodeName, nil
}
}
errorMsg = fmt.Errorf("kubernetes: Couldn't discover node %s", mid)
return nodeName, errorMsg
}