murgamu 0.8.4

A NestJS-inspired web framework for Rust
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

use super::MurHealthIndicator;
use super::MurHealthIndicatorResult;
use std::future::Future;
use std::pin::Pin;
use std::time::Duration;

pub struct MurCustomIndicator<F>
where
	F: Fn() -> Pin<Box<dyn Future<Output = MurHealthIndicatorResult> + Send>> + Send + Sync,
{
	name: String,
	check_fn: F,
	timeout: Duration,
}

impl<F> MurCustomIndicator<F>
where
	F: Fn() -> Pin<Box<dyn Future<Output = MurHealthIndicatorResult> + Send>> + Send + Sync,
{
	pub fn new(name: impl Into<String>, check_fn: F) -> Self {
		Self {
			name: name.into(),
			check_fn,
			timeout: Duration::from_secs(5),
		}
	}

	pub fn timeout(mut self, timeout: Duration) -> Self {
		self.timeout = timeout;
		self
	}
}

impl<F> MurHealthIndicator for MurCustomIndicator<F>
where
	F: Fn() -> Pin<Box<dyn Future<Output = MurHealthIndicatorResult> + Send>>
		+ Send
		+ Sync
		+ 'static,
{
	fn check(&self) -> Pin<Box<dyn Future<Output = MurHealthIndicatorResult> + Send + '_>> {
		(self.check_fn)()
	}

	fn name(&self) -> &str {
		&self.name
	}

	fn timeout(&self) -> Duration {
		self.timeout
	}
}