resc 0.3.1

A Redis based task orchestrator
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use {
    crate::{
        rule::Rule,
    },
    serde::Deserialize,
};

/// all the rules of a watcher, that is the rules
/// related to an input queue
#[derive(Debug, Deserialize)]
pub struct Ruleset {
    pub rules: Vec<Rule>,
}

impl Ruleset {
    pub fn matching_rules(&self, task: &str) -> Vec<&Rule> {
        self.rules.iter().filter(|r| r.is_match(&task)).collect()
    }
}