thingvellir 0.0.14

a concurrent, shared-nothing abstraction that manages an assembly of things
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

use crate::ServiceData;
use tokio::time::Instant;

/// Checks if the data is expired, because it's elapsed the TTL.
#[inline]
pub(super) fn is_expired<Data: ServiceData>(data: &Data) -> bool {
    match data.get_expires_at() {
        None => false,
        Some(expires_at) => *expires_at <= Instant::now(),
    }
}

pub(super) struct AbortOnPanic(String);

impl AbortOnPanic {
    pub(super) fn new(reason: String) -> Self {
        Self(reason)
    }
}

impl Drop for AbortOnPanic {
    fn drop(&mut self) {
        if std::thread::panicking() {
            eprintln!("Process aborted, because: {}", self.0);
            std::process::abort();
        }
    }
}