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
pub struct Observe;
impl Observe {
pub fn observe_with_result<F, T, E>(
table_name: &str,
is_critical: bool,
run: F,
) -> Result<T, E>
where
F: FnOnce() -> Result<T, E>,
E: std::fmt::Display,
Self: Sized,
{
crate::start_span(table_name);
match run() {
Ok(r) => {
crate::end_span(is_critical, None);
Ok(r)
}
Err(e) => {
crate::end_span(is_critical, Some(e.to_string()));
Err(e)
}
}
}
pub fn observe_all<F, T>(table_name: &str, is_critical: bool, run: F) -> T
where
F: FnOnce() -> T,
Self: Sized,
{
crate::start_span(table_name);
let result = run();
crate::end_span(is_critical, None);
result
}
}