Crate axum_tasks

Expand description

§Axum Background Tasks

Production-ready background task system for Axum applications.

§Quick Start

use axum::{Router, routing::post};
use axum_background_tasks::{AppTasks, Task, TaskResult, admin_routes, HasTasks};
use serde::{Serialize, Deserialize};

#[derive(Task, Serialize, Deserialize)]
#[task(description = "Processing data", retry = true)]
struct DataProcessing {
    data_id: String,
}

impl DataProcessing {
    pub async fn execute(&self) -> TaskResult {
        // Your task logic here
        TaskResult::Success("autosave data".to_string())
    }
}

#[derive(HasTasks)]
struct AppState {
    tasks: AppTasks,
}

#[tokio::main]
async fn main() {
    let app_state = AppState {
        tasks: AppTasks::new(),
    };
     
    let app = Router::new()
        .route("/process", post(process_handler))
        .nest("/admin", admin_routes::<AppState>())
        .with_state(app_state);
         
    // Start workers and server
}