VEX Queue

Async background worker queue for robust job processing.

Features:

• Generic Job trait
• Pluggable backend (Memory, SQL, Redis)
• Worker pool with concurrency control
• Retry with exponential backoff

vex-queue

Async background worker queue for the VEX Protocol.

Features

• In-Memory Backend - Development and testing
• Persistent Backend - Production job durability
• Worker Pools - Scalable job processing
• Job Scheduling - Delayed and recurring jobs

Installation

[dependencies]
vex-queue = "0.1"

Quick Start

use vex_queue::{Queue, Job, Worker};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let queue = Queue::new_memory();
    
    // Enqueue a job
    queue.enqueue(Job::new("process_data", payload)).await?;
    
    // Start workers
    let worker = Worker::new(queue.clone());
    worker.run().await?;
    
    Ok(())
}

License

Apache-2.0 License - see LICENSE for details.