func()

in pkg/interruptioneventstore/interruption-event-store.go [107:113]

• 7 lines of code
• 5 McCabe index (conditional complexity)

func (s *Store) shouldEventDrain(interruptionEvent *monitor.InterruptionEvent) bool {
	_, ignored := s.ignoredEvents[interruptionEvent.EventID]
	if !ignored && !interruptionEvent.InProgress && !interruptionEvent.NodeProcessed && s.TimeUntilDrain(interruptionEvent) <= 0 {
		return true
	}
	return false
}