taskflow-rs 0.1.1

A high-performance, async-first task orchestration framework for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use serde::{Deserialize, Serialize};
use uuid::Uuid;

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ExecutorConfig {
    pub worker_id: String,
    pub max_concurrent_tasks: usize,
    pub task_timeout_seconds: u64,
    pub heartbeat_interval_seconds: u64,
}

impl Default for ExecutorConfig {
    fn default() -> Self {
        Self {
            worker_id: format!("worker-{}", Uuid::new_v4()),
            max_concurrent_tasks: 10,
            task_timeout_seconds: 300,
            heartbeat_interval_seconds: 30,
        }
    }
}