(nodeName string, interruptionEventStore *interruptioneventstore.Store, node node.Node)
| 308 | } |
| 309 | |
| 310 | func handleRebootUncordon(nodeName string, interruptionEventStore *interruptioneventstore.Store, node node.Node) error { |
| 311 | isLabeled, err := node.IsLabeledWithAction(nodeName) |
| 312 | if err != nil { |
| 313 | return err |
| 314 | } |
| 315 | if !isLabeled { |
| 316 | return nil |
| 317 | } |
| 318 | eventID, err := node.GetEventID(nodeName) |
| 319 | if err != nil { |
| 320 | return err |
| 321 | } |
| 322 | err = node.UncordonIfRebooted(nodeName) |
| 323 | if err != nil { |
| 324 | return fmt.Errorf("unable to complete node label actions: %w", err) |
| 325 | } |
| 326 | interruptionEventStore.IgnoreEvent(eventID) |
| 327 | return nil |
| 328 | } |
| 329 | |
| 330 | func watchForInterruptionEvents(interruptionChan <-chan monitor.InterruptionEvent, interruptionEventStore *interruptioneventstore.Store) { |
| 331 | for { |
no test coverage detected