Method runtimeTask

pkg/controller/task.go:105–118

(logger *logs.Logger)

}

func (controller *Controller) runtimeTask(logger *logs.Logger) {
	logger.Info("start runtime task")
	runtimes := controller.runtimeDispatcher.RuntimeList()
	var wg sync.WaitGroup
	for _, runtime := range runtimes {
		wg.Add(1)
		go func(rt *rtctrl.RuntimeInfo, logger *logs.Logger) {
			controller.processRuntime(rt, logger)
			wg.Done()
		}(runtime, logger)
	}
	wg.Wait()
	logger.Info("finish runtime task")
}

func (controller *Controller) processRuntime(runtime *rtctrl.RuntimeInfo, logger *logs.Logger) {
	controller.coolDown(runtime, logger)