mosaik 0.3.19

A Rust runtime for building self-organizing, leaderless distributed systems.
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
56
57
58
59
60
61
62

#[ctor::ctor]
fn init_test_logging() {
	use tracing_subscriber::{filter::filter_fn, prelude::*};

	// Avoid re-initializing if a global default subscriber is already set
	if tracing::dispatcher::has_been_set() {
		return;
	}

	if let Ok(v) = std::env::var("TEST_TRACE") {
		let level = match v.as_str() {
			"true" | "debug" | "on" => tracing::Level::DEBUG,
			"trace" => tracing::Level::TRACE,
			"info" => tracing::Level::INFO,
			"warn" => tracing::Level::WARN,
			"error" => tracing::Level::ERROR,
			_ => return,
		};

		// disable noisy modules from dependencies
		let muted: &[&'static str] = &[
			"iroh",
			"rustls",
			"igd_next",
			"hickory_",
			"hyper_util",
			"portmapper",
			"reqwest",
			"events.net.relay.connected",
			"netwatch",
			"mio",
			"acto",
			"swarm_discovery",
			"mainline",
			"pkarr",
			"noq",
		];

		// disable disabling noisy modules tracing
		let unmute = std::env::var("TEST_TRACE_UNMUTE")
			.is_ok_and(|val| val == "1" || val == "on" || val == "yes");

		let _ = tracing_subscriber::registry()
			.with(tracing_subscriber::fmt::layer())
			.with(filter_fn(move |metadata| {
				metadata.level() <= &level
					&& (unmute
						|| !muted
							.iter()
							.any(|prefix| metadata.target().starts_with(prefix)))
			}))
			.try_init();

		// Set a custom panic hook that prints and aborts
		let default_hook = std::panic::take_hook();
		std::panic::set_hook(Box::new(move |panic_info| {
			default_hook(panic_info);
			tracing::error!("panic: {panic_info}");
			std::process::abort();
		}));
	}
}