flowbuilder-yaml 0.1.0

YAML/JSON dynamic flow loading for FlowBuilder
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126

use serde::{Deserialize, Serialize};
use std::collections::HashMap;

/// 完整的工作流配置结构
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct WorkflowConfig {
    pub workflow: Workflow,
}

/// 工作流定义
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Workflow {
    pub version: String,
    #[serde(default)]
    pub env: HashMap<String, String>,
    #[serde(default)]
    pub vars: HashMap<String, serde_yaml::Value>,
    #[serde(default)]
    pub template: Option<Template>,
    pub tasks: Vec<Task>,
}

/// 模板定义
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Template {
    pub id: String,
    pub name: String,
    pub version: String,
    pub description: String,
}

/// 任务定义
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Task {
    pub task: TaskDefinition,
}

/// 任务定义详情
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct TaskDefinition {
    pub id: String,
    pub name: String,
    pub description: String,
    #[serde(default)]
    pub actions: Vec<Action>,
}

/// 动作定义
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Action {
    pub action: ActionDefinition,
}

/// 动作定义详情
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ActionDefinition {
    pub id: String,
    pub name: String,
    pub description: String,
    #[serde(default)]
    pub flow: FlowControl,
    #[serde(default)]
    pub outputs: HashMap<String, serde_yaml::Value>,
    #[serde(rename = "type")]
    pub action_type: ActionType,
    #[serde(default)]
    pub parameters: HashMap<String, Parameter>,
}

/// 流程控制
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
pub struct FlowControl {
    #[serde(default)]
    pub next: Option<String>,
    #[serde(default)]
    pub next_if: Option<String>,
    #[serde(default)]
    pub while_util: Option<WhileUtil>,
    #[serde(default)]
    pub retry: Option<RetryConfig>,
    #[serde(default)]
    pub timeout: Option<TimeoutConfig>,
    #[serde(default)]
    pub on_error: Option<String>,
    #[serde(default)]
    pub on_timeout: Option<String>,
}

/// 循环控制
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct WhileUtil {
    pub condition: String,
    pub max_iterations: u32,
}

/// 重试配置
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RetryConfig {
    pub max_retries: u32,
    pub delay: u64, // milliseconds
}

/// 超时配置
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct TimeoutConfig {
    pub duration: u64, // milliseconds
}

/// 动作类型
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
#[serde(rename_all = "lowercase")]
pub enum ActionType {
    Cmd,
    Http,
    #[default]
    Builtin,
    Wasm,
}

/// 参数定义
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Parameter {
    pub value: serde_yaml::Value,
    #[serde(default)]
    pub required: bool,
}