jono_core 0.1.1

Shared core utilities for Jono queue libraries
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::time::{SystemTime, UNIX_EPOCH};
use ulid::Ulid;

/// A standardized way to read JONO_REDIS_URL env var
pub fn get_redis_url() -> String {
    std::env::var("JONO_REDIS_URL").unwrap_or_else(|_| "redis://localhost:6380".to_string())
}

/// Generate a new ULID for a job
pub fn generate_job_id() -> String {
    Ulid::new().to_string()
}

/// Get current timestamp in milliseconds since UNIX epoch
pub fn current_timestamp_ms() -> i64 {
    SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .expect("Time went backwards")
        .as_millis() as i64
}