alpha-core-framework 2.4.0

High-performance modular Rust framework for async task orchestration and data pipelines.
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

use std::sync::Arc;
use tokio::sync::RwLock;

/// Core Orchestrator for AlphaCore Framework
pub struct Orchestrator {
    pub name: String,
    pub tasks: Arc<RwLock<Vec<String>>>,
}

impl Orchestrator {
    pub fn new(name: &str) -> Self {
        Self {
            name: name.to_string(),
            tasks: Arc::new(RwLock::new(Vec::new())),
        }
    }

    pub async fn add_task(&self, task_name: &str) {
        let mut tasks = self.tasks.write().await;
        tasks.push(task_name.to_string());
        println!("Task '{}' added to pipeline '{}'", task_name, self.name);
    }

    pub async fn run(&self) {
        let tasks = self.tasks.read().await;
        println!("Starting execution of {} tasks...", tasks.len());
        for task in tasks.iter() {
            println!("Running: {}", task);
        }
    }
}