doido-core 0.1.0

Core errors (thiserror), anyhow Result, serde, tracing, and regex helpers for the Doido framework.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use doido_core::notifications::Notifications;
use std::sync::{Arc, Mutex};

#[test]
fn subscribers_receive_only_matching_events() {
    let hits = Arc::new(Mutex::new(Vec::<String>::new()));

    let mut bus = Notifications::new();
    let h = hits.clone();
    bus.subscribe("sql.", move |name, _payload| {
        h.lock().unwrap().push(name.to_string())
    });

    bus.instrument("sql.query", "SELECT 1");
    bus.instrument("http.request", "/");
    bus.instrument("sql.commit", "");

    assert_eq!(*hits.lock().unwrap(), vec!["sql.query", "sql.commit"]);
}