greentic_flow/
model.rs

1use indexmap::IndexMap;
2use serde::{Deserialize, Serialize};
3use serde_json::Value;
4use std::collections::BTreeMap;
5
6fn default_parameters() -> Value {
7    Value::Object(Default::default())
8}
9
10fn default_entrypoints() -> IndexMap<String, Value> {
11    IndexMap::new()
12}
13
14fn default_routing() -> Value {
15    Value::Array(Vec::new())
16}
17
18#[derive(Debug, Clone, Serialize, Deserialize)]
19pub struct FlowDoc {
20    pub id: String,
21    #[serde(default, skip_serializing_if = "Option::is_none")]
22    pub title: Option<String>,
23    #[serde(default, skip_serializing_if = "Option::is_none")]
24    pub description: Option<String>,
25    #[serde(rename = "type")]
26    pub flow_type: String,
27    #[serde(default)]
28    pub start: Option<String>,
29    #[serde(default = "default_parameters")]
30    pub parameters: Value,
31    #[serde(default)]
32    pub tags: Vec<String>,
33    #[serde(default)]
34    pub schema_version: Option<u32>,
35    #[serde(default = "default_entrypoints")]
36    pub entrypoints: IndexMap<String, Value>,
37    pub nodes: IndexMap<String, NodeDoc>,
38}
39
40#[derive(Debug, Clone, Serialize, Deserialize, Default)]
41pub struct NodeDoc {
42    #[serde(default = "default_routing")]
43    pub routing: Value,
44    #[serde(default, skip_serializing_if = "Option::is_none")]
45    pub telemetry: Option<TelemetryDoc>,
46    #[serde(skip_serializing, skip_deserializing, default)]
47    pub operation: Option<String>,
48    #[serde(skip_serializing, skip_deserializing, default)]
49    pub payload: Value,
50    #[serde(flatten, default)]
51    pub raw: IndexMap<String, Value>,
52}
53
54#[derive(Debug, Clone, Serialize, Deserialize, Default)]
55pub struct TelemetryDoc {
56    #[serde(default)]
57    pub span_name: Option<String>,
58    #[serde(default)]
59    pub attributes: BTreeMap<String, String>,
60    #[serde(default)]
61    pub sampling: Option<String>,
62}
greentic_flow/model.rs

greentic_flow/
model.rs
