Skip to main content

nominal_api/conjure/objects/persistent/compute/api/
streaming_compute_node_subscription.rs

1#[derive(
2    Debug,
3    Clone,
4    conjure_object::serde::Serialize,
5    conjure_object::serde::Deserialize,
6    conjure_object::private::DeriveWith
7)]
8#[serde(crate = "conjure_object::serde")]
9#[derive_with(PartialEq, Eq, PartialOrd, Ord, Hash)]
10#[conjure_object::private::staged_builder::staged_builder]
11#[builder(crate = conjure_object::private::staged_builder, update, inline)]
12pub struct StreamingComputeNodeSubscription {
13    #[builder(custom(type = super::StreamingComputeNodeRequest, convert = Box::new))]
14    #[serde(rename = "computeRequest")]
15    compute_request: Box<super::StreamingComputeNodeRequest>,
16    #[builder(custom(type = super::SubscriptionOptions, convert = Box::new))]
17    #[serde(rename = "subscriptionOptions")]
18    subscription_options: Box<super::SubscriptionOptions>,
19}
20impl StreamingComputeNodeSubscription {
21    /// Constructs a new instance of the type.
22    #[inline]
23    pub fn new(
24        compute_request: super::StreamingComputeNodeRequest,
25        subscription_options: super::SubscriptionOptions,
26    ) -> Self {
27        Self::builder()
28            .compute_request(compute_request)
29            .subscription_options(subscription_options)
30            .build()
31    }
32    #[inline]
33    pub fn compute_request(&self) -> &super::StreamingComputeNodeRequest {
34        &*self.compute_request
35    }
36    #[inline]
37    pub fn subscription_options(&self) -> &super::SubscriptionOptions {
38        &*self.subscription_options
39    }
40}