bonsaimq 0.3.0

Message/job queue based on bonsaidb, similar to sqlxmq.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! Common example functions

use std::sync::Once;

use tracing::level_filters::LevelFilter;
use tracing_subscriber::EnvFilter;

/// Initialize test environment.
pub fn init() {
	/// Do init only once.
	static SETUP: Once = Once::new();
	SETUP.call_once(|| {
		color_eyre::install().expect("color-eyre");

		let level_filter = LevelFilter::WARN;
		let filter = EnvFilter::from_default_env()
			.add_directive(level_filter.into())
			.add_directive("want=warn".parse().expect("parse env filter"))
			.add_directive("mio=warn".parse().expect("parse env filter"));
		tracing_subscriber::fmt().with_test_writer().with_env_filter(filter).init();
	});
}