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

/// Example 15: Queue Control - Pause, Resume, Drain, Obliterate
///
/// Demonstrates queue lifecycle management.
use flashq::FlashQ;

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

    // Push some jobs
    for i in 0..5 {
        client
            .push("control-demo", serde_json::json!({"i": i}), None)
            .await?;
    }
    println!("Pushed 5 jobs");

    // Pause queue
    client.pause("control-demo").await?;
    let paused = client.is_paused("control-demo").await?;
    println!("Queue paused: {paused}");

    // Resume queue
    client.resume("control-demo").await?;
    let paused = client.is_paused("control-demo").await?;
    println!("Queue paused after resume: {paused}");

    // List queues
    let queues = client.list_queues().await?;
    println!("\nAll queues:");
    for q in &queues {
        println!(
            "  {} - pending={} processing={} paused={}",
            q.name, q.pending, q.processing, q.paused
        );
    }

    // Drain waiting jobs
    let drained = client.drain("control-demo").await?;
    println!("\nDrained {drained} jobs");

    // Push more and obliterate
    client
        .push("control-demo", serde_json::json!({"temp": true}), None)
        .await?;
    client.obliterate("control-demo").await?;
    println!("Queue obliterated");

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