in docker/watcher.go [423:435]
func (w *watcher) cleanupWorker() { defer w.stopped.Done() for { select { case <-w.ctx.Done(): return // Wait a full period case <-time.After(w.cleanupTimeout): w.runCleanup() } } }