rust-task-queue 0.1.5

Production-ready Redis task queue with intelligent auto-scaling, Actix Web integration, and enterprise-grade observability for high-performance async Rust applications.
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

//! Convenience re-exports for common types and traits
//!
//! This module contains the most commonly used items from the rust-task-queue crate.
//! Users can import everything they need with `use rust_task_queue::prelude::*;`

// Core types and traits
pub use crate::{
    AutoScaler, AutoScalerConfig, QueueManager, QueueMetrics, RedisBroker, ScalingAction, Task,
    TaskId, TaskMetadata, TaskPriority, TaskQueue, TaskQueueBuilder, TaskQueueError, TaskRegistry,
    TaskResult, TaskScheduler, TaskWrapper, Worker,
};

// Configuration types
pub use crate::{AutoRegisterConfig, ConfigBuilder, RedisConfig, SchedulerConfig, TaskQueueConfig};

// Actix Web configuration (when feature is enabled)
#[cfg(feature = "actix-integration")]
pub use crate::ActixConfig;

#[cfg(feature = "actix-integration")]
pub use crate::actix::{
    auto_configure_task_queue, configure_task_queue_routes, configure_task_queue_routes_auto,
    create_auto_registered_task_queue, create_task_queue_from_config,
};

// Async trait for Task implementations
pub use async_trait::async_trait;

// MessagePack serialization (replaces JSON)
pub use rmp_serde;

// Common traits for serialization
pub use serde::{Deserialize, Serialize};

// Automatic task registration (when feature is enabled)
#[cfg(feature = "auto-register")]
#[cfg_attr(docsrs, doc(cfg(feature = "auto-register")))]
pub use crate::{inventory, proc_register_task as register_task, AutoRegisterTask};

// Manual task registration macros (always available)
pub use crate::{manual_register_task, register_task_with_name, register_tasks};

// Date/time handling for scheduling
pub use chrono::{DateTime, Duration, Utc};

// UUID handling for task IDs
pub use uuid::Uuid;

#[cfg(feature = "tracing")]
pub use crate::tracing_utils::{
    trace_queue_operation, trace_task_error, trace_task_lifecycle_event, trace_worker_operation,
    PerformanceTracker, QueuePerformanceMetrics, TaskLifecycleEvent, TaskPerformanceMetrics,
    WorkerPerformanceMetrics,
};

#[cfg(feature = "config")]
pub use crate::config::*;