asynq 0.1.8

Simple, reliable & efficient distributed task queue in Rust, inspired by hibiken/asynq
Documentation 
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
44
45
46

use anyhow::Result;
#[cfg(all(feature = "sentinel", feature = "json"))]
use serde::{Deserialize, Serialize};
#[cfg(all(feature = "sentinel", feature = "json"))]
#[derive(Serialize, Deserialize)]
struct EmailPayload {
  to: String,
  subject: String,
  body: String,
}
#[cfg(all(feature = "sentinel", feature = "json"))]
#[tokio::main]
async fn main() -> Result<()> {
  // Assumptions:
  // - Sentinel is running on localhost:26379
  // - The monitored master name is `mymaster` (change below if different)
  let master_name = "mymaster";
  // sentinel addresses (change as needed)
  let sentinels = vec!["redis://localhost:26379"];
  let redis_connection_info = Some(
    redis::RedisConnectionInfo::default()
      .set_db(0)
      .set_password("mypassword"),
  );
  let redis_config =
    asynq::backend::RedisConnectionType::sentinel(master_name, sentinels, redis_connection_info)?;
  let client = asynq::client::Client::new(redis_config).await?;
  // Create task
  let payload = EmailPayload {
    to: "user@example.com".to_string(),
    subject: "Welcome!".to_string(),
    body: "Welcome to our service!".to_string(),
  };

  let task = asynq::task::Task::new_with_json("email:send", &payload)?;

  // Enqueue task
  let task_info = client.enqueue(task).await?;
  println!("Task enqueued with ID: {}", task_info.id);
  Ok(())
}
#[cfg(not(all(feature = "sentinel", feature = "json")))]
#[tokio::main]
async fn main() -> Result<()> {
  Ok(())
}