add jhl

README.md

@@ -1 +1,16 @@
-# YAO-scheduler
+# YAO-scheduler
+
+
+## API
+
+**GetHeartCounter**
+
+```
+?action=get_counter
+```
+
+**GetJobTaskStatusJHL**
+
+```
+?action=jhl_job_status&job=
+```

src/history_logger.go

@@ -53,3 +53,10 @@ func (jhl *JobHistoryLogger) submitTaskStatus(jobName string, task TaskStatus) {
 		jhl.tasks[jobName] = append(tasks, task)
 	}
 }
+
+func (jhl *JobHistoryLogger) getTaskStatus(jobName string) []TaskStatus {
+	if _, ok := jhl.tasks[jobName]; ok {
+		return jhl.tasks[jobName]
+	}
+	return []TaskStatus{}
+}

src/job_manager.go

@@ -93,9 +93,13 @@ func (jm *JobManager) start() {
 		res := jm.status()
 		flag := false
 		for i := range res.Status {
-			if res.Status[i].Status == "running" {
+			if res.Status[i].Status == "ready" {
+				log.Info(jm.job.Name, "-", i, " is ready to run")
+				flag = true
+			} else if res.Status[i].Status == "running" {
 				log.Info(jm.job.Name, "-", i, " is running")
 				flag = true
+				InstanceJobHistoryLogger().submitTaskStatus(jm.job.Name, res.Status[i])
 			} else {
 				log.Println(jm.job.Name, "-", i, " ", res.Status[i].Status)
 

src/main.go

@@ -150,6 +150,13 @@ func serverAPI(w http.ResponseWriter, r *http.Request) {
 		w.Write(js)
 		break
 
+	case "jhl_job_status":
+		log.Debug("jhl_job_status")
+		js, _ := json.Marshal(InstanceJobHistoryLogger().getTaskStatus(r.URL.Query().Get("job")))
+		w.Header().Set("Content-Type", "application/json")
+		w.Write(js)
+		break
+
 	default:
 		http.Error(w, "Not Found", http.StatusNotFound)
 		break