func()

in pkg/interruptioneventstore/interruption-event-store.go [167:185]

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

func (s *Store) cleanPeriodically() {
	s.Lock()
	defer s.Unlock()
	s.callsSinceLastClean++
	if s.callsSinceLastClean < s.cleaningPeriod {
		return
	}
	log.Info().Msg("Garbage-collecting the interruption event store")
	toDelete := []string{}
	for _, e := range s.interruptionEventStore {
		if e.NodeProcessed {
			toDelete = append(toDelete, e.EventID)
		}
	}
	for _, id := range toDelete {
		delete(s.interruptionEventStore, id)
	}
	s.callsSinceLastClean = 0
}