forge-jobs 0.3.1

Sidekiq-style job queue with embedded SQLite and pluggable Postgres. Per-queue workers + cron + cluster-wide rate-limit budget + cancellation that survives across replicas.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use chrono::{DateTime, Utc};

/// Wall-clock abstraction the scheduler reads through, so tests can
/// advance time without sleeping. Per CLAUDE.md §8 ("inject a clock"
/// rather than `SystemTime::now` deep in business logic).
pub trait Clock: Send + Sync + 'static {
    fn now(&self) -> DateTime<Utc>;
}

/// Production impl. `Utc::now()` ignores `tokio::time::pause()` —
/// this is fine outside tests because real time always moves.
#[derive(Debug, Default, Clone, Copy)]
pub struct SystemClock;

impl Clock for SystemClock {
    fn now(&self) -> DateTime<Utc> {
        Utc::now()
    }
}