Method runtimeMetrics

pkg/controller/task.go:273–292

(logger *logs.Logger)

}

func (controller *Controller) runtimeMetrics(logger *logs.Logger) {
	if !controller.runOptions.RecommendedOptions.Features.EnableMetrics {
		return
	}
	logger.Info("start runtime stats task")
	runtimes := controller.runtimeDispatcher.RuntimeList()
	var wg sync.WaitGroup
	for _, runtime := range runtimes {
		if runtime == nil {
			continue
		}
		wg.Add(1)
		go func(rt *rtctrl.RuntimeInfo, logger *logs.Logger) {
			controller.processRuntimeStats(rt, logger)
			wg.Done()
		}(runtime, logger)
	}
	wg.Wait()
	logger.Info("finish runtime stats task")
}

func (controller *Controller) processRuntimeStats(rt *rtctrl.RuntimeInfo, logger *logs.Logger) {
	input := api.FuncletClientContainerInfoInput{