rrq 0.11.1

RRQ orchestrator CLI and worker runtime.
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

use std::collections::HashMap;

use rrq_config::normalize_queue_name;

pub(crate) fn queue_matches(filter: &str, job_queue: &str) -> bool {
    normalize_queue_name(filter) == normalize_queue_name(job_queue)
}

pub(crate) fn top_counts(map: &HashMap<String, usize>, limit: usize) -> Vec<(String, usize)> {
    let mut items = map.iter().map(|(k, v)| (k.clone(), *v)).collect::<Vec<_>>();
    items.sort_by(|a, b| b.1.cmp(&a.1));
    items.into_iter().take(limit).collect()
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn queue_matches_accepts_exact_and_prefixed() {
        assert!(queue_matches("default", "default"));
        assert!(queue_matches("default", "rrq:queue:default"));
        assert!(queue_matches("rrq:queue:default", "default"));
        assert!(!queue_matches("default", "other"));
    }

    #[test]
    fn top_counts_orders_and_limits() {
        let mut map = HashMap::new();
        map.insert("a".to_string(), 1);
        map.insert("b".to_string(), 3);
        map.insert("c".to_string(), 2);
        let top = top_counts(&map, 2);
        assert_eq!(top.len(), 2);
        assert_eq!(top[0].0, "b");
        assert_eq!(top[1].0, "c");
    }
}