func GetNodeResourceID()

in cmd/utils/k8s.go [20:32]


func GetNodeResourceID(ctx context.Context, nodeName string) (string, error) {
	client, err := k8sutil.NewClientsetFromConfigFlags(KubernetesConfigFlags)
	if err != nil {
		return "", err
	}

	nodeRes, err := client.CoreV1().Nodes().Get(ctx, nodeName, metaV1.GetOptions{})
	if err != nil {
		return "", err
	}

	return strings.TrimPrefix(nodeRes.Spec.ProviderID, "azure://"), nil
}