qrush 0.6.0

Lightweight Job Queue and Task Scheduler for Rust (Actix + Redis + Cron)
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

// src/routes/metrics_route.rs

use actix_web::{web, HttpResponse};
use crate::services::{
    metrics_service::{
        render_metrics,
        render_delayed_jobs,
        render_metrics_for_queue,
        render_dead_jobs,
        render_scheduled_jobs,
        job_action,
        export_queue_csv,
        get_metrics_summary,
        render_failed_jobs,
        render_retry_jobs,
    },
    cron_service::{
        render_cron_jobs,
        cron_action
    },
    basic_auth_service::{
        BasicAuthMiddleware,
    },
};

pub fn qrush_metrics_routes(cfg: &mut web::ServiceConfig) {
    cfg.service(
        web::scope("metrics")
            .wrap(BasicAuthMiddleware)
            .route("/health", web::get().to(|| async {
                HttpResponse::Ok().body("healthy")
            }))
            .route("", web::get().to(render_metrics))
            .route("/queues/{queue}", web::get().to(render_metrics_for_queue))
            .route("/extras/dead", web::get().to(render_dead_jobs))
            .route("/extras/delayed", web::get().to(render_delayed_jobs))
            .route("/extras/scheduled", web::get().to(render_scheduled_jobs))
            .route("/queues/{queue}/export", web::get().to(export_queue_csv))
            .route("/extras/summary", web::get().to(get_metrics_summary))
            .route("/jobs/action", web::post().to(job_action))
            .route("/extras/cron", web::get().to(render_cron_jobs))
            .route("/cron/action", web::post().to(cron_action))
            .route("/extras/failed", web::get().to(render_failed_jobs))
            .route("/extras/retry", web::get().to(render_retry_jobs))
    );
}