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            .with_retry_classifier(::aws_runtime::service_clock_skew::ServiceClockSkewClassifier::<
138                crate::operation::get_subscription::GetSubscriptionError,
139            >::new());
140
141        ::std::borrow::Cow::Owned(rcb)
142    }
143}
144
145#[derive(Debug)]
146struct GetSubscriptionTelemetryInputCaptureInterceptor;
147
148#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
149impl ::aws_smithy_runtime_api::client::interceptors::Intercept for GetSubscriptionTelemetryInputCaptureInterceptor {
150    fn name(&self) -> &'static str {
151        "GetSubscriptionTelemetryInputCaptureInterceptor"
152    }
153
154    fn read_before_execution(
155        &self,
156        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
157            '_,
158            ::aws_smithy_runtime_api::client::interceptors::context::Input,
159            ::aws_smithy_runtime_api::client::interceptors::context::Output,
160            ::aws_smithy_runtime_api::client::interceptors::context::Error,
161        >,
162        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
163    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
164        // Nothing to do unless the customer opted in by naming members to record.
165        let ::std::option::Option::Some(requested) = cfg
166            .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
167            .filter(|r| !r.is_empty())
168        else {
169            return ::std::result::Result::Ok(());
170        };
171
172        let ::std::option::Option::Some(input) = context.input().downcast_ref::<GetSubscriptionInput>() else {
173            // A mismatched input is not this interceptor's concern; skip quietly.
174            return ::std::result::Result::Ok(());
175        };
176
177        let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
178        if requested.should_capture("spaceName") {
179            if let ::std::option::Option::Some(value) = input.space_name.as_deref() {
180                captured.insert("spaceName", value);
181            }
182        }
183
184        cfg.interceptor_state().store_put(captured);
185        ::std::result::Result::Ok(())
186    }
187}
188#[derive(Debug)]
189struct GetSubscriptionResponseDeserializer;
190impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for GetSubscriptionResponseDeserializer {
191    fn deserialize_nonstreaming_with_config(
192        &self,
193        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
194        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
195    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
196        let (success, status) = (response.status().is_success(), response.status().as_u16());
197        let headers = response.headers();
198        let body = response.body().bytes().expect("body loaded");
199        #[allow(unused_mut)]
200        let mut force_error = false;
201        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
202        let parse_result = if !success && status != 200 || force_error {
203            crate::protocol_serde::shape_get_subscription::de_get_subscription_http_error(status, headers, body)
204        } else {
205            crate::protocol_serde::shape_get_subscription::de_get_subscription_http_response(status, headers, body)
206        };
207        crate::protocol_serde::type_erase_result(parse_result)
208    }
209}
210#[derive(Debug)]
211struct GetSubscriptionRequestSerializer;
212impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for GetSubscriptionRequestSerializer {
213    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
214    fn serialize_input(
215        &self,
216        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
217        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
218    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
219        let input = input
220            .downcast::<crate::operation::get_subscription::GetSubscriptionInput>()
221            .expect("correct type");
222        let _header_serialization_settings = _cfg
223            .load::<crate::serialization_settings::HeaderSerializationSettings>()
224            .cloned()
225            .unwrap_or_default();
226        let mut request_builder = {
227            #[allow(clippy::uninlined_format_args)]
228            fn uri_base(
229                _input: &crate::operation::get_subscription::GetSubscriptionInput,
230                output: &mut ::std::string::String,
231            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
232                use ::std::fmt::Write as _;
233                let input_1 = &_input.space_name;
234                let input_1 = input_1
235                    .as_ref()
236                    .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("space_name", "cannot be empty or unset"))?;
237                let space_name = ::aws_smithy_http::label::fmt_string(input_1, ::aws_smithy_http::label::EncodingStrategy::Default);
238                if space_name.is_empty() {
239                    return ::std::result::Result::Err(::aws_smithy_types::error::operation::BuildError::missing_field(
240                        "space_name",
241                        "cannot be empty or unset",
242                    ));
243                }
244                ::std::write!(output, "/v1/spaces/{spaceName}/subscription", spaceName = space_name).expect("formatting should succeed");
245                ::std::result::Result::Ok(())
246            }
247            #[allow(clippy::unnecessary_wraps)]
248            fn update_http_builder(
249                input: &crate::operation::get_subscription::GetSubscriptionInput,
250                builder: ::http_1x::request::Builder,
251            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
252                let mut uri = ::std::string::String::new();
253                uri_base(input, &mut uri)?;
254                ::std::result::Result::Ok(builder.method("GET").uri(uri))
255            }
256            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
257            builder
258        };
259        let body = ::aws_smithy_types::body::SdkBody::from("");
260
261        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
262    }
263}
264#[derive(Debug)]
265struct GetSubscriptionEndpointParamsInterceptor;
266
267#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
268impl ::aws_smithy_runtime_api::client::interceptors::Intercept for GetSubscriptionEndpointParamsInterceptor {
269    fn name(&self) -> &'static str {
270        "GetSubscriptionEndpointParamsInterceptor"
271    }
272
273    fn read_before_execution(
274        &self,
275        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
276            '_,
277            ::aws_smithy_runtime_api::client::interceptors::context::Input,
278            ::aws_smithy_runtime_api::client::interceptors::context::Output,
279            ::aws_smithy_runtime_api::client::interceptors::context::Error,
280        >,
281        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
282    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
283        let _input = context
284            .input()
285            .downcast_ref::<GetSubscriptionInput>()
286            .ok_or("failed to downcast to GetSubscriptionInput")?;
287
288        let params = crate::config::endpoint::Params::builder()
289            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
290            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
291            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
292            .build()
293            .map_err(|err| {
294                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
295            })?;
296        cfg.interceptor_state()
297            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
298        ::std::result::Result::Ok(())
299    }
300}
301
302// The get_* functions below are generated from JMESPath expressions in the
303// operationContextParams trait. They target the operation's input shape.
304
305/// Error type for the `GetSubscriptionError` operation.
306#[non_exhaustive]
307#[derive(::std::fmt::Debug)]
308pub enum GetSubscriptionError {
309    /// <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>
310    AccessDeniedException(crate::types::error::AccessDeniedException),
311    /// <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>
312    ConflictException(crate::types::error::ConflictException),
313    /// <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>
314    ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
315    /// <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>
316    ServiceQuotaExceededException(crate::types::error::ServiceQuotaExceededException),
317    /// <p>The request was denied due to request throttling.</p>
318    ThrottlingException(crate::types::error::ThrottlingException),
319    /// <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>
320    ValidationException(crate::types::error::ValidationException),
321    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
322    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
323    variable wildcard pattern and check `.code()`:
324     \
325    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
326     \
327    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-GetSubscriptionError) for what information is available for the error.")]
328    Unhandled(crate::error::sealed_unhandled::Unhandled),
329}
330impl GetSubscriptionError {
331    /// Creates the `GetSubscriptionError::Unhandled` variant from any error type.
332    pub fn unhandled(
333        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
334    ) -> Self {
335        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
336            source: err.into(),
337            meta: ::std::default::Default::default(),
338        })
339    }
340
341    /// Creates the `GetSubscriptionError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
342    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
343        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
344            source: err.clone().into(),
345            meta: err,
346        })
347    }
348    ///
349    /// Returns error metadata, which includes the error code, message,
350    /// request ID, and potentially additional information.
351    ///
352    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
353        match self {
354            Self::AccessDeniedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
355            Self::ConflictException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
356            Self::ResourceNotFoundException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
357            Self::ServiceQuotaExceededException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
358            Self::ThrottlingException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
359            Self::ValidationException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
360            Self::Unhandled(e) => &e.meta,
361        }
362    }
363    /// Returns `true` if the error kind is `GetSubscriptionError::AccessDeniedException`.
364    pub fn is_access_denied_exception(&self) -> bool {
365        matches!(self, Self::AccessDeniedException(_))
366    }
367    /// Returns `true` if the error kind is `GetSubscriptionError::ConflictException`.
368    pub fn is_conflict_exception(&self) -> bool {
369        matches!(self, Self::ConflictException(_))
370    }
371    /// Returns `true` if the error kind is `GetSubscriptionError::ResourceNotFoundException`.
372    pub fn is_resource_not_found_exception(&self) -> bool {
373        matches!(self, Self::ResourceNotFoundException(_))
374    }
375    /// Returns `true` if the error kind is `GetSubscriptionError::ServiceQuotaExceededException`.
376    pub fn is_service_quota_exceeded_exception(&self) -> bool {
377        matches!(self, Self::ServiceQuotaExceededException(_))
378    }
379    /// Returns `true` if the error kind is `GetSubscriptionError::ThrottlingException`.
380    pub fn is_throttling_exception(&self) -> bool {
381        matches!(self, Self::ThrottlingException(_))
382    }
383    /// Returns `true` if the error kind is `GetSubscriptionError::ValidationException`.
384    pub fn is_validation_exception(&self) -> bool {
385        matches!(self, Self::ValidationException(_))
386    }
387}
388impl ::std::error::Error for GetSubscriptionError {
389    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
390        match self {
391            Self::AccessDeniedException(_inner) => ::std::option::Option::Some(_inner),
392            Self::ConflictException(_inner) => ::std::option::Option::Some(_inner),
393            Self::ResourceNotFoundException(_inner) => ::std::option::Option::Some(_inner),
394            Self::ServiceQuotaExceededException(_inner) => ::std::option::Option::Some(_inner),
395            Self::ThrottlingException(_inner) => ::std::option::Option::Some(_inner),
396            Self::ValidationException(_inner) => ::std::option::Option::Some(_inner),
397            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
398        }
399    }
400}
401impl ::std::fmt::Display for GetSubscriptionError {
402    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
403        match self {
404            Self::AccessDeniedException(_inner) => _inner.fmt(f),
405            Self::ConflictException(_inner) => _inner.fmt(f),
406            Self::ResourceNotFoundException(_inner) => _inner.fmt(f),
407            Self::ServiceQuotaExceededException(_inner) => _inner.fmt(f),
408            Self::ThrottlingException(_inner) => _inner.fmt(f),
409            Self::ValidationException(_inner) => _inner.fmt(f),
410            Self::Unhandled(_inner) => {
411                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
412                    write!(f, "unhandled error ({code})")
413                } else {
414                    f.write_str("unhandled error")
415                }
416            }
417        }
418    }
419}
420impl ::aws_smithy_types::retry::ProvideErrorKind for GetSubscriptionError {
421    fn code(&self) -> ::std::option::Option<&str> {
422        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
423    }
424    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
425        match self {
426            Self::ThrottlingException(inner) => ::std::option::Option::Some(inner.retryable_error_kind()),
427            _ => ::std::option::Option::None,
428        }
429    }
430}
431impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for GetSubscriptionError {
432    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
433        match self {
434            Self::AccessDeniedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
435            Self::ConflictException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
436            Self::ResourceNotFoundException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
437            Self::ServiceQuotaExceededException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
438            Self::ThrottlingException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
439            Self::ValidationException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
440            Self::Unhandled(_inner) => &_inner.meta,
441        }
442    }
443}
444impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for GetSubscriptionError {
445    fn create_unhandled_error(
446        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
447        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
448    ) -> Self {
449        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
450            source,
451            meta: meta.unwrap_or_default(),
452        })
453    }
454}
455impl ::aws_types::request_id::RequestId for crate::operation::get_subscription::GetSubscriptionError {
456    fn request_id(&self) -> Option<&str> {
457        self.meta().request_id()
458    }
459}
460
461pub use crate::operation::get_subscription::_get_subscription_input::GetSubscriptionInput;
462
463pub use crate::operation::get_subscription::_get_subscription_output::GetSubscriptionOutput;
464
465mod _get_subscription_input;
466
467mod _get_subscription_output;
468
469/// Builders
470pub mod builders;
aws_sdk_codecatalyst/operation/get_subscription.rs

aws_sdk_codecatalyst/operation/
get_subscription.rs
