conductor_rust 0.1.0-alpha.0

A library for building Conductor workers with Rust
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

use std::collections::HashMap;

use serde::{ Deserialize, Serialize };
use serde_json::Value;

use crate::common::{ task::task_metadata::TaskDef, enums::WorkflowTaskTypeEnum };

#[derive(Serialize, Deserialize, Default, Debug)]
pub struct WorkflowTask {
    #[serde(rename = "type")]
    pub workflow_task_type: Option<WorkflowTaskTypeEnum>,
    #[serde(rename = "asyncComplete")]
    pub async_complete: Option<bool>,
    #[serde(rename = "caseExpression")]
    pub case_expression: Option<String>,
    #[serde(rename = "caseValueParam")]
    pub case_value_param: Option<String>,
    #[serde(rename = "decisionCases")]
    pub decision_cases: Option<HashMap<String, Option<Vec<Option<Value>>>>>,
    #[serde(rename = "defaultCase")]
    pub default_case: Option<Vec<Option<Value>>>,
    #[serde(rename = "defaultExclusiveJoinTask")]
    pub default_exclusive_join_task: Option<Vec<Option<String>>>,
    #[serde(rename = "description")]
    pub description: Option<String>,
    #[serde(rename = "dynamicForkJoinTasksParam")]
    pub dynamic_fork_join_tasks_param: Option<String>,
    #[serde(rename = "dynamicForkTasksInputParamName")]
    pub dynamic_fork_tasks_input_param_name: Option<String>,
    #[serde(rename = "dynamicForkTasksParam")]
    pub dynamic_fork_tasks_param: Option<String>,
    #[serde(rename = "dynamicTaskNameParam")]
    pub dynamic_task_name_param: Option<String>,
    #[serde(rename = "evaluatorType")]
    pub evaluator_type: Option<String>,
    #[serde(rename = "expression")]
    pub expression: Option<String>,
    #[serde(rename = "forkTasks")]
    pub fork_tasks: Option<Vec<Vec<Option<Value>>>>,
    #[serde(rename = "inputParameters")]
    pub input_parameters: HashMap<String, Option<Value>>,
    #[serde(rename = "joinOn")]
    pub join_on: Option<Vec<Option<String>>>,
    #[serde(rename = "loopCondition")]
    pub loop_condition: Option<String>,
    #[serde(rename = "loopOver")]
    pub loop_over: Option<Vec<Option<Value>>>,
    #[serde(rename = "name")]
    pub name: String,
    #[serde(rename = "optional")]
    pub optional: Option<bool>,
    #[serde(rename = "rateLimited")]
    pub rate_limited: Option<bool>,
    #[serde(rename = "retryCount")]
    pub retry_count: Option<i32>,
    #[serde(rename = "scriptExpression")]
    pub script_expression: Option<String>,
    #[serde(rename = "sink")]
    pub sink: Option<String>,
    #[serde(rename = "startDelay")]
    pub start_delay: Option<i32>,
    #[serde(rename = "subWorkflowParam")]
    pub sub_workflow_param: Option<Value>,
    #[serde(rename = "taskDefinition")]
    pub task_definition: Option<TaskDef>,
    #[serde(rename = "taskReferenceName")]
    pub task_reference_name: String,
}