runner_q 0.6.4

Durable activity queue and worker system
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

//! Observability module for queue inspection and monitoring.
//!
//! This module provides:
//! - [`QueueInspector`]: Read-only access to queue state
//! - [`ActivitySnapshot`], [`ActivityEvent`]: Core observability types
//! - [`DeadLetterRecord`]: Dead letter queue records
//! - UI components for web-based monitoring (with `axum-ui` feature)

#[cfg(feature = "postgres")]
pub mod inspector;
mod models;
pub mod ui;

// Re-export models
pub use models::{
    ActivityEvent, ActivityEventType, ActivitySnapshot, DeadLetterRecord, QueueStats,
};

// Re-export inspector (requires a backend feature)
#[cfg(feature = "postgres")]
pub use inspector::QueueInspector;

// Re-export static HTML for custom integrations
pub use ui::CONSOLE_HTML;

// Re-export UI routes (requires axum-ui feature and a backend)
#[cfg(all(feature = "axum-ui", feature = "postgres"))]
pub use ui::{observability_api, runnerq_ui};