flashq 0.4.0

High-performance Rust client for flashQ job queue
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
47
48
49
50
51

/// Example 04: Delayed Jobs - Schedule Jobs for Future Execution
///
/// Demonstrates pushing jobs with a delay.
use std::time::Duration;

use flashq::{FlashQ, PushOptions};

#[tokio::main]
async fn main() -> flashq::Result<()> {
    let client = FlashQ::new();
    client.connect().await?;

    // Push a delayed job (2 seconds)
    let id = client
        .push(
            "scheduled",
            serde_json::json!({"action": "send-reminder"}),
            Some(PushOptions {
                delay: Some(2000), // 2 seconds
                ..Default::default()
            }),
        )
        .await?;
    println!("Pushed delayed job: {id}");

    // Check state - should be "delayed"
    let state = client.get_state(id).await?;
    println!("State right after push: {:?}", state);

    // Try to pull immediately - should get nothing
    let job = client
        .pull("scheduled", Some(Duration::from_secs(1)))
        .await?;
    println!("Pull before delay: {:?}", job.is_some());

    // Wait for the delay
    println!("Waiting 2 seconds for job to become ready...");
    tokio::time::sleep(Duration::from_secs(2)).await;

    // Now pull should work
    if let Some(job) = client
        .pull("scheduled", Some(Duration::from_secs(3)))
        .await?
    {
        println!("Pulled delayed job {}: {:?}", job.id, job.data);
        client.ack(job.id, None).await?;
    }

    client.close().await?;
    Ok(())
}