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<Box<models::InputTransform>>,
28 #[serde(rename = "squash", skip_serializing_if = "Option::is_none")]
29 pub squash: Option<bool>,
30}
31
32impl ForloopFlow {
33 pub fn new(modules: Vec<models::FlowModule>, iterator: models::InputTransform, skip_failures: bool, r#type: Type) -> ForloopFlow {
34 ForloopFlow {
35 modules,
36 iterator: Box::new(iterator),
37 skip_failures,
38 r#type,
39 parallel: None,
40 parallelism: None,
41 squash: None,
42 }
43 }
44}
45#[derive(Clone, Copy, Debug, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize)]
47pub enum Type {
48 #[serde(rename = "forloopflow")]
49 Forloopflow,
50}
51
52impl Default for Type {
53 fn default() -> Type {
54 Self::Forloopflow
55 }
56}
57