The library allows for creating 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.
- Send/receive tasks in Redis
- Delayed tasks
- Support json
- Deleting from a storage after handling
- Support Redis Cluster
- Metrics
- Redis 6.2.0 or higher
cargo add taskline