INNER CODE UNIT · Go

tick

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

	tick := delaytick.New(source, 1*time.Minute)
	for range tick {
		holding, lockData, err := lock.Holding()
		if err != nil {
			log.Errorf("Error testing lock: %v", err)
		}
		if holding {
			node, err := client.CoreV1().Nodes().Get(context.TODO(), nodeID, metav1.GetOptions{})
			if err != nil {
				log.Errorf("Error retrieving node object via k8s API: %v", err)
				continue
			}

			if !lockData.Metadata.Unschedulable {
				err = uncordon(client, node)
				if err != nil {
					log.Errorf("Unable to uncordon %s: %v, will continue to hold lock and retry uncordon", node.GetName(), err)
					continue

View source record →