add k8s node labels

This commit is contained in:
Jesse Haka 2023-02-01 21:11:11 +02:00
parent e7b778f77a
commit 9df5534a13
1 changed files with 9 additions and 1 deletions

View File

@ -36,7 +36,8 @@ import (
)
const (
cacheTTL = 60 * time.Minute
cacheTTL = 60 * time.Minute
ClusterAutoscalerNodeTemplateLabel = "k8s.io_cluster-autoscaler_node-template_label_"
)
// nodeIdentifier identifies a node
@ -137,6 +138,13 @@ func (i *nodeIdentifier) IdentifyNode(ctx context.Context, node *corev1.Node) (*
}
}
for key, value := range server.Metadata {
if strings.HasPrefix(key, ClusterAutoscalerNodeTemplateLabel) {
trimKey := strings.ReplaceAll(strings.TrimPrefix(key, ClusterAutoscalerNodeTemplateLabel), "_", "/")
labels[trimKey] = value
}
}
info := &nodeidentity.Info{
InstanceID: instanceID,
Labels: labels,