distributed-scheduler 2.2.4

A distributed cronjob library
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

use distributed_scheduler::{cron, driver, node_pool};

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    tracing_subscriber::fmt::init();

    let rdb = redis::Client::open("redis://localhost:6379")?;
    let con = redis::aio::ConnectionManager::new(rdb).await?;

    let driver = driver::redis::RedisDriver::new(con.clone(), "example-service", &uuid::Uuid::new_v4().to_string())
        .await?
        .with_timeout(3);
    let np = node_pool::NodePool::new(driver).await?;
    let cron = cron::Cron::new(np).await;

    tracing::info!("Adding job");
    cron.add_job("test", "* * * * * *".parse().unwrap(), || {
        tracing::info!("Running job: {}", chrono::Utc::now());
    })
    .await?;

    tracing::info!("Starting cron");
    cron.start().await?;

    Ok(())
}