apalis-cron 0.4.8

A simple yet extensible library for cron-like job scheduling for rust.
docs.rs failed to build apalis-cron-0.4.8
Please check the build logs for more information.
See Builds for ideas on how to fix a failed build, or Metadata for how to configure docs.rs builds.
If you believe this is docs.rs' fault, open an issue.
Visit the last successful build: apalis-cron-1.0.0-rc.4

apalis-cron

A simple yet extensible library for cron-like job scheduling for rust. Since apalis-cron is build on top of apalis which supports tower middleware, you should be able to easily add middleware such as tracing, retries, load shed, concurrency etc.

Example

use apalis::prelude::*;
use apalis::layers::{Extension, DefaultRetryPolicy, RetryLayer};
use apalis::cron::Schedule;
use tower::ServiceBuilder;
use std::str::FromStr;

#[derive(Default, Debug, Clone)]
struct Reminder;

impl Job for Reminder {
    const NAME: &'static str = "reminder::DailyReminder";
}
async fn send_reminder(job: Reminder, ctx: JobContext) {
    // Do reminder stuff
}

#[tokio::main]
async fn main() {
    let schedule = Schedule::from_str("@daily").unwrap();

    let service = ServiceBuilder::new()
        .layer(RetryLayer::new(DefaultRetryPolicy))
        .service(job_fn(send_reminder));

    let worker = WorkerBuilder::new("daily-cron-worker")
        .stream(CronStream::new(schedule).to_stream())
        .build(service);

    Monitor::new()
        .register(worker)
        .run()
        .await
        .unwrap();
}