schedule 0.1.0

An in-process scheduler for periodic jobs. Schedule lets you run Rust functions on a cron-like schedule.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

use std::vec::Vec;

use job::Job;

#[derive(Default)]
pub struct Agenda<'a> {
    jobs: Vec<Job<'a>>,
}

impl<'a> Agenda<'a> {
    pub fn new() -> Agenda<'a> {
        Default::default()
    }

    pub fn add(&mut self, job: Job<'a>) {
        // Add new job
        self.jobs.push(job);

        // Re-sort job list
        self.jobs.sort_by_key(|j| j.next_run_at);
    }

    pub fn run_pending(&mut self) {
        for job in &mut self.jobs {
            if job.is_ready() {
                job.run();
            } else {
                // The jobs array is sorted so the first non-ready job we hit
                // means we're at the end of what we care
                break;
            }
        }

        // Re-sort job list
        self.jobs.sort_by_key(|j| j.next_run_at);
    }
}