func PostMetadata()

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
}