nominal_api_conjure/conjure/objects/scout/compute/api/
variable_value.rs1use conjure_object::serde::{ser, de};
2use conjure_object::serde::ser::SerializeMap as SerializeMap_;
3use conjure_object::private::{UnionField_, UnionTypeField_};
4use std::fmt;
5#[derive(Debug, Clone, conjure_object::private::DeriveWith)]
6#[derive_with(PartialEq, Eq, PartialOrd, Ord, Hash)]
7pub enum VariableValue {
8 Double(#[derive_with(with = conjure_object::private::DoubleWrapper)] f64),
9 ComputeNode(super::ComputeNodeWithContext),
10 Duration(super::super::super::run::api::Duration),
11 Integer(i32),
12 #[deprecated(note = "use series instead.")]
13 Channel(Box<super::ChannelSeries>),
14 Derived(Box<super::DerivedSeries>),
15 Series(super::SeriesVariable),
16 String(String),
17 StringSet(std::collections::BTreeSet<String>),
18 Timestamp(super::super::super::super::api::Timestamp),
19 Unknown(Unknown),
21}
22impl ser::Serialize for VariableValue {
23 fn serialize<S>(&self, s: S) -> Result<S::Ok, S::Error>
24 where
25 S: ser::Serializer,
26 {
27 let mut map = s.serialize_map(Some(2))?;
28 match self {
29 VariableValue::Double(value) => {
30 map.serialize_entry(&"type", &"double")?;
31 map.serialize_entry(&"double", value)?;
32 }
33 VariableValue::ComputeNode(value) => {
34 map.serialize_entry(&"type", &"computeNode")?;
35 map.serialize_entry(&"computeNode", value)?;
36 }
37 VariableValue::Duration(value) => {
38 map.serialize_entry(&"type", &"duration")?;
39 map.serialize_entry(&"duration", value)?;
40 }
41 VariableValue::Integer(value) => {
42 map.serialize_entry(&"type", &"integer")?;
43 map.serialize_entry(&"integer", value)?;
44 }
45 #[allow(deprecated)]
46 VariableValue::Channel(value) => {
47 map.serialize_entry(&"type", &"channel")?;
48 map.serialize_entry(&"channel", value)?;
49 }
50 VariableValue::Derived(value) => {
51 map.serialize_entry(&"type", &"derived")?;
52 map.serialize_entry(&"derived", value)?;
53 }
54 VariableValue::Series(value) => {
55 map.serialize_entry(&"type", &"series")?;
56 map.serialize_entry(&"series", value)?;
57 }
58 VariableValue::String(value) => {
59 map.serialize_entry(&"type", &"string")?;
60 map.serialize_entry(&"string", value)?;
61 }
62 VariableValue::StringSet(value) => {
63 map.serialize_entry(&"type", &"stringSet")?;
64 map.serialize_entry(&"stringSet", value)?;
65 }
66 VariableValue::Timestamp(value) => {
67 map.serialize_entry(&"type", &"timestamp")?;
68 map.serialize_entry(&"timestamp", value)?;
69 }
70 VariableValue::Unknown(value) => {
71 map.serialize_entry(&"type", &value.type_)?;
72 map.serialize_entry(&value.type_, &value.value)?;
73 }
74 }
75 map.end()
76 }
77}
78impl<'de> de::Deserialize<'de> for VariableValue {
79 fn deserialize<D>(d: D) -> Result<VariableValue, D::Error>
80 where
81 D: de::Deserializer<'de>,
82 {
83 d.deserialize_map(Visitor_)
84 }
85}
86struct Visitor_;
87impl<'de> de::Visitor<'de> for Visitor_ {
88 type Value = VariableValue;
89 fn expecting(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
90 fmt.write_str("union VariableValue")
91 }
92 fn visit_map<A>(self, mut map: A) -> Result<VariableValue, A::Error>
93 where
94 A: de::MapAccess<'de>,
95 {
96 let v = match map.next_key::<UnionField_<Variant_>>()? {
97 Some(UnionField_::Type) => {
98 let variant = map.next_value()?;
99 let key = map.next_key()?;
100 match (variant, key) {
101 (Variant_::Double, Some(Variant_::Double)) => {
102 let value = map.next_value()?;
103 VariableValue::Double(value)
104 }
105 (Variant_::ComputeNode, Some(Variant_::ComputeNode)) => {
106 let value = map.next_value()?;
107 VariableValue::ComputeNode(value)
108 }
109 (Variant_::Duration, Some(Variant_::Duration)) => {
110 let value = map.next_value()?;
111 VariableValue::Duration(value)
112 }
113 (Variant_::Integer, Some(Variant_::Integer)) => {
114 let value = map.next_value()?;
115 VariableValue::Integer(value)
116 }
117 #[allow(deprecated)]
118 (Variant_::Channel, Some(Variant_::Channel)) => {
119 let value = map.next_value()?;
120 VariableValue::Channel(value)
121 }
122 (Variant_::Derived, Some(Variant_::Derived)) => {
123 let value = map.next_value()?;
124 VariableValue::Derived(value)
125 }
126 (Variant_::Series, Some(Variant_::Series)) => {
127 let value = map.next_value()?;
128 VariableValue::Series(value)
129 }
130 (Variant_::String, Some(Variant_::String)) => {
131 let value = map.next_value()?;
132 VariableValue::String(value)
133 }
134 (Variant_::StringSet, Some(Variant_::StringSet)) => {
135 let value = map.next_value()?;
136 VariableValue::StringSet(value)
137 }
138 (Variant_::Timestamp, Some(Variant_::Timestamp)) => {
139 let value = map.next_value()?;
140 VariableValue::Timestamp(value)
141 }
142 (Variant_::Unknown(type_), Some(Variant_::Unknown(b))) => {
143 if type_ == b {
144 let value = map.next_value()?;
145 VariableValue::Unknown(Unknown { type_, value })
146 } else {
147 return Err(
148 de::Error::invalid_value(de::Unexpected::Str(&type_), &&*b),
149 )
150 }
151 }
152 (variant, Some(key)) => {
153 return Err(
154 de::Error::invalid_value(
155 de::Unexpected::Str(key.as_str()),
156 &variant.as_str(),
157 ),
158 );
159 }
160 (variant, None) => {
161 return Err(de::Error::missing_field(variant.as_str()));
162 }
163 }
164 }
165 Some(UnionField_::Value(variant)) => {
166 let value = match &variant {
167 Variant_::Double => {
168 let value = map.next_value()?;
169 VariableValue::Double(value)
170 }
171 Variant_::ComputeNode => {
172 let value = map.next_value()?;
173 VariableValue::ComputeNode(value)
174 }
175 Variant_::Duration => {
176 let value = map.next_value()?;
177 VariableValue::Duration(value)
178 }
179 Variant_::Integer => {
180 let value = map.next_value()?;
181 VariableValue::Integer(value)
182 }
183 Variant_::Channel => {
184 let value = map.next_value()?;
185 #[allow(deprecated)] VariableValue::Channel(value)
186 }
187 Variant_::Derived => {
188 let value = map.next_value()?;
189 VariableValue::Derived(value)
190 }
191 Variant_::Series => {
192 let value = map.next_value()?;
193 VariableValue::Series(value)
194 }
195 Variant_::String => {
196 let value = map.next_value()?;
197 VariableValue::String(value)
198 }
199 Variant_::StringSet => {
200 let value = map.next_value()?;
201 VariableValue::StringSet(value)
202 }
203 Variant_::Timestamp => {
204 let value = map.next_value()?;
205 VariableValue::Timestamp(value)
206 }
207 Variant_::Unknown(type_) => {
208 let value = map.next_value()?;
209 VariableValue::Unknown(Unknown {
210 type_: type_.clone(),
211 value,
212 })
213 }
214 };
215 if map.next_key::<UnionTypeField_>()?.is_none() {
216 return Err(de::Error::missing_field("type"));
217 }
218 let type_variant = map.next_value::<Variant_>()?;
219 if variant != type_variant {
220 return Err(
221 de::Error::invalid_value(
222 de::Unexpected::Str(type_variant.as_str()),
223 &variant.as_str(),
224 ),
225 );
226 }
227 value
228 }
229 None => return Err(de::Error::missing_field("type")),
230 };
231 if map.next_key::<UnionField_<Variant_>>()?.is_some() {
232 return Err(de::Error::invalid_length(3, &"type and value fields"));
233 }
234 Ok(v)
235 }
236}
237#[derive(PartialEq)]
238enum Variant_ {
239 Double,
240 ComputeNode,
241 Duration,
242 Integer,
243 Channel,
244 Derived,
245 Series,
246 String,
247 StringSet,
248 Timestamp,
249 Unknown(Box<str>),
250}
251impl Variant_ {
252 fn as_str(&self) -> &'static str {
253 match *self {
254 Variant_::Double => "double",
255 Variant_::ComputeNode => "computeNode",
256 Variant_::Duration => "duration",
257 Variant_::Integer => "integer",
258 Variant_::Channel => "channel",
259 Variant_::Derived => "derived",
260 Variant_::Series => "series",
261 Variant_::String => "string",
262 Variant_::StringSet => "stringSet",
263 Variant_::Timestamp => "timestamp",
264 Variant_::Unknown(_) => "unknown variant",
265 }
266 }
267}
268impl<'de> de::Deserialize<'de> for Variant_ {
269 fn deserialize<D>(d: D) -> Result<Variant_, D::Error>
270 where
271 D: de::Deserializer<'de>,
272 {
273 d.deserialize_str(VariantVisitor_)
274 }
275}
276struct VariantVisitor_;
277impl<'de> de::Visitor<'de> for VariantVisitor_ {
278 type Value = Variant_;
279 fn expecting(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
280 fmt.write_str("string")
281 }
282 fn visit_str<E>(self, value: &str) -> Result<Variant_, E>
283 where
284 E: de::Error,
285 {
286 let v = match value {
287 "double" => Variant_::Double,
288 "computeNode" => Variant_::ComputeNode,
289 "duration" => Variant_::Duration,
290 "integer" => Variant_::Integer,
291 "channel" => Variant_::Channel,
292 "derived" => Variant_::Derived,
293 "series" => Variant_::Series,
294 "string" => Variant_::String,
295 "stringSet" => Variant_::StringSet,
296 "timestamp" => Variant_::Timestamp,
297 value => Variant_::Unknown(value.to_string().into_boxed_str()),
298 };
299 Ok(v)
300 }
301}
302#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
304pub struct Unknown {
305 type_: Box<str>,
306 value: conjure_object::Any,
307}
308impl Unknown {
309 #[inline]
311 pub fn type_(&self) -> &str {
312 &self.type_
313 }
314}