night 0.0.5

A scalable Task Queue for executing asynchronous tasks in topological order.
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

pub mod common;
pub mod config;
pub mod mission;
pub mod task;
pub mod utils;

pub use config::config::ConfigManager;
pub use mission::mission::Mission;
pub use utils::error::{NightError, Result};

/// Initialize the Night system with a configuration file.
pub async fn init(config_path: &str) -> Result<Mission> {
    let config = ConfigManager::load_config(config_path)?;
    Mission::new(config).await
}

/// Start the mission execution.
pub async fn run(mission: &Mission) -> Result<()> {
    mission.start().await
}

/// Stop a specific task in the mission.
pub async fn stop_task(mission: &Mission, task_id: uuid::Uuid) -> Result<()> {
    mission.stop_task(task_id).await
}

/// Get information about all tasks in the mission.
pub async fn get_all_task_info(
    mission: &Mission,
) -> std::collections::HashMap<uuid::Uuid, common::types::TaskInfo> {
    mission.get_all_task_info().await
}

/// Get information about a specific task in the mission.
pub async fn get_task_info(
    mission: &Mission,
    task_id: uuid::Uuid,
) -> Result<common::types::TaskInfo> {
    mission.get_task_info(task_id).await
}