INNER CODE UNIT · Go

maintainRebootRequiredMetric

kubereboot/kured · cmd/kured/main.go:482

func maintainRebootRequiredMetric(nodeID string, checker checkers.Checker) {
	for {
		if checker.RebootRequired() {
			rebootRequiredGauge.WithLabelValues(nodeID).Set(1)
		} else {
			rebootRequiredGauge.WithLabelValues(nodeID).Set(0)
		}
		time.Sleep(time.Minute)
	}
}

func addNodeAnnotations(client *kubernetes.Clientset, nodeID string, annotations map[string]string) error {
	node, err := client.CoreV1().Nodes().Get(context.TODO(), nodeID, metav1.GetOptions{})
	if err != nil {
		log.Errorf("Error retrieving node object via k8s API: %s", err)
		return err
	}
	for k, v := range annotations {

View source record →