rustqueue 0.2.0

Background jobs without infrastructure — embeddable job queue with zero external dependencies
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119

//! Queue-related HTTP endpoints.

use std::sync::Arc;

use axum::Json;
use axum::Router;
use axum::extract::{Path, State};
use axum::routing::{get, post};
use serde::Serialize;
use utoipa::ToSchema;

use crate::api::{ApiError, AppState};
use crate::engine::models::QueueCounts;
use crate::engine::queue::QueueInfo;

// ── Response types ──────────────────────────────────────────────────────────

#[derive(Debug, Serialize, ToSchema)]
pub struct ListQueuesResponse {
    pub ok: bool,
    pub queues: Vec<QueueInfo>,
}

#[derive(Debug, Serialize, ToSchema)]
pub struct QueueStatsResponse {
    pub ok: bool,
    pub counts: QueueCounts,
}

#[derive(Debug, Serialize, ToSchema)]
pub struct OkResponse {
    pub ok: bool,
}

// ── Routes ──────────────────────────────────────────────────────────────────

pub fn routes() -> Router<Arc<AppState>> {
    Router::new()
        .route("/api/v1/queues", get(list_queues))
        .route("/api/v1/queues/{queue}/stats", get(queue_stats))
        .route("/api/v1/queues/{queue}/pause", post(pause_queue))
        .route("/api/v1/queues/{queue}/resume", post(resume_queue))
}

// ── Handlers ────────────────────────────────────────────────────────────────

/// GET /api/v1/queues — List all queues with counts.
#[utoipa::path(
    get,
    path = "/api/v1/queues",
    tag = "Queues",
    responses(
        (status = 200, description = "List of all queues", body = ListQueuesResponse),
        (status = 401, description = "Unauthorized"),
    )
)]
async fn list_queues(
    State(state): State<Arc<AppState>>,
) -> Result<Json<ListQueuesResponse>, ApiError> {
    let queues = state.queue_manager.list_queues().await?;
    Ok(Json(ListQueuesResponse { ok: true, queues }))
}

/// GET /api/v1/queues/:queue/stats — Get queue statistics.
#[utoipa::path(
    get,
    path = "/api/v1/queues/{queue}/stats",
    tag = "Queues",
    params(("queue" = String, Path, description = "Queue name")),
    responses(
        (status = 200, description = "Queue statistics", body = QueueStatsResponse),
        (status = 401, description = "Unauthorized"),
    )
)]
async fn queue_stats(
    State(state): State<Arc<AppState>>,
    Path(queue): Path<String>,
) -> Result<Json<QueueStatsResponse>, ApiError> {
    let counts = state.queue_manager.get_queue_stats(&queue).await?;
    Ok(Json(QueueStatsResponse { ok: true, counts }))
}

/// POST /api/v1/queues/:queue/pause — Pause a queue (reject new pushes).
#[utoipa::path(
    post,
    path = "/api/v1/queues/{queue}/pause",
    tag = "Queues",
    params(("queue" = String, Path, description = "Queue name")),
    responses(
        (status = 200, description = "Queue paused", body = OkResponse),
        (status = 401, description = "Unauthorized"),
    )
)]
async fn pause_queue(
    State(state): State<Arc<AppState>>,
    Path(queue): Path<String>,
) -> Json<OkResponse> {
    state.queue_manager.pause_queue(&queue);
    Json(OkResponse { ok: true })
}

/// POST /api/v1/queues/:queue/resume — Resume a paused queue.
#[utoipa::path(
    post,
    path = "/api/v1/queues/{queue}/resume",
    tag = "Queues",
    params(("queue" = String, Path, description = "Queue name")),
    responses(
        (status = 200, description = "Queue resumed", body = OkResponse),
        (status = 401, description = "Unauthorized"),
    )
)]
async fn resume_queue(
    State(state): State<Arc<AppState>>,
    Path(queue): Path<String>,
) -> Json<OkResponse> {
    state.queue_manager.resume_queue(&queue);
    Json(OkResponse { ok: true })
}