little-durable-objects 0.1.11

Standalone regional durable-object control plane, host, and durability runtime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::{
    sync::OnceLock,
    time::{Instant, SystemTime, UNIX_EPOCH},
};

use anyhow::Result;

pub trait Clock: Send + Sync {
    fn now_ms(&self) -> Result<u64>;
}

#[derive(Clone, Copy, Debug, Default)]
pub struct SystemClock;

static ANCHOR: OnceLock<(SystemTime, Instant)> = OnceLock::new();

impl Clock for SystemClock {
    fn now_ms(&self) -> Result<u64> {
        let (wall, monotonic) = *ANCHOR.get_or_init(|| (SystemTime::now(), Instant::now()));
        let now = wall + monotonic.elapsed();
        Ok(u64::try_from(now.duration_since(UNIX_EPOCH)?.as_millis())?)
    }
}