azums 0.1.3

High-performance job queue & streaming engine for Rust — from embedded to cloud
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

//! Job queue core: models, repository, retry logic, and execution runner.
//!
//! This module contains both stable and unstable sub-modules.
//! See [`STABILITY.md`](https://github.com/BlockForge-Dev/azums/blob/main/STABILITY.md)
//! for the full API stability policy.

pub mod attempts;
pub mod enqueue_guard;
pub mod error_codes;
pub mod ingest_decisions;
pub mod model;
pub mod policies;
pub mod policy_decisions;
pub mod repo;
pub mod retry;
pub mod runner;
pub mod stream_repo;

pub use attempts::AttemptsRepo;
pub use model::{Job, JobStatus, NewJob};
pub use policies::{PoliciesRepo, QueuePolicy};
pub use policy_decisions::{PolicyDecisionRow, PolicyDecisionsRepo};
pub use repo::JobsRepo;
pub use stream_repo::StreamRepo;

// ── Unstable modules ──
// These modules may change in minor versions before 1.0.

/// ⚠️ **Unstable API** — This module's interface may change in minor versions before 1.0.
///
/// Job execution timeline reconstruction for audit and debugging.
pub mod timeline;

/// ⚠️ **Unstable API** — This module's interface may change in minor versions before 1.0.
///
/// Debug view for inspecting job state, attempts, and policy decisions.
pub mod debug_view;

/// ⚠️ **Unstable API** — This module's interface may change in minor versions before 1.0.
///
/// Maintenance operations: archival, pruning, and retention management.
pub mod maintenance;
pub use maintenance::{cutoff_days, MaintenanceRepo};

/// ⚠️ **Unstable API** — This module's interface may change in minor versions before 1.0.
///
/// Queue-level metrics aggregation.
pub mod metrics;
pub use metrics::{Metrics, MetricsRepo};