in pkg/k8sutil/marker.go [15:34]
func PostMetadata(nc v1.NodeInterface, nodeName string, cont marker.Container) error {
node, err := nc.Get(context.TODO(), nodeName, v1meta.GetOptions{})
if err != nil {
return errors.WithMessage(err, "unable to get node")
}
marker.OverwriteFrom(cont, node)
if logging.Debuggable {
l := logging.New("k8sutil")
l.WithFields(logrus.Fields{
"node": nodeName,
"annotations": node.GetAnnotations(),
"labels": node.GetLabels(),
}).Debug("merged in new metadata")
}
_, err = nc.Update(context.TODO(), node, v1meta.UpdateOptions{})
if err != nil {
return errors.WithMessage(err, "unable to update node")
}
return nil
}