windmill_api/models/
forloop_flow.rs1use crate::models;
12use serde::{Deserialize, Serialize};
13
14#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
15pub struct ForloopFlow {
16 #[serde(rename = "modules")]
17 pub modules: Vec<models::FlowModule>,
18 #[serde(rename = "iterator")]
19 pub iterator: Box<models::InputTransform>,
20 #[serde(rename = "skip_failures")]
21 pub skip_failures: bool,
22 #[serde(rename = "type")]
23 pub r#type: Type,
24 #[serde(rename = "parallel", skip_serializing_if = "Option::is_none")]
25 pub parallel: Option<bool>,
26 #[serde(rename = "parallelism", skip_serializing_if = "Option::is_none")]
27 pub parallelism: Option<i32>,
28}
29
30impl ForloopFlow {
31 pub fn new(modules: Vec<models::FlowModule>, iterator: models::InputTransform, skip_failures: bool, r#type: Type) -> ForloopFlow {
32 ForloopFlow {
33 modules,
34 iterator: Box::new(iterator),
35 skip_failures,
36 r#type,
37 parallel: None,
38 parallelism: None,
39 }
40 }
41}
42#[derive(Clone, Copy, Debug, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize)]
44pub enum Type {
45 #[serde(rename = "forloopflow")]
46 Forloopflow,
47}
48
49impl Default for Type {
50 fn default() -> Type {
51 Self::Forloopflow
52 }
53}
54