aws_sdk_pcs/operation/
update_queue.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `UpdateQueue`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct UpdateQueue;
6impl UpdateQueue {
7    /// Creates a new `UpdateQueue`
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::update_queue::UpdateQueueInput,
14    ) -> ::std::result::Result<
15        crate::operation::update_queue::UpdateQueueOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::update_queue::UpdateQueueError,
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::update_queue::UpdateQueueError>()
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::update_queue::UpdateQueueOutput>()
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::update_queue::UpdateQueueInput,
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("PCS", "UpdateQueue", 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                "PCS.UpdateQueue",
59                "rpc.service" = "PCS",
60                "rpc.method" = "UpdateQueue",
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        runtime_plugins = runtime_plugins.with_operation_plugin(crate::client_idempotency_token::IdempotencyTokenRuntimePlugin::new(
74            |token_provider, input| {
75                let input: &mut crate::operation::update_queue::UpdateQueueInput = input.downcast_mut().expect("correct type");
76                if input.client_token.is_none() {
77                    input.client_token = ::std::option::Option::Some(token_provider.make_idempotency_token());
78                }
79            },
80        ));
81        if let ::std::option::Option::Some(config_override) = config_override {
82            for plugin in config_override.runtime_plugins.iter().cloned() {
83                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
84            }
85            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
86                config_override,
87                client_config.config.clone(),
88                &client_config.runtime_components,
89            ));
90        }
91        runtime_plugins
92    }
93}
94impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for UpdateQueue {
95    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
96        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("UpdateQueue");
97
98        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
99            UpdateQueueRequestSerializer,
100        ));
101        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
102            UpdateQueueResponseDeserializer,
103        ));
104
105        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
106            crate::config::auth::Params::builder()
107                .operation_name("UpdateQueue")
108                .build()
109                .expect("required fields set"),
110        ));
111
112        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new("UpdateQueue", "PCS"));
113        let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
114        signing_options.double_uri_encode = true;
115        signing_options.content_sha256_header = false;
116        signing_options.normalize_uri_path = true;
117        signing_options.payload_override = None;
118
119        cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
120            signing_options,
121            ..::std::default::Default::default()
122        });
123
124        ::std::option::Option::Some(cfg.freeze())
125    }
126
127    fn runtime_components(
128        &self,
129        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
130    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
131        #[allow(unused_mut)]
132        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("UpdateQueue")
133            .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
134            .with_interceptor(UpdateQueueEndpointParamsInterceptor)
135            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
136                crate::operation::update_queue::UpdateQueueError,
137            >::new())
138            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
139                crate::operation::update_queue::UpdateQueueError,
140            >::new())
141            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
142                crate::operation::update_queue::UpdateQueueError,
143            >::new());
144
145        ::std::borrow::Cow::Owned(rcb)
146    }
147}
148
149#[derive(Debug)]
150struct UpdateQueueResponseDeserializer;
151impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for UpdateQueueResponseDeserializer {
152    fn deserialize_nonstreaming(
153        &self,
154        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
155    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
156        let (success, status) = (response.status().is_success(), response.status().as_u16());
157        let headers = response.headers();
158        let body = response.body().bytes().expect("body loaded");
159        #[allow(unused_mut)]
160        let mut force_error = false;
161        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
162        let parse_result = if !success && status != 200 || force_error {
163            crate::protocol_serde::shape_update_queue::de_update_queue_http_error(status, headers, body)
164        } else {
165            crate::protocol_serde::shape_update_queue::de_update_queue_http_response(status, headers, body)
166        };
167        crate::protocol_serde::type_erase_result(parse_result)
168    }
169}
170#[derive(Debug)]
171struct UpdateQueueRequestSerializer;
172impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for UpdateQueueRequestSerializer {
173    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
174    fn serialize_input(
175        &self,
176        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
177        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
178    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
179        let input = input
180            .downcast::<crate::operation::update_queue::UpdateQueueInput>()
181            .expect("correct type");
182        let _header_serialization_settings = _cfg
183            .load::<crate::serialization_settings::HeaderSerializationSettings>()
184            .cloned()
185            .unwrap_or_default();
186        let mut request_builder = {
187            #[allow(clippy::uninlined_format_args)]
188            fn uri_base(
189                _input: &crate::operation::update_queue::UpdateQueueInput,
190                output: &mut ::std::string::String,
191            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
192                use ::std::fmt::Write as _;
193                ::std::write!(output, "/").expect("formatting should succeed");
194                ::std::result::Result::Ok(())
195            }
196            #[allow(clippy::unnecessary_wraps)]
197            fn update_http_builder(
198                input: &crate::operation::update_queue::UpdateQueueInput,
199                builder: ::http::request::Builder,
200            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
201                let mut uri = ::std::string::String::new();
202                uri_base(input, &mut uri)?;
203                ::std::result::Result::Ok(builder.method("POST").uri(uri))
204            }
205            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
206            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.0");
207            builder = _header_serialization_settings.set_default_header(
208                builder,
209                ::http::header::HeaderName::from_static("x-amz-target"),
210                "AWSParallelComputingService.UpdateQueue",
211            );
212            builder
213        };
214        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_update_queue::ser_update_queue_input(&input)?);
215        if let Some(content_length) = body.content_length() {
216            let content_length = content_length.to_string();
217            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
218        }
219        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
220    }
221}
222#[derive(Debug)]
223struct UpdateQueueEndpointParamsInterceptor;
224
225impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateQueueEndpointParamsInterceptor {
226    fn name(&self) -> &'static str {
227        "UpdateQueueEndpointParamsInterceptor"
228    }
229
230    fn read_before_execution(
231        &self,
232        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
233            '_,
234            ::aws_smithy_runtime_api::client::interceptors::context::Input,
235            ::aws_smithy_runtime_api::client::interceptors::context::Output,
236            ::aws_smithy_runtime_api::client::interceptors::context::Error,
237        >,
238        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
239    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
240        let _input = context
241            .input()
242            .downcast_ref::<UpdateQueueInput>()
243            .ok_or("failed to downcast to UpdateQueueInput")?;
244
245        let params = crate::config::endpoint::Params::builder()
246            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
247            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
248            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
249            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
250            .build()
251            .map_err(|err| {
252                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
253            })?;
254        cfg.interceptor_state()
255            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
256        ::std::result::Result::Ok(())
257    }
258}
259
260// The get_* functions below are generated from JMESPath expressions in the
261// operationContextParams trait. They target the operation's input shape.
262
263/// Error type for the `UpdateQueueError` operation.
264#[non_exhaustive]
265#[derive(::std::fmt::Debug)]
266pub enum UpdateQueueError {
267    /// <p>You don't have permission to perform the action.</p>
268    /// <p><u>Examples</u></p>
269    /// <ul>
270    /// <li>
271    /// <p>The launch template instance profile doesn't pass <code>iam:PassRole</code> verification.</p></li>
272    /// <li>
273    /// <p>There is a mismatch between the account ID and cluster ID.</p></li>
274    /// <li>
275    /// <p>The cluster ID doesn't exist.</p></li>
276    /// <li>
277    /// <p>The EC2 instance isn't present.</p></li>
278    /// </ul>
279    AccessDeniedException(crate::types::error::AccessDeniedException),
280    /// <p>Your request has conflicting operations. This can occur if you're trying to perform more than 1 operation on the same resource at the same time.</p>
281    /// <p><u>Examples</u></p>
282    /// <ul>
283    /// <li>
284    /// <p>A cluster with the same name already exists.</p></li>
285    /// <li>
286    /// <p>A cluster isn't in <code>ACTIVE</code> status.</p></li>
287    /// <li>
288    /// <p>A cluster to delete is in an unstable state. For example, because it still has <code>ACTIVE</code> node groups or queues.</p></li>
289    /// <li>
290    /// <p>A queue already exists in a cluster.</p></li>
291    /// </ul>
292    ConflictException(crate::types::error::ConflictException),
293    /// <p>PCS can't process your request right now. Try again later.</p>
294    InternalServerException(crate::types::error::InternalServerException),
295    /// <p>The requested resource can't be found. The cluster, node group, or queue you're attempting to get, update, list, or delete doesn't exist.</p>
296    /// <p><u>Examples</u></p>
297    ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
298    /// <p>You exceeded your service quota. Service quotas, also referred to as limits, are the maximum number of service resources or operations for your Amazon Web Services account. To learn how to increase your service quota, see <a href="https://docs.aws.amazon.com/servicequotas/latest/userguide/request-quota-increase.html">Requesting a quota increase</a> in the <i>Service Quotas User Guide</i></p>
299    /// <p><u>Examples</u></p>
300    /// <ul>
301    /// <li>
302    /// <p>The max number of clusters or queues has been reached for the account.</p></li>
303    /// <li>
304    /// <p>The max number of compute node groups has been reached for the associated cluster.</p></li>
305    /// <li>
306    /// <p>The total of <code>maxInstances</code> across all compute node groups has been reached for associated cluster.</p></li>
307    /// </ul>
308    ServiceQuotaExceededException(crate::types::error::ServiceQuotaExceededException),
309    /// <p>Your request exceeded a request rate quota. Check the resource's request rate quota and try again.</p>
310    ThrottlingException(crate::types::error::ThrottlingException),
311    /// <p>The request isn't valid.</p>
312    /// <p><u>Examples</u></p>
313    /// <ul>
314    /// <li>
315    /// <p>Your request contains malformed JSON or unsupported characters.</p></li>
316    /// <li>
317    /// <p>The scheduler version isn't supported.</p></li>
318    /// <li>
319    /// <p>There are networking related errors, such as network validation failure.</p></li>
320    /// <li>
321    /// <p>AMI type is <code>CUSTOM</code> and the launch template doesn't define the AMI ID, or the AMI type is AL2 and the launch template defines the AMI.</p></li>
322    /// </ul>
323    ValidationException(crate::types::error::ValidationException),
324    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
325    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
326    variable wildcard pattern and check `.code()`:
327     \
328    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
329     \
330    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-UpdateQueueError) for what information is available for the error.")]
331    Unhandled(crate::error::sealed_unhandled::Unhandled),
332}
333impl UpdateQueueError {
334    /// Creates the `UpdateQueueError::Unhandled` variant from any error type.
335    pub fn unhandled(
336        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
337    ) -> Self {
338        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
339            source: err.into(),
340            meta: ::std::default::Default::default(),
341        })
342    }
343
344    /// Creates the `UpdateQueueError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
345    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
346        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
347            source: err.clone().into(),
348            meta: err,
349        })
350    }
351    ///
352    /// Returns error metadata, which includes the error code, message,
353    /// request ID, and potentially additional information.
354    ///
355    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
356        match self {
357            Self::AccessDeniedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
358            Self::ConflictException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
359            Self::InternalServerException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
360            Self::ResourceNotFoundException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
361            Self::ServiceQuotaExceededException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
362            Self::ThrottlingException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
363            Self::ValidationException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
364            Self::Unhandled(e) => &e.meta,
365        }
366    }
367    /// Returns `true` if the error kind is `UpdateQueueError::AccessDeniedException`.
368    pub fn is_access_denied_exception(&self) -> bool {
369        matches!(self, Self::AccessDeniedException(_))
370    }
371    /// Returns `true` if the error kind is `UpdateQueueError::ConflictException`.
372    pub fn is_conflict_exception(&self) -> bool {
373        matches!(self, Self::ConflictException(_))
374    }
375    /// Returns `true` if the error kind is `UpdateQueueError::InternalServerException`.
376    pub fn is_internal_server_exception(&self) -> bool {
377        matches!(self, Self::InternalServerException(_))
378    }
379    /// Returns `true` if the error kind is `UpdateQueueError::ResourceNotFoundException`.
380    pub fn is_resource_not_found_exception(&self) -> bool {
381        matches!(self, Self::ResourceNotFoundException(_))
382    }
383    /// Returns `true` if the error kind is `UpdateQueueError::ServiceQuotaExceededException`.
384    pub fn is_service_quota_exceeded_exception(&self) -> bool {
385        matches!(self, Self::ServiceQuotaExceededException(_))
386    }
387    /// Returns `true` if the error kind is `UpdateQueueError::ThrottlingException`.
388    pub fn is_throttling_exception(&self) -> bool {
389        matches!(self, Self::ThrottlingException(_))
390    }
391    /// Returns `true` if the error kind is `UpdateQueueError::ValidationException`.
392    pub fn is_validation_exception(&self) -> bool {
393        matches!(self, Self::ValidationException(_))
394    }
395}
396impl ::std::error::Error for UpdateQueueError {
397    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
398        match self {
399            Self::AccessDeniedException(_inner) => ::std::option::Option::Some(_inner),
400            Self::ConflictException(_inner) => ::std::option::Option::Some(_inner),
401            Self::InternalServerException(_inner) => ::std::option::Option::Some(_inner),
402            Self::ResourceNotFoundException(_inner) => ::std::option::Option::Some(_inner),
403            Self::ServiceQuotaExceededException(_inner) => ::std::option::Option::Some(_inner),
404            Self::ThrottlingException(_inner) => ::std::option::Option::Some(_inner),
405            Self::ValidationException(_inner) => ::std::option::Option::Some(_inner),
406            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
407        }
408    }
409}
410impl ::std::fmt::Display for UpdateQueueError {
411    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
412        match self {
413            Self::AccessDeniedException(_inner) => _inner.fmt(f),
414            Self::ConflictException(_inner) => _inner.fmt(f),
415            Self::InternalServerException(_inner) => _inner.fmt(f),
416            Self::ResourceNotFoundException(_inner) => _inner.fmt(f),
417            Self::ServiceQuotaExceededException(_inner) => _inner.fmt(f),
418            Self::ThrottlingException(_inner) => _inner.fmt(f),
419            Self::ValidationException(_inner) => _inner.fmt(f),
420            Self::Unhandled(_inner) => {
421                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
422                    write!(f, "unhandled error ({code})")
423                } else {
424                    f.write_str("unhandled error")
425                }
426            }
427        }
428    }
429}
430impl ::aws_smithy_types::retry::ProvideErrorKind for UpdateQueueError {
431    fn code(&self) -> ::std::option::Option<&str> {
432        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
433    }
434    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
435        match self {
436            Self::InternalServerException(inner) => ::std::option::Option::Some(inner.retryable_error_kind()),
437            Self::ThrottlingException(inner) => ::std::option::Option::Some(inner.retryable_error_kind()),
438            _ => ::std::option::Option::None,
439        }
440    }
441}
442impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for UpdateQueueError {
443    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
444        match self {
445            Self::AccessDeniedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
446            Self::ConflictException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
447            Self::InternalServerException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
448            Self::ResourceNotFoundException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
449            Self::ServiceQuotaExceededException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
450            Self::ThrottlingException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
451            Self::ValidationException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
452            Self::Unhandled(_inner) => &_inner.meta,
453        }
454    }
455}
456impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for UpdateQueueError {
457    fn create_unhandled_error(
458        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
459        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
460    ) -> Self {
461        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
462            source,
463            meta: meta.unwrap_or_default(),
464        })
465    }
466}
467impl ::aws_types::request_id::RequestId for crate::operation::update_queue::UpdateQueueError {
468    fn request_id(&self) -> Option<&str> {
469        self.meta().request_id()
470    }
471}
472
473pub use crate::operation::update_queue::_update_queue_output::UpdateQueueOutput;
474
475pub use crate::operation::update_queue::_update_queue_input::UpdateQueueInput;
476
477mod _update_queue_input;
478
479mod _update_queue_output;
480
481/// Builders
482pub mod builders;
aws_sdk_pcs/operation/update_queue.rs

aws_sdk_pcs/operation/
update_queue.rs
