1
0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-12-13 07:46:43 +00:00

update scheduler_priority

This commit is contained in:
2019-07-12 15:12:51 +08:00
parent b48d9a92c0
commit 5f9a9b00ce
3 changed files with 16 additions and 15 deletions

View File

@@ -3,8 +3,8 @@ package main
type JobPriority int
const (
Low JobPriority = iota
Medium
Hight
Urgent
Low JobPriority = 1
Medium JobPriority = 25
Hight JobPriority = 50
Urgent JobPriority = 99
)

View File

@@ -103,6 +103,7 @@ func (scheduler *SchedulerPriority) Schedule(job Job) {
right = mid - 1
}
}
fmt.Println(index)
scheduler.queue = append(scheduler.queue, Job{})
copy(scheduler.queue[index+1:], scheduler.queue[index:])

View File

@@ -113,17 +113,17 @@ type NodeStatus struct {
}
type Job struct {
ID int `json:"id"`
Name string `json:"name"`
Tasks []Task `json:"tasks"`
Workspace string `json:"workspace"`
Cluster int `json:"virtual_cluster"`
Priority int `json:"priority"`
RunBefore int `json:"run_before"`
CreatedAt int `json:"created_at"`
UpdatedAt int `json:"updated_at"`
CreatedBy int `json:"created_by"`
Status State `json:"status"`
ID int `json:"id"`
Name string `json:"name"`
Tasks []Task `json:"tasks"`
Workspace string `json:"workspace"`
Cluster int `json:"virtual_cluster"`
Priority JobPriority `json:"priority"`
RunBefore int `json:"run_before"`
CreatedAt int `json:"created_at"`
UpdatedAt int `json:"updated_at"`
CreatedBy int `json:"created_by"`
Status State `json:"status"`
}
type Task struct {