Method processRuntimeStats

pkg/controller/task.go:294–313

(rt *rtctrl.RuntimeInfo, logger *logs.Logger)

}

func (controller *Controller) processRuntimeStats(rt *rtctrl.RuntimeInfo, logger *logs.Logger) {
	input := api.FuncletClientContainerInfoInput{
		RequestID: id.GetRequestID(),
		ID:        rt.RuntimeID,
	}
	info, err := controller.FuncletClient.Info(&input)
	if err != nil {
		logger.Errorf("get runtime %s info from funclet failed: %s", rt.RuntimeID, err)
		return
	}
	if info.ResourceStats == nil || info.ResourceStats.CPUStats == nil || info.ResourceStats.MemoryStats == nil {
		logger.Warnf("get runtime %s info from funclet failed: resource stats is nil", rt.RuntimeID)
		return
	}
	value := metric.GetCounterValue(RuntimeMetricName(RuntimeCPUUsageSeconds), info.ContainerID)
	inc := (float64(info.ResourceStats.CPUStats.TotalUsage) - value) / float64(time.Second)
	metric.AddWithLabels(RuntimeMetricName(RuntimeCPUUsageSeconds), inc, getResourceLabels(info.ContainerID))
	metric.SetGaugeWithLabels(RuntimeMetricName(RuntimeMemoryUsageBytes), float64(info.ResourceStats.MemoryStats.Usage), getResourceLabels(info.ContainerID))
	return
}

func getResourceLabels(ID string) *prometheus.Labels {
	labels := prometheus.Labels{}