chainmq 1.1.2

A Redis-backed, type-safe job queue for Rust. Provides job registration and execution, delayed jobs, retries with backoff, and scalable workers.
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

//! Standalone Web UI process (same server as `chainmq::start_web_ui`).
//!
//! By default the dashboard requires sign-in (see [`WebUIConfig::default`] in the library: username
//! and password **`ChainMQ`**). Override credentials in code, for example:
//!
//! ```ignore
//! WebUIConfig {
//!     auth: Some(WebUIAuth {
//!         username: "admin".into(),
//!         password: std::env::var("DASHBOARD_PASSWORD").expect("DASHBOARD_PASSWORD"),
//!     }),
//!     ..WebUIConfig::default()
//! }
//! ```
//!
//! Environment:
//! - `REDIS_URL` — Redis connection (default `redis://127.0.0.1:6370` to match other examples)
//! - Optional: set `auth: None` on [`WebUIConfig`] if you want no login (not recommended for exposed hosts).

use chainmq::{Queue, QueueOptions, RedisClient, WebUIConfig, start_web_ui};

#[tokio::main]
async fn main() -> std::io::Result<()> {
    tracing_subscriber::fmt::try_init().ok();

    let redis_url =
        std::env::var("REDIS_URL").unwrap_or_else(|_| "redis://127.0.0.1:6370".to_string());

    println!("Connecting to Redis at: {}", redis_url);

    let queue = Queue::new(QueueOptions {
        redis: RedisClient::Url(redis_url),
        ..Default::default()
    })
    .await
    .expect("Failed to create queue");

    let config = WebUIConfig {
        port: 8080,
        ..Default::default()
    };

    println!(
        "Starting ChainMQ Web UI on http://127.0.0.1:{} (sign in with default ChainMQ / ChainMQ unless you changed WebUIConfig.auth)",
        config.port
    );

    start_web_ui(queue, config).await?.await
}