cloudiful-scheduler 0.4.2

Single-job async scheduling library for background work with optional Valkey-backed state.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use redis::Client;
use std::time::{SystemTime, UNIX_EPOCH};

pub fn valkey_url() -> Option<String> {
    std::env::var("SCHEDULER_VALKEY_URL").ok()
}

pub fn unique_id(prefix: &str) -> String {
    let now = SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .expect("system time before unix epoch")
        .as_nanos();
    format!("{prefix}-{}-{now}", std::process::id())
}

pub async fn connection(url: &str) -> redis::aio::MultiplexedConnection {
    Client::open(url)
        .expect("invalid valkey url")
        .get_multiplexed_async_connection()
        .await
        .expect("failed to get valkey connection")
}