nebula_fbthrift_graph_v2/
types.rs

1// @generated by Thrift for src/interface/graph.thrift
2// This file is probably not the place you want to edit!
3
4//! Thrift type definitions for `graph`.
5
6#![allow(clippy::redundant_closure)]
7
8
9#[derive(Clone, PartialEq)]
10pub struct ProfilingStats {
11    pub rows: ::std::primitive::i64,
12    pub exec_duration_in_us: ::std::primitive::i64,
13    pub total_duration_in_us: ::std::primitive::i64,
14    pub other_stats: ::std::option::Option<::std::collections::BTreeMap<::std::vec::Vec<::std::primitive::u8>, ::std::vec::Vec<::std::primitive::u8>>>,
15    // This field forces `..Default::default()` when instantiating this
16    // struct, to make code future-proof against new fields added later to
17    // the definition in Thrift. If you don't want this, add the annotation
18    // `(rust.exhaustive)` to the Thrift struct to eliminate this field.
19    #[doc(hidden)]
20    pub _dot_dot_Default_default: self::dot_dot::OtherFields,
21}
22
23#[derive(Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
24pub struct PlanNodeBranchInfo {
25    pub is_do_branch: ::std::primitive::bool,
26    pub condition_node_id: ::std::primitive::i64,
27    // This field forces `..Default::default()` when instantiating this
28    // struct, to make code future-proof against new fields added later to
29    // the definition in Thrift. If you don't want this, add the annotation
30    // `(rust.exhaustive)` to the Thrift struct to eliminate this field.
31    #[doc(hidden)]
32    pub _dot_dot_Default_default: self::dot_dot::OtherFields,
33}
34
35#[derive(Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
36pub struct Pair {
37    pub key: ::std::vec::Vec<::std::primitive::u8>,
38    pub value: ::std::vec::Vec<::std::primitive::u8>,
39    // This field forces `..Default::default()` when instantiating this
40    // struct, to make code future-proof against new fields added later to
41    // the definition in Thrift. If you don't want this, add the annotation
42    // `(rust.exhaustive)` to the Thrift struct to eliminate this field.
43    #[doc(hidden)]
44    pub _dot_dot_Default_default: self::dot_dot::OtherFields,
45}
46
47#[derive(Clone, PartialEq)]
48pub struct PlanNodeDescription {
49    pub name: ::std::vec::Vec<::std::primitive::u8>,
50    pub id: ::std::primitive::i64,
51    pub output_var: ::std::vec::Vec<::std::primitive::u8>,
52    pub description: ::std::option::Option<::std::vec::Vec<crate::types::Pair>>,
53    pub profiles: ::std::option::Option<::std::vec::Vec<crate::types::ProfilingStats>>,
54    pub branch_info: ::std::option::Option<crate::types::PlanNodeBranchInfo>,
55    pub dependencies: ::std::option::Option<::std::vec::Vec<::std::primitive::i64>>,
56    // This field forces `..Default::default()` when instantiating this
57    // struct, to make code future-proof against new fields added later to
58    // the definition in Thrift. If you don't want this, add the annotation
59    // `(rust.exhaustive)` to the Thrift struct to eliminate this field.
60    #[doc(hidden)]
61    pub _dot_dot_Default_default: self::dot_dot::OtherFields,
62}
63
64#[derive(Clone, PartialEq)]
65pub struct PlanDescription {
66    pub plan_node_descs: ::std::vec::Vec<crate::types::PlanNodeDescription>,
67    pub node_index_map: ::std::collections::BTreeMap<::std::primitive::i64, ::std::primitive::i64>,
68    pub format: ::std::vec::Vec<::std::primitive::u8>,
69    pub optimize_time_in_us: ::std::primitive::i32,
70    // This field forces `..Default::default()` when instantiating this
71    // struct, to make code future-proof against new fields added later to
72    // the definition in Thrift. If you don't want this, add the annotation
73    // `(rust.exhaustive)` to the Thrift struct to eliminate this field.
74    #[doc(hidden)]
75    pub _dot_dot_Default_default: self::dot_dot::OtherFields,
76}
77
78#[derive(Clone, PartialEq)]
79pub struct ExecutionResponse {
80    pub error_code: common::types::ErrorCode,
81    pub latency_in_us: ::std::primitive::i32,
82    pub data: ::std::option::Option<common::types::DataSet>,
83    pub space_name: ::std::option::Option<::std::vec::Vec<::std::primitive::u8>>,
84    pub error_msg: ::std::option::Option<::std::vec::Vec<::std::primitive::u8>>,
85    pub plan_desc: ::std::option::Option<crate::types::PlanDescription>,
86    pub comment: ::std::option::Option<::std::vec::Vec<::std::primitive::u8>>,
87    // This field forces `..Default::default()` when instantiating this
88    // struct, to make code future-proof against new fields added later to
89    // the definition in Thrift. If you don't want this, add the annotation
90    // `(rust.exhaustive)` to the Thrift struct to eliminate this field.
91    #[doc(hidden)]
92    pub _dot_dot_Default_default: self::dot_dot::OtherFields,
93}
94
95#[derive(Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
96pub struct AuthResponse {
97    pub error_code: common::types::ErrorCode,
98    pub error_msg: ::std::option::Option<::std::vec::Vec<::std::primitive::u8>>,
99    pub session_id: ::std::option::Option<::std::primitive::i64>,
100    pub time_zone_offset_seconds: ::std::option::Option<::std::primitive::i32>,
101    pub time_zone_name: ::std::option::Option<::std::vec::Vec<::std::primitive::u8>>,
102    // This field forces `..Default::default()` when instantiating this
103    // struct, to make code future-proof against new fields added later to
104    // the definition in Thrift. If you don't want this, add the annotation
105    // `(rust.exhaustive)` to the Thrift struct to eliminate this field.
106    #[doc(hidden)]
107    pub _dot_dot_Default_default: self::dot_dot::OtherFields,
108}
109
110#[derive(Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
111pub struct VerifyClientVersionResp {
112    pub error_code: common::types::ErrorCode,
113    pub error_msg: ::std::option::Option<::std::vec::Vec<::std::primitive::u8>>,
114    // This field forces `..Default::default()` when instantiating this
115    // struct, to make code future-proof against new fields added later to
116    // the definition in Thrift. If you don't want this, add the annotation
117    // `(rust.exhaustive)` to the Thrift struct to eliminate this field.
118    #[doc(hidden)]
119    pub _dot_dot_Default_default: self::dot_dot::OtherFields,
120}
121
122#[derive(Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
123pub struct VerifyClientVersionReq {
124    pub version: ::std::vec::Vec<::std::primitive::u8>,
125    // This field forces `..Default::default()` when instantiating this
126    // struct, to make code future-proof against new fields added later to
127    // the definition in Thrift. If you don't want this, add the annotation
128    // `(rust.exhaustive)` to the Thrift struct to eliminate this field.
129    #[doc(hidden)]
130    pub _dot_dot_Default_default: self::dot_dot::OtherFields,
131}
132
133#[allow(clippy::derivable_impls)]
134impl ::std::default::Default for self::ProfilingStats {
135    fn default() -> Self {
136        Self {
137            rows: ::std::default::Default::default(),
138            exec_duration_in_us: ::std::default::Default::default(),
139            total_duration_in_us: ::std::default::Default::default(),
140            other_stats: ::std::option::Option::None,
141            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
142        }
143    }
144}
145
146impl ::std::fmt::Debug for self::ProfilingStats {
147    fn fmt(&self, formatter: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
148        formatter
149            .debug_struct("ProfilingStats")
150            .field("rows", &self.rows)
151            .field("exec_duration_in_us", &self.exec_duration_in_us)
152            .field("total_duration_in_us", &self.total_duration_in_us)
153            .field("other_stats", &self.other_stats)
154            .finish()
155    }
156}
157
158unsafe impl ::std::marker::Send for self::ProfilingStats {}
159unsafe impl ::std::marker::Sync for self::ProfilingStats {}
160
161impl ::fbthrift::GetTType for self::ProfilingStats {
162    const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
163}
164
165impl<P> ::fbthrift::Serialize<P> for self::ProfilingStats
166where
167    P: ::fbthrift::ProtocolWriter,
168{
169    fn write(&self, p: &mut P) {
170        p.write_struct_begin("ProfilingStats");
171        p.write_field_begin("rows", ::fbthrift::TType::I64, 1);
172        ::fbthrift::Serialize::write(&self.rows, p);
173        p.write_field_end();
174        p.write_field_begin("exec_duration_in_us", ::fbthrift::TType::I64, 2);
175        ::fbthrift::Serialize::write(&self.exec_duration_in_us, p);
176        p.write_field_end();
177        p.write_field_begin("total_duration_in_us", ::fbthrift::TType::I64, 3);
178        ::fbthrift::Serialize::write(&self.total_duration_in_us, p);
179        p.write_field_end();
180        if let ::std::option::Option::Some(some) = &self.other_stats {
181            p.write_field_begin("other_stats", ::fbthrift::TType::Map, 4);
182            ::fbthrift::Serialize::write(some, p);
183            p.write_field_end();
184        }
185        p.write_field_stop();
186        p.write_struct_end();
187    }
188}
189
190impl<P> ::fbthrift::Deserialize<P> for self::ProfilingStats
191where
192    P: ::fbthrift::ProtocolReader,
193{
194    fn read(p: &mut P) -> ::anyhow::Result<Self> {
195        static FIELDS: &[::fbthrift::Field] = &[
196            ::fbthrift::Field::new("exec_duration_in_us", ::fbthrift::TType::I64, 2),
197            ::fbthrift::Field::new("other_stats", ::fbthrift::TType::Map, 4),
198            ::fbthrift::Field::new("rows", ::fbthrift::TType::I64, 1),
199            ::fbthrift::Field::new("total_duration_in_us", ::fbthrift::TType::I64, 3),
200        ];
201        let mut field_rows = ::std::option::Option::None;
202        let mut field_exec_duration_in_us = ::std::option::Option::None;
203        let mut field_total_duration_in_us = ::std::option::Option::None;
204        let mut field_other_stats = ::std::option::Option::None;
205        let _ = p.read_struct_begin(|_| ())?;
206        loop {
207            let (_, fty, fid) = p.read_field_begin(|_| (), FIELDS)?;
208            match (fty, fid as ::std::primitive::i32) {
209                (::fbthrift::TType::Stop, _) => break,
210                (::fbthrift::TType::I64, 1) => field_rows = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
211                (::fbthrift::TType::I64, 2) => field_exec_duration_in_us = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
212                (::fbthrift::TType::I64, 3) => field_total_duration_in_us = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
213                (::fbthrift::TType::Map, 4) => field_other_stats = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
214                (fty, _) => p.skip(fty)?,
215            }
216            p.read_field_end()?;
217        }
218        p.read_struct_end()?;
219        ::std::result::Result::Ok(Self {
220            rows: field_rows.unwrap_or_default(),
221            exec_duration_in_us: field_exec_duration_in_us.unwrap_or_default(),
222            total_duration_in_us: field_total_duration_in_us.unwrap_or_default(),
223            other_stats: field_other_stats,
224            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
225        })
226    }
227}
228
229
230#[allow(clippy::derivable_impls)]
231impl ::std::default::Default for self::PlanNodeBranchInfo {
232    fn default() -> Self {
233        Self {
234            is_do_branch: ::std::default::Default::default(),
235            condition_node_id: ::std::default::Default::default(),
236            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
237        }
238    }
239}
240
241impl ::std::fmt::Debug for self::PlanNodeBranchInfo {
242    fn fmt(&self, formatter: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
243        formatter
244            .debug_struct("PlanNodeBranchInfo")
245            .field("is_do_branch", &self.is_do_branch)
246            .field("condition_node_id", &self.condition_node_id)
247            .finish()
248    }
249}
250
251unsafe impl ::std::marker::Send for self::PlanNodeBranchInfo {}
252unsafe impl ::std::marker::Sync for self::PlanNodeBranchInfo {}
253
254impl ::fbthrift::GetTType for self::PlanNodeBranchInfo {
255    const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
256}
257
258impl<P> ::fbthrift::Serialize<P> for self::PlanNodeBranchInfo
259where
260    P: ::fbthrift::ProtocolWriter,
261{
262    fn write(&self, p: &mut P) {
263        p.write_struct_begin("PlanNodeBranchInfo");
264        p.write_field_begin("is_do_branch", ::fbthrift::TType::Bool, 1);
265        ::fbthrift::Serialize::write(&self.is_do_branch, p);
266        p.write_field_end();
267        p.write_field_begin("condition_node_id", ::fbthrift::TType::I64, 2);
268        ::fbthrift::Serialize::write(&self.condition_node_id, p);
269        p.write_field_end();
270        p.write_field_stop();
271        p.write_struct_end();
272    }
273}
274
275impl<P> ::fbthrift::Deserialize<P> for self::PlanNodeBranchInfo
276where
277    P: ::fbthrift::ProtocolReader,
278{
279    fn read(p: &mut P) -> ::anyhow::Result<Self> {
280        static FIELDS: &[::fbthrift::Field] = &[
281            ::fbthrift::Field::new("condition_node_id", ::fbthrift::TType::I64, 2),
282            ::fbthrift::Field::new("is_do_branch", ::fbthrift::TType::Bool, 1),
283        ];
284        let mut field_is_do_branch = ::std::option::Option::None;
285        let mut field_condition_node_id = ::std::option::Option::None;
286        let _ = p.read_struct_begin(|_| ())?;
287        loop {
288            let (_, fty, fid) = p.read_field_begin(|_| (), FIELDS)?;
289            match (fty, fid as ::std::primitive::i32) {
290                (::fbthrift::TType::Stop, _) => break,
291                (::fbthrift::TType::Bool, 1) => field_is_do_branch = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
292                (::fbthrift::TType::I64, 2) => field_condition_node_id = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
293                (fty, _) => p.skip(fty)?,
294            }
295            p.read_field_end()?;
296        }
297        p.read_struct_end()?;
298        ::std::result::Result::Ok(Self {
299            is_do_branch: field_is_do_branch.unwrap_or_default(),
300            condition_node_id: field_condition_node_id.unwrap_or_default(),
301            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
302        })
303    }
304}
305
306
307#[allow(clippy::derivable_impls)]
308impl ::std::default::Default for self::Pair {
309    fn default() -> Self {
310        Self {
311            key: ::std::default::Default::default(),
312            value: ::std::default::Default::default(),
313            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
314        }
315    }
316}
317
318impl ::std::fmt::Debug for self::Pair {
319    fn fmt(&self, formatter: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
320        formatter
321            .debug_struct("Pair")
322            .field("key", &self.key)
323            .field("value", &self.value)
324            .finish()
325    }
326}
327
328unsafe impl ::std::marker::Send for self::Pair {}
329unsafe impl ::std::marker::Sync for self::Pair {}
330
331impl ::fbthrift::GetTType for self::Pair {
332    const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
333}
334
335impl<P> ::fbthrift::Serialize<P> for self::Pair
336where
337    P: ::fbthrift::ProtocolWriter,
338{
339    fn write(&self, p: &mut P) {
340        p.write_struct_begin("Pair");
341        p.write_field_begin("key", ::fbthrift::TType::String, 1);
342        ::fbthrift::Serialize::write(&self.key, p);
343        p.write_field_end();
344        p.write_field_begin("value", ::fbthrift::TType::String, 2);
345        ::fbthrift::Serialize::write(&self.value, p);
346        p.write_field_end();
347        p.write_field_stop();
348        p.write_struct_end();
349    }
350}
351
352impl<P> ::fbthrift::Deserialize<P> for self::Pair
353where
354    P: ::fbthrift::ProtocolReader,
355{
356    fn read(p: &mut P) -> ::anyhow::Result<Self> {
357        static FIELDS: &[::fbthrift::Field] = &[
358            ::fbthrift::Field::new("key", ::fbthrift::TType::String, 1),
359            ::fbthrift::Field::new("value", ::fbthrift::TType::String, 2),
360        ];
361        let mut field_key = ::std::option::Option::None;
362        let mut field_value = ::std::option::Option::None;
363        let _ = p.read_struct_begin(|_| ())?;
364        loop {
365            let (_, fty, fid) = p.read_field_begin(|_| (), FIELDS)?;
366            match (fty, fid as ::std::primitive::i32) {
367                (::fbthrift::TType::Stop, _) => break,
368                (::fbthrift::TType::String, 1) => field_key = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
369                (::fbthrift::TType::String, 2) => field_value = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
370                (fty, _) => p.skip(fty)?,
371            }
372            p.read_field_end()?;
373        }
374        p.read_struct_end()?;
375        ::std::result::Result::Ok(Self {
376            key: field_key.unwrap_or_default(),
377            value: field_value.unwrap_or_default(),
378            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
379        })
380    }
381}
382
383
384#[allow(clippy::derivable_impls)]
385impl ::std::default::Default for self::PlanNodeDescription {
386    fn default() -> Self {
387        Self {
388            name: ::std::default::Default::default(),
389            id: ::std::default::Default::default(),
390            output_var: ::std::default::Default::default(),
391            description: ::std::option::Option::None,
392            profiles: ::std::option::Option::None,
393            branch_info: ::std::option::Option::None,
394            dependencies: ::std::option::Option::None,
395            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
396        }
397    }
398}
399
400impl ::std::fmt::Debug for self::PlanNodeDescription {
401    fn fmt(&self, formatter: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
402        formatter
403            .debug_struct("PlanNodeDescription")
404            .field("name", &self.name)
405            .field("id", &self.id)
406            .field("output_var", &self.output_var)
407            .field("description", &self.description)
408            .field("profiles", &self.profiles)
409            .field("branch_info", &self.branch_info)
410            .field("dependencies", &self.dependencies)
411            .finish()
412    }
413}
414
415unsafe impl ::std::marker::Send for self::PlanNodeDescription {}
416unsafe impl ::std::marker::Sync for self::PlanNodeDescription {}
417
418impl ::fbthrift::GetTType for self::PlanNodeDescription {
419    const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
420}
421
422impl<P> ::fbthrift::Serialize<P> for self::PlanNodeDescription
423where
424    P: ::fbthrift::ProtocolWriter,
425{
426    fn write(&self, p: &mut P) {
427        p.write_struct_begin("PlanNodeDescription");
428        p.write_field_begin("name", ::fbthrift::TType::String, 1);
429        ::fbthrift::Serialize::write(&self.name, p);
430        p.write_field_end();
431        p.write_field_begin("id", ::fbthrift::TType::I64, 2);
432        ::fbthrift::Serialize::write(&self.id, p);
433        p.write_field_end();
434        p.write_field_begin("output_var", ::fbthrift::TType::String, 3);
435        ::fbthrift::Serialize::write(&self.output_var, p);
436        p.write_field_end();
437        if let ::std::option::Option::Some(some) = &self.description {
438            p.write_field_begin("description", ::fbthrift::TType::List, 4);
439            ::fbthrift::Serialize::write(some, p);
440            p.write_field_end();
441        }
442        if let ::std::option::Option::Some(some) = &self.profiles {
443            p.write_field_begin("profiles", ::fbthrift::TType::List, 5);
444            ::fbthrift::Serialize::write(some, p);
445            p.write_field_end();
446        }
447        if let ::std::option::Option::Some(some) = &self.branch_info {
448            p.write_field_begin("branch_info", ::fbthrift::TType::Struct, 6);
449            ::fbthrift::Serialize::write(some, p);
450            p.write_field_end();
451        }
452        if let ::std::option::Option::Some(some) = &self.dependencies {
453            p.write_field_begin("dependencies", ::fbthrift::TType::List, 7);
454            ::fbthrift::Serialize::write(some, p);
455            p.write_field_end();
456        }
457        p.write_field_stop();
458        p.write_struct_end();
459    }
460}
461
462impl<P> ::fbthrift::Deserialize<P> for self::PlanNodeDescription
463where
464    P: ::fbthrift::ProtocolReader,
465{
466    fn read(p: &mut P) -> ::anyhow::Result<Self> {
467        static FIELDS: &[::fbthrift::Field] = &[
468            ::fbthrift::Field::new("branch_info", ::fbthrift::TType::Struct, 6),
469            ::fbthrift::Field::new("dependencies", ::fbthrift::TType::List, 7),
470            ::fbthrift::Field::new("description", ::fbthrift::TType::List, 4),
471            ::fbthrift::Field::new("id", ::fbthrift::TType::I64, 2),
472            ::fbthrift::Field::new("name", ::fbthrift::TType::String, 1),
473            ::fbthrift::Field::new("output_var", ::fbthrift::TType::String, 3),
474            ::fbthrift::Field::new("profiles", ::fbthrift::TType::List, 5),
475        ];
476        let mut field_name = ::std::option::Option::None;
477        let mut field_id = ::std::option::Option::None;
478        let mut field_output_var = ::std::option::Option::None;
479        let mut field_description = ::std::option::Option::None;
480        let mut field_profiles = ::std::option::Option::None;
481        let mut field_branch_info = ::std::option::Option::None;
482        let mut field_dependencies = ::std::option::Option::None;
483        let _ = p.read_struct_begin(|_| ())?;
484        loop {
485            let (_, fty, fid) = p.read_field_begin(|_| (), FIELDS)?;
486            match (fty, fid as ::std::primitive::i32) {
487                (::fbthrift::TType::Stop, _) => break,
488                (::fbthrift::TType::String, 1) => field_name = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
489                (::fbthrift::TType::I64, 2) => field_id = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
490                (::fbthrift::TType::String, 3) => field_output_var = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
491                (::fbthrift::TType::List, 4) => field_description = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
492                (::fbthrift::TType::List, 5) => field_profiles = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
493                (::fbthrift::TType::Struct, 6) => field_branch_info = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
494                (::fbthrift::TType::List, 7) => field_dependencies = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
495                (fty, _) => p.skip(fty)?,
496            }
497            p.read_field_end()?;
498        }
499        p.read_struct_end()?;
500        ::std::result::Result::Ok(Self {
501            name: field_name.unwrap_or_default(),
502            id: field_id.unwrap_or_default(),
503            output_var: field_output_var.unwrap_or_default(),
504            description: field_description,
505            profiles: field_profiles,
506            branch_info: field_branch_info,
507            dependencies: field_dependencies,
508            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
509        })
510    }
511}
512
513
514#[allow(clippy::derivable_impls)]
515impl ::std::default::Default for self::PlanDescription {
516    fn default() -> Self {
517        Self {
518            plan_node_descs: ::std::default::Default::default(),
519            node_index_map: ::std::default::Default::default(),
520            format: ::std::default::Default::default(),
521            optimize_time_in_us: ::std::default::Default::default(),
522            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
523        }
524    }
525}
526
527impl ::std::fmt::Debug for self::PlanDescription {
528    fn fmt(&self, formatter: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
529        formatter
530            .debug_struct("PlanDescription")
531            .field("plan_node_descs", &self.plan_node_descs)
532            .field("node_index_map", &self.node_index_map)
533            .field("format", &self.format)
534            .field("optimize_time_in_us", &self.optimize_time_in_us)
535            .finish()
536    }
537}
538
539unsafe impl ::std::marker::Send for self::PlanDescription {}
540unsafe impl ::std::marker::Sync for self::PlanDescription {}
541
542impl ::fbthrift::GetTType for self::PlanDescription {
543    const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
544}
545
546impl<P> ::fbthrift::Serialize<P> for self::PlanDescription
547where
548    P: ::fbthrift::ProtocolWriter,
549{
550    fn write(&self, p: &mut P) {
551        p.write_struct_begin("PlanDescription");
552        p.write_field_begin("plan_node_descs", ::fbthrift::TType::List, 1);
553        ::fbthrift::Serialize::write(&self.plan_node_descs, p);
554        p.write_field_end();
555        p.write_field_begin("node_index_map", ::fbthrift::TType::Map, 2);
556        ::fbthrift::Serialize::write(&self.node_index_map, p);
557        p.write_field_end();
558        p.write_field_begin("format", ::fbthrift::TType::String, 3);
559        ::fbthrift::Serialize::write(&self.format, p);
560        p.write_field_end();
561        p.write_field_begin("optimize_time_in_us", ::fbthrift::TType::I32, 4);
562        ::fbthrift::Serialize::write(&self.optimize_time_in_us, p);
563        p.write_field_end();
564        p.write_field_stop();
565        p.write_struct_end();
566    }
567}
568
569impl<P> ::fbthrift::Deserialize<P> for self::PlanDescription
570where
571    P: ::fbthrift::ProtocolReader,
572{
573    fn read(p: &mut P) -> ::anyhow::Result<Self> {
574        static FIELDS: &[::fbthrift::Field] = &[
575            ::fbthrift::Field::new("format", ::fbthrift::TType::String, 3),
576            ::fbthrift::Field::new("node_index_map", ::fbthrift::TType::Map, 2),
577            ::fbthrift::Field::new("optimize_time_in_us", ::fbthrift::TType::I32, 4),
578            ::fbthrift::Field::new("plan_node_descs", ::fbthrift::TType::List, 1),
579        ];
580        let mut field_plan_node_descs = ::std::option::Option::None;
581        let mut field_node_index_map = ::std::option::Option::None;
582        let mut field_format = ::std::option::Option::None;
583        let mut field_optimize_time_in_us = ::std::option::Option::None;
584        let _ = p.read_struct_begin(|_| ())?;
585        loop {
586            let (_, fty, fid) = p.read_field_begin(|_| (), FIELDS)?;
587            match (fty, fid as ::std::primitive::i32) {
588                (::fbthrift::TType::Stop, _) => break,
589                (::fbthrift::TType::List, 1) => field_plan_node_descs = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
590                (::fbthrift::TType::Map, 2) => field_node_index_map = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
591                (::fbthrift::TType::String, 3) => field_format = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
592                (::fbthrift::TType::I32, 4) => field_optimize_time_in_us = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
593                (fty, _) => p.skip(fty)?,
594            }
595            p.read_field_end()?;
596        }
597        p.read_struct_end()?;
598        ::std::result::Result::Ok(Self {
599            plan_node_descs: field_plan_node_descs.unwrap_or_default(),
600            node_index_map: field_node_index_map.unwrap_or_default(),
601            format: field_format.unwrap_or_default(),
602            optimize_time_in_us: field_optimize_time_in_us.unwrap_or_default(),
603            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
604        })
605    }
606}
607
608
609#[allow(clippy::derivable_impls)]
610impl ::std::default::Default for self::ExecutionResponse {
611    fn default() -> Self {
612        Self {
613            error_code: ::std::default::Default::default(),
614            latency_in_us: ::std::default::Default::default(),
615            data: ::std::option::Option::None,
616            space_name: ::std::option::Option::None,
617            error_msg: ::std::option::Option::None,
618            plan_desc: ::std::option::Option::None,
619            comment: ::std::option::Option::None,
620            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
621        }
622    }
623}
624
625impl ::std::fmt::Debug for self::ExecutionResponse {
626    fn fmt(&self, formatter: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
627        formatter
628            .debug_struct("ExecutionResponse")
629            .field("error_code", &self.error_code)
630            .field("latency_in_us", &self.latency_in_us)
631            .field("data", &self.data)
632            .field("space_name", &self.space_name)
633            .field("error_msg", &self.error_msg)
634            .field("plan_desc", &self.plan_desc)
635            .field("comment", &self.comment)
636            .finish()
637    }
638}
639
640unsafe impl ::std::marker::Send for self::ExecutionResponse {}
641unsafe impl ::std::marker::Sync for self::ExecutionResponse {}
642
643impl ::fbthrift::GetTType for self::ExecutionResponse {
644    const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
645}
646
647impl<P> ::fbthrift::Serialize<P> for self::ExecutionResponse
648where
649    P: ::fbthrift::ProtocolWriter,
650{
651    fn write(&self, p: &mut P) {
652        p.write_struct_begin("ExecutionResponse");
653        p.write_field_begin("error_code", ::fbthrift::TType::I32, 1);
654        ::fbthrift::Serialize::write(&self.error_code, p);
655        p.write_field_end();
656        p.write_field_begin("latency_in_us", ::fbthrift::TType::I32, 2);
657        ::fbthrift::Serialize::write(&self.latency_in_us, p);
658        p.write_field_end();
659        if let ::std::option::Option::Some(some) = &self.data {
660            p.write_field_begin("data", ::fbthrift::TType::Struct, 3);
661            ::fbthrift::Serialize::write(some, p);
662            p.write_field_end();
663        }
664        if let ::std::option::Option::Some(some) = &self.space_name {
665            p.write_field_begin("space_name", ::fbthrift::TType::String, 4);
666            ::fbthrift::Serialize::write(some, p);
667            p.write_field_end();
668        }
669        if let ::std::option::Option::Some(some) = &self.error_msg {
670            p.write_field_begin("error_msg", ::fbthrift::TType::String, 5);
671            ::fbthrift::Serialize::write(some, p);
672            p.write_field_end();
673        }
674        if let ::std::option::Option::Some(some) = &self.plan_desc {
675            p.write_field_begin("plan_desc", ::fbthrift::TType::Struct, 6);
676            ::fbthrift::Serialize::write(some, p);
677            p.write_field_end();
678        }
679        if let ::std::option::Option::Some(some) = &self.comment {
680            p.write_field_begin("comment", ::fbthrift::TType::String, 7);
681            ::fbthrift::Serialize::write(some, p);
682            p.write_field_end();
683        }
684        p.write_field_stop();
685        p.write_struct_end();
686    }
687}
688
689impl<P> ::fbthrift::Deserialize<P> for self::ExecutionResponse
690where
691    P: ::fbthrift::ProtocolReader,
692{
693    fn read(p: &mut P) -> ::anyhow::Result<Self> {
694        static FIELDS: &[::fbthrift::Field] = &[
695            ::fbthrift::Field::new("comment", ::fbthrift::TType::String, 7),
696            ::fbthrift::Field::new("data", ::fbthrift::TType::Struct, 3),
697            ::fbthrift::Field::new("error_code", ::fbthrift::TType::I32, 1),
698            ::fbthrift::Field::new("error_msg", ::fbthrift::TType::String, 5),
699            ::fbthrift::Field::new("latency_in_us", ::fbthrift::TType::I32, 2),
700            ::fbthrift::Field::new("plan_desc", ::fbthrift::TType::Struct, 6),
701            ::fbthrift::Field::new("space_name", ::fbthrift::TType::String, 4),
702        ];
703        let mut field_error_code = ::std::option::Option::None;
704        let mut field_latency_in_us = ::std::option::Option::None;
705        let mut field_data = ::std::option::Option::None;
706        let mut field_space_name = ::std::option::Option::None;
707        let mut field_error_msg = ::std::option::Option::None;
708        let mut field_plan_desc = ::std::option::Option::None;
709        let mut field_comment = ::std::option::Option::None;
710        let _ = p.read_struct_begin(|_| ())?;
711        loop {
712            let (_, fty, fid) = p.read_field_begin(|_| (), FIELDS)?;
713            match (fty, fid as ::std::primitive::i32) {
714                (::fbthrift::TType::Stop, _) => break,
715                (::fbthrift::TType::I32, 1) => field_error_code = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
716                (::fbthrift::TType::I32, 2) => field_latency_in_us = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
717                (::fbthrift::TType::Struct, 3) => field_data = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
718                (::fbthrift::TType::String, 4) => field_space_name = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
719                (::fbthrift::TType::String, 5) => field_error_msg = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
720                (::fbthrift::TType::Struct, 6) => field_plan_desc = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
721                (::fbthrift::TType::String, 7) => field_comment = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
722                (fty, _) => p.skip(fty)?,
723            }
724            p.read_field_end()?;
725        }
726        p.read_struct_end()?;
727        ::std::result::Result::Ok(Self {
728            error_code: field_error_code.unwrap_or_default(),
729            latency_in_us: field_latency_in_us.unwrap_or_default(),
730            data: field_data,
731            space_name: field_space_name,
732            error_msg: field_error_msg,
733            plan_desc: field_plan_desc,
734            comment: field_comment,
735            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
736        })
737    }
738}
739
740
741#[allow(clippy::derivable_impls)]
742impl ::std::default::Default for self::AuthResponse {
743    fn default() -> Self {
744        Self {
745            error_code: ::std::default::Default::default(),
746            error_msg: ::std::option::Option::None,
747            session_id: ::std::option::Option::None,
748            time_zone_offset_seconds: ::std::option::Option::None,
749            time_zone_name: ::std::option::Option::None,
750            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
751        }
752    }
753}
754
755impl ::std::fmt::Debug for self::AuthResponse {
756    fn fmt(&self, formatter: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
757        formatter
758            .debug_struct("AuthResponse")
759            .field("error_code", &self.error_code)
760            .field("error_msg", &self.error_msg)
761            .field("session_id", &self.session_id)
762            .field("time_zone_offset_seconds", &self.time_zone_offset_seconds)
763            .field("time_zone_name", &self.time_zone_name)
764            .finish()
765    }
766}
767
768unsafe impl ::std::marker::Send for self::AuthResponse {}
769unsafe impl ::std::marker::Sync for self::AuthResponse {}
770
771impl ::fbthrift::GetTType for self::AuthResponse {
772    const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
773}
774
775impl<P> ::fbthrift::Serialize<P> for self::AuthResponse
776where
777    P: ::fbthrift::ProtocolWriter,
778{
779    fn write(&self, p: &mut P) {
780        p.write_struct_begin("AuthResponse");
781        p.write_field_begin("error_code", ::fbthrift::TType::I32, 1);
782        ::fbthrift::Serialize::write(&self.error_code, p);
783        p.write_field_end();
784        if let ::std::option::Option::Some(some) = &self.error_msg {
785            p.write_field_begin("error_msg", ::fbthrift::TType::String, 2);
786            ::fbthrift::Serialize::write(some, p);
787            p.write_field_end();
788        }
789        if let ::std::option::Option::Some(some) = &self.session_id {
790            p.write_field_begin("session_id", ::fbthrift::TType::I64, 3);
791            ::fbthrift::Serialize::write(some, p);
792            p.write_field_end();
793        }
794        if let ::std::option::Option::Some(some) = &self.time_zone_offset_seconds {
795            p.write_field_begin("time_zone_offset_seconds", ::fbthrift::TType::I32, 4);
796            ::fbthrift::Serialize::write(some, p);
797            p.write_field_end();
798        }
799        if let ::std::option::Option::Some(some) = &self.time_zone_name {
800            p.write_field_begin("time_zone_name", ::fbthrift::TType::String, 5);
801            ::fbthrift::Serialize::write(some, p);
802            p.write_field_end();
803        }
804        p.write_field_stop();
805        p.write_struct_end();
806    }
807}
808
809impl<P> ::fbthrift::Deserialize<P> for self::AuthResponse
810where
811    P: ::fbthrift::ProtocolReader,
812{
813    fn read(p: &mut P) -> ::anyhow::Result<Self> {
814        static FIELDS: &[::fbthrift::Field] = &[
815            ::fbthrift::Field::new("error_code", ::fbthrift::TType::I32, 1),
816            ::fbthrift::Field::new("error_msg", ::fbthrift::TType::String, 2),
817            ::fbthrift::Field::new("session_id", ::fbthrift::TType::I64, 3),
818            ::fbthrift::Field::new("time_zone_name", ::fbthrift::TType::String, 5),
819            ::fbthrift::Field::new("time_zone_offset_seconds", ::fbthrift::TType::I32, 4),
820        ];
821        let mut field_error_code = ::std::option::Option::None;
822        let mut field_error_msg = ::std::option::Option::None;
823        let mut field_session_id = ::std::option::Option::None;
824        let mut field_time_zone_offset_seconds = ::std::option::Option::None;
825        let mut field_time_zone_name = ::std::option::Option::None;
826        let _ = p.read_struct_begin(|_| ())?;
827        loop {
828            let (_, fty, fid) = p.read_field_begin(|_| (), FIELDS)?;
829            match (fty, fid as ::std::primitive::i32) {
830                (::fbthrift::TType::Stop, _) => break,
831                (::fbthrift::TType::I32, 1) => field_error_code = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
832                (::fbthrift::TType::String, 2) => field_error_msg = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
833                (::fbthrift::TType::I64, 3) => field_session_id = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
834                (::fbthrift::TType::I32, 4) => field_time_zone_offset_seconds = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
835                (::fbthrift::TType::String, 5) => field_time_zone_name = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
836                (fty, _) => p.skip(fty)?,
837            }
838            p.read_field_end()?;
839        }
840        p.read_struct_end()?;
841        ::std::result::Result::Ok(Self {
842            error_code: field_error_code.unwrap_or_default(),
843            error_msg: field_error_msg,
844            session_id: field_session_id,
845            time_zone_offset_seconds: field_time_zone_offset_seconds,
846            time_zone_name: field_time_zone_name,
847            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
848        })
849    }
850}
851
852
853#[allow(clippy::derivable_impls)]
854impl ::std::default::Default for self::VerifyClientVersionResp {
855    fn default() -> Self {
856        Self {
857            error_code: ::std::default::Default::default(),
858            error_msg: ::std::option::Option::None,
859            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
860        }
861    }
862}
863
864impl ::std::fmt::Debug for self::VerifyClientVersionResp {
865    fn fmt(&self, formatter: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
866        formatter
867            .debug_struct("VerifyClientVersionResp")
868            .field("error_code", &self.error_code)
869            .field("error_msg", &self.error_msg)
870            .finish()
871    }
872}
873
874unsafe impl ::std::marker::Send for self::VerifyClientVersionResp {}
875unsafe impl ::std::marker::Sync for self::VerifyClientVersionResp {}
876
877impl ::fbthrift::GetTType for self::VerifyClientVersionResp {
878    const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
879}
880
881impl<P> ::fbthrift::Serialize<P> for self::VerifyClientVersionResp
882where
883    P: ::fbthrift::ProtocolWriter,
884{
885    fn write(&self, p: &mut P) {
886        p.write_struct_begin("VerifyClientVersionResp");
887        p.write_field_begin("error_code", ::fbthrift::TType::I32, 1);
888        ::fbthrift::Serialize::write(&self.error_code, p);
889        p.write_field_end();
890        if let ::std::option::Option::Some(some) = &self.error_msg {
891            p.write_field_begin("error_msg", ::fbthrift::TType::String, 2);
892            ::fbthrift::Serialize::write(some, p);
893            p.write_field_end();
894        }
895        p.write_field_stop();
896        p.write_struct_end();
897    }
898}
899
900impl<P> ::fbthrift::Deserialize<P> for self::VerifyClientVersionResp
901where
902    P: ::fbthrift::ProtocolReader,
903{
904    fn read(p: &mut P) -> ::anyhow::Result<Self> {
905        static FIELDS: &[::fbthrift::Field] = &[
906            ::fbthrift::Field::new("error_code", ::fbthrift::TType::I32, 1),
907            ::fbthrift::Field::new("error_msg", ::fbthrift::TType::String, 2),
908        ];
909        let mut field_error_code = ::std::option::Option::None;
910        let mut field_error_msg = ::std::option::Option::None;
911        let _ = p.read_struct_begin(|_| ())?;
912        loop {
913            let (_, fty, fid) = p.read_field_begin(|_| (), FIELDS)?;
914            match (fty, fid as ::std::primitive::i32) {
915                (::fbthrift::TType::Stop, _) => break,
916                (::fbthrift::TType::I32, 1) => field_error_code = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
917                (::fbthrift::TType::String, 2) => field_error_msg = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
918                (fty, _) => p.skip(fty)?,
919            }
920            p.read_field_end()?;
921        }
922        p.read_struct_end()?;
923        ::std::result::Result::Ok(Self {
924            error_code: field_error_code.unwrap_or_default(),
925            error_msg: field_error_msg,
926            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
927        })
928    }
929}
930
931
932#[allow(clippy::derivable_impls)]
933impl ::std::default::Default for self::VerifyClientVersionReq {
934    fn default() -> Self {
935        Self {
936            version: "2.6.0".as_bytes().into(),
937            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
938        }
939    }
940}
941
942impl ::std::fmt::Debug for self::VerifyClientVersionReq {
943    fn fmt(&self, formatter: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
944        formatter
945            .debug_struct("VerifyClientVersionReq")
946            .field("version", &self.version)
947            .finish()
948    }
949}
950
951unsafe impl ::std::marker::Send for self::VerifyClientVersionReq {}
952unsafe impl ::std::marker::Sync for self::VerifyClientVersionReq {}
953
954impl ::fbthrift::GetTType for self::VerifyClientVersionReq {
955    const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
956}
957
958impl<P> ::fbthrift::Serialize<P> for self::VerifyClientVersionReq
959where
960    P: ::fbthrift::ProtocolWriter,
961{
962    fn write(&self, p: &mut P) {
963        p.write_struct_begin("VerifyClientVersionReq");
964        p.write_field_begin("version", ::fbthrift::TType::String, 1);
965        ::fbthrift::Serialize::write(&self.version, p);
966        p.write_field_end();
967        p.write_field_stop();
968        p.write_struct_end();
969    }
970}
971
972impl<P> ::fbthrift::Deserialize<P> for self::VerifyClientVersionReq
973where
974    P: ::fbthrift::ProtocolReader,
975{
976    fn read(p: &mut P) -> ::anyhow::Result<Self> {
977        static FIELDS: &[::fbthrift::Field] = &[
978            ::fbthrift::Field::new("version", ::fbthrift::TType::String, 1),
979        ];
980        let mut field_version = ::std::option::Option::None;
981        let _ = p.read_struct_begin(|_| ())?;
982        loop {
983            let (_, fty, fid) = p.read_field_begin(|_| (), FIELDS)?;
984            match (fty, fid as ::std::primitive::i32) {
985                (::fbthrift::TType::Stop, _) => break,
986                (::fbthrift::TType::String, 1) => field_version = ::std::option::Option::Some(::fbthrift::Deserialize::read(p)?),
987                (fty, _) => p.skip(fty)?,
988            }
989            p.read_field_end()?;
990        }
991        p.read_struct_end()?;
992        ::std::result::Result::Ok(Self {
993            version: field_version.unwrap_or_else(|| "2.6.0".as_bytes().into()),
994            _dot_dot_Default_default: self::dot_dot::OtherFields(()),
995        })
996    }
997}
998
999
1000mod dot_dot {
1001    #[derive(Copy, Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
1002    pub struct OtherFields(pub(crate) ());
1003
1004    #[allow(dead_code)] // if serde isn't being used
1005    pub(super) fn default_for_serde_deserialize() -> OtherFields {
1006        OtherFields(())
1007    }
1008}
nebula_fbthrift_graph_v2/types.rs

nebula_fbthrift_graph_v2/
types.rs
