Struct TaskQueue

pub struct TaskQueue {
    pub broker: Arc<RedisBroker>,
    pub scheduler: Arc<TaskScheduler>,
    pub autoscaler: Arc<AutoScaler>,
    pub metrics: Arc<MetricsCollector>,
    /* private fields */
}

Main task queue framework

Fields

broker: Arc<RedisBroker>

scheduler: Arc<TaskScheduler>

autoscaler: Arc<AutoScaler>

metrics: Arc<MetricsCollector>

Implementations

impl TaskQueue

pub async fn new(redis_url: &str) -> Result<Self, TaskQueueError>

Create a new task queue instance

pub async fn with_autoscaler_config( redis_url: &str, autoscaler_config: AutoScalerConfig, ) -> Result<Self, TaskQueueError>

Create a new task queue with custom auto-scaler configuration

pub async fn start_workers( &self, initial_count: usize, ) -> Result<(), TaskQueueError>

Start the specified number of workers with auto-registered tasks (if available)

pub async fn start_workers_with_registry( &self, initial_count: usize, task_registry: Arc<TaskRegistry>, ) -> Result<(), TaskQueueError>

Start workers with a custom task registry

pub fn start_autoscaler(&self) -> Result<(), TaskQueueError>

Start the auto-scaler background process

pub async fn start_scheduler(&self) -> Result<(), TaskQueueError>

Start the task scheduler background process

pub async fn stop_scheduler(&self)

Stop the task scheduler

pub async fn enqueue<T: Task>( &self, task: T, queue: &str, ) -> Result<TaskId, TaskQueueError>

Enqueue a task for immediate execution

pub async fn schedule<T: Task>( &self, task: T, queue: &str, delay: Duration, ) -> Result<TaskId, TaskQueueError>

Schedule a task for delayed execution

pub async fn worker_count(&self) -> usize

Get the current number of active workers

pub async fn stop_workers(&self)

Stop all workers

pub async fn shutdown(&self) -> Result<(), TaskQueueError>

Initiate graceful shutdown of the entire task queue

pub async fn shutdown_with_timeout( &self, timeout: Duration, ) -> Result<(), TaskQueueError>

Shutdown with a custom timeout

pub async fn is_shutting_down(&self) -> bool

Check if shutdown has been initiated

pub async fn shutdown_receiver(&self) -> Option<Receiver<()>>

Get a shutdown signal receiver for external components

pub async fn health_check(&self) -> Result<HealthStatus, TaskQueueError>

Get comprehensive health status

pub async fn get_metrics(&self) -> Result<TaskQueueMetrics, TaskQueueError>

Get comprehensive metrics

pub async fn get_system_metrics(&self) -> SystemMetrics

Get enhanced system metrics with memory and performance data

pub async fn get_metrics_summary(&self) -> String

Get a quick metrics summary for debugging

Trait Implementations

impl Clone for TaskQueue

fn clone(&self) -> TaskQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.