kubernetes
/
kops
mirror of https://github.com/kubernetes/kops.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

protokube - query host by label when setting master tags

This commit is contained in:
Rodrigo Menezes 2020-12-11 15:14:55 -08:00
parent 916ff32a2d
commit 01842c3d39
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
protokube/pkg/protokube/labeler.go
View File

@ -34,10 +34,17 @@ func bootstrapMasterNodeLabels(ctx context.Context, kubeContext *KubernetesConte
} }
klog.V(2).Infof("Querying k8s for node %q", nodeName) klog.V(2).Infof("Querying k8s for node %q", nodeName)
node, err := client.CoreV1().Nodes().Get(ctx, nodeName, metav1.GetOptions{}) labelSelector := fmt.Sprintf("kubernetes.io/hostname=%s", nodeName)
listOptions := metav1.ListOptions{
LabelSelector: labelSelector,
}
nodes, err := client.CoreV1().Nodes().List(ctx, listOptions)
if err != nil { if err != nil {
return fmt.Errorf("error querying node %q: %v", nodeName, err) return fmt.Errorf("error querying node %q: %v", nodeName, err)
} else if len(nodes.Items) != 1 {
return fmt.Errorf("error querying node %q: expected 1 node with label %v, found %d", nodeName, labelSelector, len(nodes.Items))
} }
node := nodes.Items[0]
labels := map[string]string{ labels := map[string]string{
"node-role.kubernetes.io/master": "", "node-role.kubernetes.io/master": "",