aws_sdk_devopsguru/operation/
describe_resource_collection_health.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `DescribeResourceCollectionHealth`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct DescribeResourceCollectionHealth;
6impl DescribeResourceCollectionHealth {
7    /// Creates a new `DescribeResourceCollectionHealth`
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::describe_resource_collection_health::DescribeResourceCollectionHealthInput,
14    ) -> ::std::result::Result<
15        crate::operation::describe_resource_collection_health::DescribeResourceCollectionHealthOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::describe_resource_collection_health::DescribeResourceCollectionHealthError,
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::describe_resource_collection_health::DescribeResourceCollectionHealthError>()
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::describe_resource_collection_health::DescribeResourceCollectionHealthOutput>()
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::describe_resource_collection_health::DescribeResourceCollectionHealthInput,
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(
55            "DevOps Guru",
56            "DescribeResourceCollectionHealth",
57            input,
58            runtime_plugins,
59            stop_point,
60        )
61        // Create a parent span for the entire operation. Includes a random, internal-only,
62        // seven-digit ID for the operation orchestration so that it can be correlated in the logs.
63        .instrument(::tracing::debug_span!(
64            "DevOps Guru.DescribeResourceCollectionHealth",
65            "rpc.service" = "DevOps Guru",
66            "rpc.method" = "DescribeResourceCollectionHealth",
67            "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
68            "rpc.system" = "aws-api",
69        ))
70        .await
71    }
72
73    pub(crate) fn operation_runtime_plugins(
74        client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
75        client_config: &crate::config::Config,
76        config_override: ::std::option::Option<crate::config::Builder>,
77    ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
78        let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
79
80        if let ::std::option::Option::Some(config_override) = config_override {
81            for plugin in config_override.runtime_plugins.iter().cloned() {
82                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
83            }
84            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
85                config_override,
86                client_config.config.clone(),
87                &client_config.runtime_components,
88            ));
89        }
90        runtime_plugins
91    }
92}
93impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for DescribeResourceCollectionHealth {
94    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
95        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("DescribeResourceCollectionHealth");
96
97        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
98            DescribeResourceCollectionHealthRequestSerializer,
99        ));
100        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
101            DescribeResourceCollectionHealthResponseDeserializer,
102        ));
103
104        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
105            crate::config::auth::Params::builder()
106                .operation_name("DescribeResourceCollectionHealth")
107                .build()
108                .expect("required fields set"),
109        ));
110
111        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
112            "DescribeResourceCollectionHealth",
113            "DevOps Guru",
114        ));
115        let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
116        signing_options.double_uri_encode = true;
117        signing_options.content_sha256_header = false;
118        signing_options.normalize_uri_path = true;
119        signing_options.payload_override = None;
120
121        cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
122            signing_options,
123            ..::std::default::Default::default()
124        });
125
126        ::std::option::Option::Some(cfg.freeze())
127    }
128
129    fn runtime_components(
130        &self,
131        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
132    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
133        #[allow(unused_mut)]
134        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("DescribeResourceCollectionHealth")
135            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
136                ::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default(),
137            ))
138            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
139                DescribeResourceCollectionHealthEndpointParamsInterceptor,
140            ))
141            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
142                crate::operation::describe_resource_collection_health::DescribeResourceCollectionHealthError,
143            >::new())
144            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
145                crate::operation::describe_resource_collection_health::DescribeResourceCollectionHealthError,
146            >::new())
147            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
148                crate::operation::describe_resource_collection_health::DescribeResourceCollectionHealthError,
149            >::new());
150
151        ::std::borrow::Cow::Owned(rcb)
152    }
153}
154
155#[derive(Debug)]
156struct DescribeResourceCollectionHealthResponseDeserializer;
157impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for DescribeResourceCollectionHealthResponseDeserializer {
158    fn deserialize_nonstreaming_with_config(
159        &self,
160        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
161        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
162    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
163        let (success, status) = (response.status().is_success(), response.status().as_u16());
164        let headers = response.headers();
165        let body = response.body().bytes().expect("body loaded");
166        #[allow(unused_mut)]
167        let mut force_error = false;
168        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
169        let parse_result = if !success && status != 200 || force_error {
170            crate::protocol_serde::shape_describe_resource_collection_health::de_describe_resource_collection_health_http_error(status, headers, body)
171        } else {
172            crate::protocol_serde::shape_describe_resource_collection_health::de_describe_resource_collection_health_http_response(
173                status, headers, body,
174            )
175        };
176        crate::protocol_serde::type_erase_result(parse_result)
177    }
178}
179#[derive(Debug)]
180struct DescribeResourceCollectionHealthRequestSerializer;
181impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for DescribeResourceCollectionHealthRequestSerializer {
182    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
183    fn serialize_input(
184        &self,
185        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
186        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
187    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
188        let input = input
189            .downcast::<crate::operation::describe_resource_collection_health::DescribeResourceCollectionHealthInput>()
190            .expect("correct type");
191        let _header_serialization_settings = _cfg
192            .load::<crate::serialization_settings::HeaderSerializationSettings>()
193            .cloned()
194            .unwrap_or_default();
195        let mut request_builder = {
196            #[allow(clippy::uninlined_format_args)]
197            fn uri_base(
198                _input: &crate::operation::describe_resource_collection_health::DescribeResourceCollectionHealthInput,
199                output: &mut ::std::string::String,
200            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
201                use ::std::fmt::Write as _;
202                let input_1 = &_input.resource_collection_type;
203                let input_1 = input_1.as_ref().ok_or_else(|| {
204                    ::aws_smithy_types::error::operation::BuildError::missing_field("resource_collection_type", "cannot be empty or unset")
205                })?;
206                let resource_collection_type =
207                    ::aws_smithy_http::label::fmt_string(input_1.as_str(), ::aws_smithy_http::label::EncodingStrategy::Default);
208                if resource_collection_type.is_empty() {
209                    return ::std::result::Result::Err(::aws_smithy_types::error::operation::BuildError::missing_field(
210                        "resource_collection_type",
211                        "cannot be empty or unset",
212                    ));
213                }
214                ::std::write!(
215                    output,
216                    "/accounts/health/resource-collection/{ResourceCollectionType}",
217                    ResourceCollectionType = resource_collection_type
218                )
219                .expect("formatting should succeed");
220                ::std::result::Result::Ok(())
221            }
222            fn uri_query(
223                _input: &crate::operation::describe_resource_collection_health::DescribeResourceCollectionHealthInput,
224                mut output: &mut ::std::string::String,
225            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
226                let mut query = ::aws_smithy_http::query::Writer::new(output);
227                if let ::std::option::Option::Some(inner_2) = &_input.next_token {
228                    {
229                        query.push_kv("NextToken", &::aws_smithy_http::query::fmt_string(inner_2));
230                    }
231                }
232                ::std::result::Result::Ok(())
233            }
234            #[allow(clippy::unnecessary_wraps)]
235            fn update_http_builder(
236                input: &crate::operation::describe_resource_collection_health::DescribeResourceCollectionHealthInput,
237                builder: ::http_1x::request::Builder,
238            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
239                let mut uri = ::std::string::String::new();
240                uri_base(input, &mut uri)?;
241                uri_query(input, &mut uri)?;
242                ::std::result::Result::Ok(builder.method("GET").uri(uri))
243            }
244            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
245            builder
246        };
247        let body = ::aws_smithy_types::body::SdkBody::from("");
248
249        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
250    }
251}
252#[derive(Debug)]
253struct DescribeResourceCollectionHealthEndpointParamsInterceptor;
254
255#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
256impl ::aws_smithy_runtime_api::client::interceptors::Intercept for DescribeResourceCollectionHealthEndpointParamsInterceptor {
257    fn name(&self) -> &'static str {
258        "DescribeResourceCollectionHealthEndpointParamsInterceptor"
259    }
260
261    fn read_before_execution(
262        &self,
263        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
264            '_,
265            ::aws_smithy_runtime_api::client::interceptors::context::Input,
266            ::aws_smithy_runtime_api::client::interceptors::context::Output,
267            ::aws_smithy_runtime_api::client::interceptors::context::Error,
268        >,
269        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
270    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
271        let _input = context
272            .input()
273            .downcast_ref::<DescribeResourceCollectionHealthInput>()
274            .ok_or("failed to downcast to DescribeResourceCollectionHealthInput")?;
275
276        let params = crate::config::endpoint::Params::builder()
277            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
278            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
279            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
280            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
281            .build()
282            .map_err(|err| {
283                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
284            })?;
285        cfg.interceptor_state()
286            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
287        ::std::result::Result::Ok(())
288    }
289}
290
291// The get_* functions below are generated from JMESPath expressions in the
292// operationContextParams trait. They target the operation's input shape.
293
294/// Error type for the `DescribeResourceCollectionHealthError` operation.
295#[non_exhaustive]
296#[derive(::std::fmt::Debug)]
297pub enum DescribeResourceCollectionHealthError {
298    /// <p>You don't have permissions to perform the requested operation. The user or role that is making the request must have at least one IAM permissions policy attached that grants the required permissions. For more information, see <a href="https://docs.aws.amazon.com/IAM/latest/UserGuide/access.html">Access Management</a> in the <i>IAM User Guide</i>.</p>
299    AccessDeniedException(crate::types::error::AccessDeniedException),
300    /// <p>An internal failure in an Amazon service occurred.</p>
301    InternalServerException(crate::types::error::InternalServerException),
302    /// <p>The request was denied due to a request throttling.</p>
303    ThrottlingException(crate::types::error::ThrottlingException),
304    /// <p>Contains information about data passed in to a field during a request that is not valid.</p>
305    ValidationException(crate::types::error::ValidationException),
306    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
307    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
308    variable wildcard pattern and check `.code()`:
309     \
310    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
311     \
312    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeResourceCollectionHealthError) for what information is available for the error.")]
313    Unhandled(crate::error::sealed_unhandled::Unhandled),
314}
315impl DescribeResourceCollectionHealthError {
316    /// Creates the `DescribeResourceCollectionHealthError::Unhandled` variant from any error type.
317    pub fn unhandled(
318        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
319    ) -> Self {
320        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
321            source: err.into(),
322            meta: ::std::default::Default::default(),
323        })
324    }
325
326    /// Creates the `DescribeResourceCollectionHealthError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
327    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
328        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
329            source: err.clone().into(),
330            meta: err,
331        })
332    }
333    ///
334    /// Returns error metadata, which includes the error code, message,
335    /// request ID, and potentially additional information.
336    ///
337    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
338        match self {
339            Self::AccessDeniedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
340            Self::InternalServerException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
341            Self::ThrottlingException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
342            Self::ValidationException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
343            Self::Unhandled(e) => &e.meta,
344        }
345    }
346    /// Returns `true` if the error kind is `DescribeResourceCollectionHealthError::AccessDeniedException`.
347    pub fn is_access_denied_exception(&self) -> bool {
348        matches!(self, Self::AccessDeniedException(_))
349    }
350    /// Returns `true` if the error kind is `DescribeResourceCollectionHealthError::InternalServerException`.
351    pub fn is_internal_server_exception(&self) -> bool {
352        matches!(self, Self::InternalServerException(_))
353    }
354    /// Returns `true` if the error kind is `DescribeResourceCollectionHealthError::ThrottlingException`.
355    pub fn is_throttling_exception(&self) -> bool {
356        matches!(self, Self::ThrottlingException(_))
357    }
358    /// Returns `true` if the error kind is `DescribeResourceCollectionHealthError::ValidationException`.
359    pub fn is_validation_exception(&self) -> bool {
360        matches!(self, Self::ValidationException(_))
361    }
362}
363impl ::std::error::Error for DescribeResourceCollectionHealthError {
364    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
365        match self {
366            Self::AccessDeniedException(_inner) => ::std::option::Option::Some(_inner),
367            Self::InternalServerException(_inner) => ::std::option::Option::Some(_inner),
368            Self::ThrottlingException(_inner) => ::std::option::Option::Some(_inner),
369            Self::ValidationException(_inner) => ::std::option::Option::Some(_inner),
370            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
371        }
372    }
373}
374impl ::std::fmt::Display for DescribeResourceCollectionHealthError {
375    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
376        match self {
377            Self::AccessDeniedException(_inner) => _inner.fmt(f),
378            Self::InternalServerException(_inner) => _inner.fmt(f),
379            Self::ThrottlingException(_inner) => _inner.fmt(f),
380            Self::ValidationException(_inner) => _inner.fmt(f),
381            Self::Unhandled(_inner) => {
382                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
383                    write!(f, "unhandled error ({code})")
384                } else {
385                    f.write_str("unhandled error")
386                }
387            }
388        }
389    }
390}
391impl ::aws_smithy_types::retry::ProvideErrorKind for DescribeResourceCollectionHealthError {
392    fn code(&self) -> ::std::option::Option<&str> {
393        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
394    }
395    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
396        ::std::option::Option::None
397    }
398}
399impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for DescribeResourceCollectionHealthError {
400    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
401        match self {
402            Self::AccessDeniedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
403            Self::InternalServerException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
404            Self::ThrottlingException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
405            Self::ValidationException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
406            Self::Unhandled(_inner) => &_inner.meta,
407        }
408    }
409}
410impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for DescribeResourceCollectionHealthError {
411    fn create_unhandled_error(
412        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
413        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
414    ) -> Self {
415        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
416            source,
417            meta: meta.unwrap_or_default(),
418        })
419    }
420}
421impl ::aws_types::request_id::RequestId for crate::operation::describe_resource_collection_health::DescribeResourceCollectionHealthError {
422    fn request_id(&self) -> Option<&str> {
423        self.meta().request_id()
424    }
425}
426
427pub use crate::operation::describe_resource_collection_health::_describe_resource_collection_health_input::DescribeResourceCollectionHealthInput;
428
429pub use crate::operation::describe_resource_collection_health::_describe_resource_collection_health_output::DescribeResourceCollectionHealthOutput;
430
431mod _describe_resource_collection_health_input;
432
433mod _describe_resource_collection_health_output;
434
435/// Builders
436pub mod builders;
437
438/// Paginator for this operation
439pub mod paginator;
aws_sdk_devopsguru/operation/describe_resource_collection_health.rs

aws_sdk_devopsguru/operation/
describe_resource_collection_health.rs
