Taskline

The library allows to create scheduled tasks via Redis for Rust.

producer.schedule(&"Hello!".to_string(), &(now() + 30000.)).await;

loop {
    let tasks = consumer.poll(&now()).await.unwrap();

    for task in tasks {
        println!("Consumed {:?}", task);
    }
}

That means the Consumed will be printed in 30 seconds.

You can customize a format of an event for redis. Write your wrapper over RedisBackend. See redis_json backend.

diagram

Features

Send/receive tasks in redis
Delayed tasks
Support json
Deleting from storage after handling. Experimental implementation
Support redis cluster
Metrics

Requirements

Redis 6.2.0 or higher

Installation

Cargo

cargo add taskline

License

MIT LICENSE

Contribution

CONTRIBUTING.md