apalis-cron 0.4.8

A simple yet extensible library for cron-like job scheduling for rust.
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

# 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

```rust
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();
}
```