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

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

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

    let etcd = etcd_client::Client::connect(vec!["localhost:2379"], None).await?;

    let driver = driver::etcd::EtcdDriver::new(etcd, "example-service", &uuid::Uuid::new_v4().to_string()).await?;
    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(())
}