func()

in pipeline/endpoints/disk.go [127:141]

• 15 lines of code
• 4 McCabe index (conditional complexity)

func (ep *DiskEndpoint) run(start time.Time) {
	nextFire := start.Add(cleanupInterval)
	for {
		t := ep.clock.NewTimerAt(nextFire)
		select {
		case <-t.GetC():
			ep.cleanup()
		case <-ep.quit:
			ep.wait.Done()
			return
		}
		t.Stop()
		nextFire = nextFire.Add(cleanupInterval)
	}
}