Skip to main content

aws_sdk_codecatalyst/operation/
get_subscription.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `GetSubscription`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct GetSubscription;
6impl GetSubscription {
7    /// Creates a new `GetSubscription`
8    pub fn new() -> Self {
9        Self
10    }
11    pub(crate) async fn orchestrate(
12        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
13        input: crate::operation::get_subscription::GetSubscriptionInput,
14    ) -> ::std::result::Result<
15        crate::operation::get_subscription::GetSubscriptionOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::get_subscription::GetSubscriptionError,
18            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
19        >,
20    > {
21        let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
22            ::aws_smithy_runtime_api::client::interceptors::context::Error,
23            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
24        >| {
25            err.map_service_error(|err| {
26                err.downcast::<crate::operation::get_subscription::GetSubscriptionError>()
27                    .expect("correct error type")
28            })
29        };
30        let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
31            .await
32            .map_err(map_err)?;
33        let output = context.finalize().map_err(map_err)?;
34        ::std::result::Result::Ok(
35            output
36                .downcast::<crate::operation::get_subscription::GetSubscriptionOutput>()
37                .expect("correct output type"),
38        )
39    }
40
41    pub(crate) async fn orchestrate_with_stop_point(
42        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
43        input: crate::operation::get_subscription::GetSubscriptionInput,
44        stop_point: ::aws_smithy_runtime::client::orchestrator::StopPoint,
45    ) -> ::std::result::Result<
46        ::aws_smithy_runtime_api::client::interceptors::context::InterceptorContext,
47        ::aws_smithy_runtime_api::client::result::SdkError<
48            ::aws_smithy_runtime_api::client::interceptors::context::Error,
49            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
50        >,
51    > {
52        let input = ::aws_smithy_runtime_api::client::interceptors::context::Input::erase(input);
53        use ::tracing::Instrument;
54        ::aws_smithy_runtime::client::orchestrator::invoke_with_stop_point("CodeCatalyst", "GetSubscription", input, runtime_plugins, stop_point)
55            // Create a parent span for the entire operation. Includes a random, internal-only,
56            // seven-digit ID for the operation orchestration so that it can be correlated in the logs.
57            .instrument(::tracing::debug_span!(
58                "CodeCatalyst.GetSubscription",
59                "rpc.service" = "CodeCatalyst",
60                "rpc.method" = "GetSubscription",
61                "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
62                "rpc.system" = "aws-api",
63            ))
64            .await
65    }
66
67    pub(crate) fn operation_runtime_plugins(
68        client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
69        client_config: &crate::config::Config,
70        config_override: ::std::option::Option<crate::config::Builder>,
71    ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
72        let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
73
74        if let ::std::option::Option::Some(config_override) = config_override {
75            for plugin in config_override.runtime_plugins.iter().cloned() {
76                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
77            }
78            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
79                config_override,
80                client_config.config.clone(),
81                &client_config.runtime_components,
82            ));
83        }
84        runtime_plugins
85    }
86}
87impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for GetSubscription {
88    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
89        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("GetSubscription");
90
91        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
92            GetSubscriptionRequestSerializer,
93        ));
94        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
95            GetSubscriptionResponseDeserializer,
96        ));
97
98        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
99            crate::config::auth::Params::builder()
100                .operation_name("GetSubscription")
101                .build()
102                .expect("required fields set"),
103        ));
104
105        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
106            "GetSubscription",
107            "CodeCatalyst",
108        ));
109
110        ::std::option::Option::Some(cfg.freeze())
111    }
112
113    fn runtime_components(
114        &self,
115        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
116    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
117        #[allow(unused_mut)]
118        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("GetSubscription")
119            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
120                GetSubscriptionTelemetryInputCaptureInterceptor,
121            ))
122            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
123                ::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default(),
124            ))
125            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
126                GetSubscriptionEndpointParamsInterceptor,
127            ))
128            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
129                crate::operation::get_subscription::GetSubscriptionError,
130            >::new())
131            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
132                crate::operation::get_subscription::GetSubscriptionError,
133            >::new())
134            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
135                crate::operation::get_subscription::GetSubscriptionError,
136            >::new());
137
138        ::std::borrow::Cow::Owned(rcb)
139    }
140}
141
142#[derive(Debug)]
143struct GetSubscriptionTelemetryInputCaptureInterceptor;
144
145#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
146impl ::aws_smithy_runtime_api::client::interceptors::Intercept for GetSubscriptionTelemetryInputCaptureInterceptor {
147    fn name(&self) -> &'static str {
148        "GetSubscriptionTelemetryInputCaptureInterceptor"
149    }
150
151    fn read_before_execution(
152        &self,
153        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
154            '_,
155            ::aws_smithy_runtime_api::client::interceptors::context::Input,
156            ::aws_smithy_runtime_api::client::interceptors::context::Output,
157            ::aws_smithy_runtime_api::client::interceptors::context::Error,
158        >,
159        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
160    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
161        // Nothing to do unless the customer opted in by naming members to record.
162        let ::std::option::Option::Some(requested) = cfg
163            .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
164            .filter(|r| !r.is_empty())
165        else {
166            return ::std::result::Result::Ok(());
167        };
168
169        let ::std::option::Option::Some(input) = context.input().downcast_ref::<GetSubscriptionInput>() else {
170            // A mismatched input is not this interceptor's concern; skip quietly.
171            return ::std::result::Result::Ok(());
172        };
173
174        let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
175        if requested.should_capture("spaceName") {
176            if let ::std::option::Option::Some(value) = input.space_name.as_deref() {
177                captured.insert("spaceName", value);
178            }
179        }
180
181        cfg.interceptor_state().store_put(captured);
182        ::std::result::Result::Ok(())
183    }
184}
185#[derive(Debug)]
186struct GetSubscriptionResponseDeserializer;
187impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for GetSubscriptionResponseDeserializer {
188    fn deserialize_nonstreaming_with_config(
189        &self,
190        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
191        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
192    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
193        let (success, status) = (response.status().is_success(), response.status().as_u16());
194        let headers = response.headers();
195        let body = response.body().bytes().expect("body loaded");
196        #[allow(unused_mut)]
197        let mut force_error = false;
198        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
199        let parse_result = if !success && status != 200 || force_error {
200            crate::protocol_serde::shape_get_subscription::de_get_subscription_http_error(status, headers, body)
201        } else {
202            crate::protocol_serde::shape_get_subscription::de_get_subscription_http_response(status, headers, body)
203        };
204        crate::protocol_serde::type_erase_result(parse_result)
205    }
206}
207#[derive(Debug)]
208struct GetSubscriptionRequestSerializer;
209impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for GetSubscriptionRequestSerializer {
210    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
211    fn serialize_input(
212        &self,
213        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
214        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
215    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
216        let input = input
217            .downcast::<crate::operation::get_subscription::GetSubscriptionInput>()
218            .expect("correct type");
219        let _header_serialization_settings = _cfg
220            .load::<crate::serialization_settings::HeaderSerializationSettings>()
221            .cloned()
222            .unwrap_or_default();
223        let mut request_builder = {
224            #[allow(clippy::uninlined_format_args)]
225            fn uri_base(
226                _input: &crate::operation::get_subscription::GetSubscriptionInput,
227                output: &mut ::std::string::String,
228            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
229                use ::std::fmt::Write as _;
230                let input_1 = &_input.space_name;
231                let input_1 = input_1
232                    .as_ref()
233                    .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("space_name", "cannot be empty or unset"))?;
234                let space_name = ::aws_smithy_http::label::fmt_string(input_1, ::aws_smithy_http::label::EncodingStrategy::Default);
235                if space_name.is_empty() {
236                    return ::std::result::Result::Err(::aws_smithy_types::error::operation::BuildError::missing_field(
237                        "space_name",
238                        "cannot be empty or unset",
239                    ));
240                }
241                ::std::write!(output, "/v1/spaces/{spaceName}/subscription", spaceName = space_name).expect("formatting should succeed");
242                ::std::result::Result::Ok(())
243            }
244            #[allow(clippy::unnecessary_wraps)]
245            fn update_http_builder(
246                input: &crate::operation::get_subscription::GetSubscriptionInput,
247                builder: ::http_1x::request::Builder,
248            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
249                let mut uri = ::std::string::String::new();
250                uri_base(input, &mut uri)?;
251                ::std::result::Result::Ok(builder.method("GET").uri(uri))
252            }
253            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
254            builder
255        };
256        let body = ::aws_smithy_types::body::SdkBody::from("");
257
258        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
259    }
260}
261#[derive(Debug)]
262struct GetSubscriptionEndpointParamsInterceptor;
263
264#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
265impl ::aws_smithy_runtime_api::client::interceptors::Intercept for GetSubscriptionEndpointParamsInterceptor {
266    fn name(&self) -> &'static str {
267        "GetSubscriptionEndpointParamsInterceptor"
268    }
269
270    fn read_before_execution(
271        &self,
272        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
273            '_,
274            ::aws_smithy_runtime_api::client::interceptors::context::Input,
275            ::aws_smithy_runtime_api::client::interceptors::context::Output,
276            ::aws_smithy_runtime_api::client::interceptors::context::Error,
277        >,
278        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
279    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
280        let _input = context
281            .input()
282            .downcast_ref::<GetSubscriptionInput>()
283            .ok_or("failed to downcast to GetSubscriptionInput")?;
284
285        let params = crate::config::endpoint::Params::builder()
286            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
287            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
288            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
289            .build()
290            .map_err(|err| {
291                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
292            })?;
293        cfg.interceptor_state()
294            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
295        ::std::result::Result::Ok(())
296    }
297}
298
299// The get_* functions below are generated from JMESPath expressions in the
300// operationContextParams trait. They target the operation's input shape.
301
302/// Error type for the `GetSubscriptionError` operation.
303#[non_exhaustive]
304#[derive(::std::fmt::Debug)]
305pub enum GetSubscriptionError {
306    /// <p>The request was denied because you don't have sufficient access to perform this action. Verify that you are a member of a role that allows this action.</p>
307    AccessDeniedException(crate::types::error::AccessDeniedException),
308    /// <p>The request was denied because the requested operation would cause a conflict with the current state of a service resource associated with the request. Another user might have updated the resource. Reload, make sure you have the latest data, and then try again.</p>
309    ConflictException(crate::types::error::ConflictException),
310    /// <p>The request was denied because the specified resource was not found. Verify that the spelling is correct and that you have access to the resource.</p>
311    ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
312    /// <p>The request was denied because one or more resources has reached its limits for the tier the space belongs to. Either reduce the number of resources, or change the tier if applicable.</p>
313    ServiceQuotaExceededException(crate::types::error::ServiceQuotaExceededException),
314    /// <p>The request was denied due to request throttling.</p>
315    ThrottlingException(crate::types::error::ThrottlingException),
316    /// <p>The request was denied because an input failed to satisfy the constraints specified by the service. Check the spelling and input requirements, and then try again.</p>
317    ValidationException(crate::types::error::ValidationException),
318    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
319    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
320    variable wildcard pattern and check `.code()`:
321     \
322    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
323     \
324    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-GetSubscriptionError) for what information is available for the error.")]
325    Unhandled(crate::error::sealed_unhandled::Unhandled),
326}
327impl GetSubscriptionError {
328    /// Creates the `GetSubscriptionError::Unhandled` variant from any error type.
329    pub fn unhandled(
330        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
331    ) -> Self {
332        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
333            source: err.into(),
334            meta: ::std::default::Default::default(),
335        })
336    }
337
338    /// Creates the `GetSubscriptionError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
339    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
340        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
341            source: err.clone().into(),
342            meta: err,
343        })
344    }
345    ///
346    /// Returns error metadata, which includes the error code, message,
347    /// request ID, and potentially additional information.
348    ///
349    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
350        match self {
351            Self::AccessDeniedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
352            Self::ConflictException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
353            Self::ResourceNotFoundException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
354            Self::ServiceQuotaExceededException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
355            Self::ThrottlingException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
356            Self::ValidationException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
357            Self::Unhandled(e) => &e.meta,
358        }
359    }
360    /// Returns `true` if the error kind is `GetSubscriptionError::AccessDeniedException`.
361    pub fn is_access_denied_exception(&self) -> bool {
362        matches!(self, Self::AccessDeniedException(_))
363    }
364    /// Returns `true` if the error kind is `GetSubscriptionError::ConflictException`.
365    pub fn is_conflict_exception(&self) -> bool {
366        matches!(self, Self::ConflictException(_))
367    }
368    /// Returns `true` if the error kind is `GetSubscriptionError::ResourceNotFoundException`.
369    pub fn is_resource_not_found_exception(&self) -> bool {
370        matches!(self, Self::ResourceNotFoundException(_))
371    }
372    /// Returns `true` if the error kind is `GetSubscriptionError::ServiceQuotaExceededException`.
373    pub fn is_service_quota_exceeded_exception(&self) -> bool {
374        matches!(self, Self::ServiceQuotaExceededException(_))
375    }
376    /// Returns `true` if the error kind is `GetSubscriptionError::ThrottlingException`.
377    pub fn is_throttling_exception(&self) -> bool {
378        matches!(self, Self::ThrottlingException(_))
379    }
380    /// Returns `true` if the error kind is `GetSubscriptionError::ValidationException`.
381    pub fn is_validation_exception(&self) -> bool {
382        matches!(self, Self::ValidationException(_))
383    }
384}
385impl ::std::error::Error for GetSubscriptionError {
386    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
387        match self {
388            Self::AccessDeniedException(_inner) => ::std::option::Option::Some(_inner),
389            Self::ConflictException(_inner) => ::std::option::Option::Some(_inner),
390            Self::ResourceNotFoundException(_inner) => ::std::option::Option::Some(_inner),
391            Self::ServiceQuotaExceededException(_inner) => ::std::option::Option::Some(_inner),
392            Self::ThrottlingException(_inner) => ::std::option::Option::Some(_inner),
393            Self::ValidationException(_inner) => ::std::option::Option::Some(_inner),
394            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
395        }
396    }
397}
398impl ::std::fmt::Display for GetSubscriptionError {
399    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
400        match self {
401            Self::AccessDeniedException(_inner) => _inner.fmt(f),
402            Self::ConflictException(_inner) => _inner.fmt(f),
403            Self::ResourceNotFoundException(_inner) => _inner.fmt(f),
404            Self::ServiceQuotaExceededException(_inner) => _inner.fmt(f),
405            Self::ThrottlingException(_inner) => _inner.fmt(f),
406            Self::ValidationException(_inner) => _inner.fmt(f),
407            Self::Unhandled(_inner) => {
408                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
409                    write!(f, "unhandled error ({code})")
410                } else {
411                    f.write_str("unhandled error")
412                }
413            }
414        }
415    }
416}
417impl ::aws_smithy_types::retry::ProvideErrorKind for GetSubscriptionError {
418    fn code(&self) -> ::std::option::Option<&str> {
419        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
420    }
421    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
422        match self {
423            Self::ThrottlingException(inner) => ::std::option::Option::Some(inner.retryable_error_kind()),
424            _ => ::std::option::Option::None,
425        }
426    }
427}
428impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for GetSubscriptionError {
429    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
430        match self {
431            Self::AccessDeniedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
432            Self::ConflictException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
433            Self::ResourceNotFoundException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
434            Self::ServiceQuotaExceededException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
435            Self::ThrottlingException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
436            Self::ValidationException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
437            Self::Unhandled(_inner) => &_inner.meta,
438        }
439    }
440}
441impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for GetSubscriptionError {
442    fn create_unhandled_error(
443        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
444        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
445    ) -> Self {
446        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
447            source,
448            meta: meta.unwrap_or_default(),
449        })
450    }
451}
452impl ::aws_types::request_id::RequestId for crate::operation::get_subscription::GetSubscriptionError {
453    fn request_id(&self) -> Option<&str> {
454        self.meta().request_id()
455    }
456}
457
458pub use crate::operation::get_subscription::_get_subscription_input::GetSubscriptionInput;
459
460pub use crate::operation::get_subscription::_get_subscription_output::GetSubscriptionOutput;
461
462mod _get_subscription_input;
463
464mod _get_subscription_output;
465
466/// Builders
467pub mod builders;