Method RunLoop

internal/execute/watchmanager/watchmanager.go:331–341

(ctx context.Context, doCycle func())

}

func (wm *WatchManager) RunLoop(ctx context.Context, doCycle func()) {
	for {
		select {
		case <-ctx.Done():
			wm.CloseAllWatches()
			return
		case <-wm.doCycleCh:
			doCycle()
		}
	}
}