nominal_api/conjure/objects/ingest/api/
resolve_streaming_session_response.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 ResolveStreamingSessionResponse {
16    #[serde(rename = "sessionRid")]
17    session_rid: super::StreamingSessionRid,
18    #[serde(rename = "datasetRid")]
19    dataset_rid: super::super::super::api::rids::DatasetRid,
20    #[serde(rename = "status")]
21    status: super::StreamingSessionStatus,
22    #[builder(
23        default,
24        custom(
25            type = impl
26            Into<Option<super::StreamingSessionSource>>,
27            convert = |v|v.into().map(Box::new)
28        )
29    )]
30    #[serde(rename = "source", skip_serializing_if = "Option::is_none", default)]
31    source: Option<Box<super::StreamingSessionSource>>,
32    #[builder(
33        default,
34        custom(
35            type = impl
36            Into<Option<super::super::super::api::Range>>,
37            convert = |v|v.into().map(Box::new)
38        )
39    )]
40    #[serde(rename = "bounds", skip_serializing_if = "Option::is_none", default)]
41    bounds: Option<Box<super::super::super::api::Range>>,
42    #[serde(rename = "pointsCount")]
43    points_count: conjure_object::SafeLong,
44    #[builder(custom(type = super::super::super::api::Timestamp, convert = Box::new))]
45    #[serde(rename = "createdAt")]
46    created_at: Box<super::super::super::api::Timestamp>,
47}
48impl ResolveStreamingSessionResponse {
49    #[inline]
50    pub fn session_rid(&self) -> &super::StreamingSessionRid {
51        &self.session_rid
52    }
53    #[inline]
54    pub fn dataset_rid(&self) -> &super::super::super::api::rids::DatasetRid {
55        &self.dataset_rid
56    }
57    #[inline]
58    pub fn status(&self) -> &super::StreamingSessionStatus {
59        &self.status
60    }
61    #[inline]
62    pub fn source(&self) -> Option<&super::StreamingSessionSource> {
63        self.source.as_ref().map(|o| &**o)
64    }
65    #[inline]
66    pub fn bounds(&self) -> Option<&super::super::super::api::Range> {
67        self.bounds.as_ref().map(|o| &**o)
68    }
69    #[inline]
70    pub fn points_count(&self) -> conjure_object::SafeLong {
71        self.points_count
72    }
73    #[inline]
74    pub fn created_at(&self) -> &super::super::super::api::Timestamp {
75        &*self.created_at
76    }
77}
nominal_api/conjure/objects/ingest/api/resolve_streaming_session_response.rs

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