willdo 0.0.1

Task manager with DAG
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

//! Job graph abstraction

use super::{commander::Commander, progress::ProgressTracker};
use crate::job::{Job, JobId};
use std::sync::Arc;

/// A built [JobRepository] knows the job graph and can decide which jobs are required and which jobs can be executed.
pub trait JobRepository {
    /// Get a list of jobs ready to run for the goals
    fn execute(&mut self, goals: &[Box<str>]) -> Vec<Execution>;
    /// Get a list of jobs required to satisfy the oals
    fn select(&self, goals: &[Box<str>]) -> Vec<JobId>;
}
impl<T: JobRepository> JobRepository for &mut T {
    fn execute(&mut self, goals: &[Box<str>]) -> Vec<Execution> {
        T::execute(self, goals)
    }
    fn select(&self, goals: &[Box<str>]) -> Vec<JobId> {
        T::select(self, goals)
    }
}

/// A scheduled job instance
#[derive(Debug, Clone)]
pub struct Execution {
    job: Arc<Job>,
    commander: Arc<dyn Commander + Send + Sync>,
    progress: Arc<dyn ProgressTracker + Send + Sync>,
}
impl Execution {
    /// Create a new job exectuion
    pub fn new(
        job: Arc<Job>,
        commander: Arc<dyn Commander + Send + Sync>,
        progress: Arc<dyn ProgressTracker + Send + Sync>,
    ) -> Self {
        Self {
            job,
            commander,
            progress,
        }
    }
    /// Get executed job
    pub fn job(&self) -> &Job {
        &self.job
    }
    /// Get assigned commander
    pub fn commander(&self) -> &dyn Commander {
        self.commander.as_ref()
    }
    /// Get assigned progress tracker
    pub fn progress(&self) -> &dyn ProgressTracker {
        self.progress.as_ref()
    }
}