MCPcopy Create free account
hub / github.com/aws/aws-node-termination-handler / handleRebootUncordon

Function handleRebootUncordon

cmd/node-termination-handler.go:310–328  ·  view source on GitHub ↗
(nodeName string, interruptionEventStore *interruptioneventstore.Store, node node.Node)

Source from the content-addressed store, hash-verified

308}
309
310func 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
330func watchForInterruptionEvents(interruptionChan <-chan monitor.InterruptionEvent, interruptionEventStore *interruptioneventstore.Store) {
331 for {

Callers 1

mainFunction · 0.85

Calls 4

IsLabeledWithActionMethod · 0.80
GetEventIDMethod · 0.80
UncordonIfRebootedMethod · 0.80
IgnoreEventMethod · 0.80

Tested by

no test coverage detected