Method defaultLogCounterInfo

tasks.go:370–382

(ctx *TaskContext)

}

func (service *TaskService) defaultLogCounterInfo(ctx *TaskContext) error {
	showInfos := []*ShowCountInfo{}
	for _, t := range service.GetAllTasks() {
		//service.Logger().Debug(t.TaskID(), " Start:", t.CounterInfo().StartTime.Format(fullTimeLayout), " RUN:", t.CounterInfo().RunCounter.Count(), " ERROR:", t.CounterInfo().ErrorCounter.Count())
		showInfos = append(showInfos, &ShowCountInfo{TaskID: t.TaskID(), Lable: "RUN", Count: t.CounterInfo().RunCounter.Count()})
		showInfos = append(showInfos, &ShowCountInfo{TaskID: t.TaskID(), Lable: "ERROR", Count: t.CounterInfo().ErrorCounter.Count()})
	}
	if len(showInfos) > 0 {
		str, _ := json.Marshal(showInfos)
		service.Logger().Debug(string(str))
	}
	return nil
}

// ValidateTaskType validate the TaskType is supported
func ValidateTaskType(taskType string) bool {