()
| 34 | } |
| 35 | |
| 36 | func (q *scheduleQueue) GetJobs() (jobs []jobScheduleInfo) { |
| 37 | cur := q.list.Iterator() |
| 38 | defer cur.Close() |
| 39 | |
| 40 | for cur.Next() { |
| 41 | cj := cur.Value().(*mirrorJob) |
| 42 | jobs = append(jobs, jobScheduleInfo{ |
| 43 | cj.Name(), |
| 44 | cur.Key().(time.Time), |
| 45 | }) |
| 46 | } |
| 47 | return |
| 48 | } |
| 49 | |
| 50 | func (q *scheduleQueue) AddJob(schedTime time.Time, job *mirrorJob) { |
| 51 | q.Lock() |
no test coverage detected