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
52
53
54
55
56
57
58
59
60
61
62
63
64
65

/// Example 11: Unique Jobs - Deduplication by Key
///
/// Demonstrates using unique_key to prevent duplicate jobs.
use flashq::{FlashQ, PushOptions};

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

    // Push with unique key
    let id1 = client
        .push(
            "unique-demo",
            serde_json::json!({"email": "user@example.com"}),
            Some(PushOptions {
                unique_key: Some("email:user@example.com".to_string()),
                ..Default::default()
            }),
        )
        .await?;
    println!("First push: job {id1}");

    // Push again with same unique key - should be deduplicated
    let result = client
        .push(
            "unique-demo",
            serde_json::json!({"email": "user@example.com"}),
            Some(PushOptions {
                unique_key: Some("email:user@example.com".to_string()),
                ..Default::default()
            }),
        )
        .await;

    match result {
        Ok(id2) => println!("Second push: job {id2} (same ID means deduplicated)"),
        Err(e) => println!("Second push rejected (duplicate): {e}"),
    }

    // Push with custom job ID for idempotency
    let id3 = client
        .push(
            "unique-demo",
            serde_json::json!({"order": "ORD-123"}),
            Some(PushOptions {
                job_id: Some("order-123".to_string()),
                ..Default::default()
            }),
        )
        .await?;
    println!("Custom ID push: job {id3}");

    // Lookup by custom ID
    let found = client.get_job_by_custom_id("order-123").await?;
    if let Some(jws) = found {
        println!(
            "Found by custom ID: job {} state={:?}",
            jws.job.id, jws.state
        );
    }

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