nominal_api/conjure/objects/ingest/api/
new_data_source.rs

1#[derive(
2    Debug,
3    Clone,
4    conjure_object::serde::Serialize,
5    conjure_object::serde::Deserialize,
6    PartialEq,
7    Eq,
8    PartialOrd,
9    Ord,
10    Hash
11)]
12#[serde(crate = "conjure_object::serde")]
13#[conjure_object::private::staged_builder::staged_builder]
14#[builder(crate = conjure_object::private::staged_builder, update, inline)]
15pub struct NewDataSource {
16    #[builder(custom(type = super::IngestSource, convert = Box::new))]
17    #[serde(rename = "source")]
18    source: Box<super::IngestSource>,
19    #[builder(
20        default,
21        map(
22            key(type = super::super::super::api::PropertyName),
23            value(type = super::super::super::api::PropertyValue)
24        )
25    )]
26    #[serde(
27        rename = "properties",
28        skip_serializing_if = "std::collections::BTreeMap::is_empty",
29        default
30    )]
31    properties: std::collections::BTreeMap<
32        super::super::super::api::PropertyName,
33        super::super::super::api::PropertyValue,
34    >,
35    #[builder(default, set(item(type = super::super::super::api::Label)))]
36    #[serde(
37        rename = "labels",
38        skip_serializing_if = "std::collections::BTreeSet::is_empty",
39        default
40    )]
41    labels: std::collections::BTreeSet<super::super::super::api::Label>,
42    #[builder(default, into)]
43    #[serde(rename = "description", skip_serializing_if = "Option::is_none", default)]
44    description: Option<String>,
45    #[builder(default, into)]
46    #[serde(rename = "name", skip_serializing_if = "Option::is_none", default)]
47    name: Option<String>,
48    #[builder(
49        default,
50        custom(
51            type = impl
52            Into<Option<super::TimestampMetadata>>,
53            convert = |v|v.into().map(Box::new)
54        )
55    )]
56    #[serde(rename = "timeColumnSpec", skip_serializing_if = "Option::is_none", default)]
57    time_column_spec: Option<Box<super::TimestampMetadata>>,
58    #[builder(
59        default,
60        custom(
61            type = impl
62            Into<Option<super::ChannelConfig>>,
63            convert = |v|v.into().map(Box::new)
64        )
65    )]
66    #[serde(rename = "channelConfig", skip_serializing_if = "Option::is_none", default)]
67    channel_config: Option<Box<super::ChannelConfig>>,
68}
69impl NewDataSource {
70    /// Constructs a new instance of the type.
71    #[inline]
72    pub fn new(source: super::IngestSource) -> Self {
73        Self::builder().source(source).build()
74    }
75    #[inline]
76    pub fn source(&self) -> &super::IngestSource {
77        &*self.source
78    }
79    #[inline]
80    pub fn properties(
81        &self,
82    ) -> &std::collections::BTreeMap<
83        super::super::super::api::PropertyName,
84        super::super::super::api::PropertyValue,
85    > {
86        &self.properties
87    }
88    #[inline]
89    pub fn labels(
90        &self,
91    ) -> &std::collections::BTreeSet<super::super::super::api::Label> {
92        &self.labels
93    }
94    #[inline]
95    pub fn description(&self) -> Option<&str> {
96        self.description.as_ref().map(|o| &**o)
97    }
98    #[inline]
99    pub fn name(&self) -> Option<&str> {
100        self.name.as_ref().map(|o| &**o)
101    }
102    #[inline]
103    pub fn time_column_spec(&self) -> Option<&super::TimestampMetadata> {
104        self.time_column_spec.as_ref().map(|o| &**o)
105    }
106    #[inline]
107    pub fn channel_config(&self) -> Option<&super::ChannelConfig> {
108        self.channel_config.as_ref().map(|o| &**o)
109    }
110}
nominal_api/conjure/objects/ingest/api/new_data_source.rs

nominal_api/conjure/objects/ingest/api/
new_data_source.rs
