1#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct UpdateConnectionAliasPermission;
6impl UpdateConnectionAliasPermission {
7 pub fn new() -> Self {
9 Self
10 }
11 pub const INPUT_SCHEMA: &'static ::aws_smithy_schema::Schema<'static> =
13 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionInput::SCHEMA;
14 pub const OUTPUT_SCHEMA: &'static ::aws_smithy_schema::Schema<'static> =
16 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionOutput::SCHEMA;
17 pub(crate) async fn orchestrate(
18 runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
19 input: crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionInput,
20 ) -> ::std::result::Result<
21 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionOutput,
22 ::aws_smithy_runtime_api::client::result::SdkError<
23 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError,
24 ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
25 >,
26 > {
27 let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
28 ::aws_smithy_runtime_api::client::interceptors::context::Error,
29 ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
30 >| {
31 err.map_service_error(|err| {
32 err.downcast::<crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError>()
33 .expect("correct error type")
34 })
35 };
36 let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
37 .await
38 .map_err(map_err)?;
39 let output = context.finalize().map_err(map_err)?;
40 ::std::result::Result::Ok(
41 output
42 .downcast::<crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionOutput>()
43 .expect("correct output type"),
44 )
45 }
46
47 pub(crate) async fn orchestrate_with_stop_point(
48 runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
49 input: crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionInput,
50 stop_point: ::aws_smithy_runtime::client::orchestrator::StopPoint,
51 ) -> ::std::result::Result<
52 ::aws_smithy_runtime_api::client::interceptors::context::InterceptorContext,
53 ::aws_smithy_runtime_api::client::result::SdkError<
54 ::aws_smithy_runtime_api::client::interceptors::context::Error,
55 ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
56 >,
57 > {
58 let input = ::aws_smithy_runtime_api::client::interceptors::context::Input::erase(input);
59 use ::tracing::Instrument;
60 ::aws_smithy_runtime::client::orchestrator::invoke_with_stop_point(
61 "WorkSpaces",
62 "UpdateConnectionAliasPermission",
63 input,
64 runtime_plugins,
65 stop_point,
66 )
67 .instrument(::tracing::debug_span!(
70 "WorkSpaces.UpdateConnectionAliasPermission",
71 "rpc.service" = "WorkSpaces",
72 "rpc.method" = "UpdateConnectionAliasPermission",
73 "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
74 "rpc.system" = "aws-api",
75 ))
76 .await
77 }
78
79 pub(crate) fn operation_runtime_plugins(
80 client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
81 client_config: &crate::config::Config,
82 config_override: ::std::option::Option<crate::config::Builder>,
83 ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
84 let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
85
86 if let ::std::option::Option::Some(config_override) = config_override {
87 for plugin in config_override.runtime_plugins.iter().cloned() {
88 runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
89 }
90 runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
91 config_override,
92 client_config.config.clone(),
93 &client_config.runtime_components,
94 ));
95 }
96 runtime_plugins
97 }
98}
99pub(crate) mod error_registry {
108 pub(crate) static REGISTRY: ::std::sync::LazyLock<::aws_smithy_schema::registry::TypeRegistry> = ::std::sync::LazyLock::new(|| {
109 ::aws_smithy_schema::registry::TypeRegistry::builder()
110 .insert_error_shape(
111 crate::types::error::AccessDeniedException::SCHEMA,
112 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::aws_smithy_types::type_erasure::TypeErasedBox, ::aws_smithy_schema::serde::SerdeError> {
113 ::std::result::Result::Ok(::aws_smithy_types::type_erasure::TypeErasedBox::new(crate::types::error::AccessDeniedException::deserialize(d)?))
114 },
115 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync>, ::aws_smithy_schema::serde::SerdeError> {
116 ::std::result::Result::Ok(::std::boxed::Box::new(crate::types::error::AccessDeniedException::deserialize(d)?))
117 },
118 )
119.insert_error_shape(
120 crate::types::error::InvalidParameterValuesException::SCHEMA,
121 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::aws_smithy_types::type_erasure::TypeErasedBox, ::aws_smithy_schema::serde::SerdeError> {
122 ::std::result::Result::Ok(::aws_smithy_types::type_erasure::TypeErasedBox::new(crate::types::error::InvalidParameterValuesException::deserialize(d)?))
123 },
124 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync>, ::aws_smithy_schema::serde::SerdeError> {
125 ::std::result::Result::Ok(::std::boxed::Box::new(crate::types::error::InvalidParameterValuesException::deserialize(d)?))
126 },
127 )
128.insert_error_shape(
129 crate::types::error::InvalidResourceStateException::SCHEMA,
130 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::aws_smithy_types::type_erasure::TypeErasedBox, ::aws_smithy_schema::serde::SerdeError> {
131 ::std::result::Result::Ok(::aws_smithy_types::type_erasure::TypeErasedBox::new(crate::types::error::InvalidResourceStateException::deserialize(d)?))
132 },
133 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync>, ::aws_smithy_schema::serde::SerdeError> {
134 ::std::result::Result::Ok(::std::boxed::Box::new(crate::types::error::InvalidResourceStateException::deserialize(d)?))
135 },
136 )
137.insert_error_shape(
138 crate::types::error::OperationNotSupportedException::SCHEMA,
139 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::aws_smithy_types::type_erasure::TypeErasedBox, ::aws_smithy_schema::serde::SerdeError> {
140 ::std::result::Result::Ok(::aws_smithy_types::type_erasure::TypeErasedBox::new(crate::types::error::OperationNotSupportedException::deserialize(d)?))
141 },
142 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync>, ::aws_smithy_schema::serde::SerdeError> {
143 ::std::result::Result::Ok(::std::boxed::Box::new(crate::types::error::OperationNotSupportedException::deserialize(d)?))
144 },
145 )
146.insert_error_shape(
147 crate::types::error::ResourceAssociatedException::SCHEMA,
148 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::aws_smithy_types::type_erasure::TypeErasedBox, ::aws_smithy_schema::serde::SerdeError> {
149 ::std::result::Result::Ok(::aws_smithy_types::type_erasure::TypeErasedBox::new(crate::types::error::ResourceAssociatedException::deserialize(d)?))
150 },
151 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync>, ::aws_smithy_schema::serde::SerdeError> {
152 ::std::result::Result::Ok(::std::boxed::Box::new(crate::types::error::ResourceAssociatedException::deserialize(d)?))
153 },
154 )
155.insert_error_shape(
156 crate::types::error::ResourceLimitExceededException::SCHEMA,
157 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::aws_smithy_types::type_erasure::TypeErasedBox, ::aws_smithy_schema::serde::SerdeError> {
158 ::std::result::Result::Ok(::aws_smithy_types::type_erasure::TypeErasedBox::new(crate::types::error::ResourceLimitExceededException::deserialize(d)?))
159 },
160 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync>, ::aws_smithy_schema::serde::SerdeError> {
161 ::std::result::Result::Ok(::std::boxed::Box::new(crate::types::error::ResourceLimitExceededException::deserialize(d)?))
162 },
163 )
164.insert_error_shape(
165 crate::types::error::ResourceNotFoundException::SCHEMA,
166 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::aws_smithy_types::type_erasure::TypeErasedBox, ::aws_smithy_schema::serde::SerdeError> {
167 ::std::result::Result::Ok(::aws_smithy_types::type_erasure::TypeErasedBox::new(crate::types::error::ResourceNotFoundException::deserialize(d)?))
168 },
169 |d: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer| -> ::std::result::Result<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync>, ::aws_smithy_schema::serde::SerdeError> {
170 ::std::result::Result::Ok(::std::boxed::Box::new(crate::types::error::ResourceNotFoundException::deserialize(d)?))
171 },
172 )
173 .build()
174 });
175}
176impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for UpdateConnectionAliasPermission {
177 fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
178 let mut cfg = ::aws_smithy_types::config_bag::Layer::new("UpdateConnectionAliasPermission");
179
180 cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
181 UpdateConnectionAliasPermissionRequestSerializer,
182 ));
183 cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
184 UpdateConnectionAliasPermissionResponseDeserializer,
185 ));
186
187 cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
188 crate::config::auth::Params::builder()
189 .operation_name("UpdateConnectionAliasPermission")
190 .build()
191 .expect("required fields set"),
192 ));
193
194 cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
195 "UpdateConnectionAliasPermission",
196 "WorkSpaces",
197 ));
198 let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
199 signing_options.double_uri_encode = true;
200 signing_options.content_sha256_header = false;
201 signing_options.normalize_uri_path = true;
202 signing_options.payload_override = None;
203
204 cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
205 signing_options,
206 ..::std::default::Default::default()
207 });
208
209 ::std::option::Option::Some(cfg.freeze())
210 }
211
212 fn runtime_components(
213 &self,
214 _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
215 ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
216 #[allow(unused_mut)]
217 let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("UpdateConnectionAliasPermission")
218 .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
219 UpdateConnectionAliasPermissionTelemetryInputCaptureInterceptor,
220 ))
221 .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
222 ::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default(),
223 ))
224 .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
225 UpdateConnectionAliasPermissionEndpointParamsInterceptor,
226 ))
227 .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
228 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError,
229 >::new())
230 .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
231 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError,
232 >::new())
233 .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
234 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError,
235 >::new())
236 .with_retry_classifier(::aws_runtime::service_clock_skew::ServiceClockSkewClassifier::<
237 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError,
238 >::new());
239
240 ::std::borrow::Cow::Owned(rcb)
241 }
242}
243
244#[derive(Debug)]
245struct UpdateConnectionAliasPermissionTelemetryInputCaptureInterceptor;
246
247#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
248impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateConnectionAliasPermissionTelemetryInputCaptureInterceptor {
249 fn name(&self) -> &'static str {
250 "UpdateConnectionAliasPermissionTelemetryInputCaptureInterceptor"
251 }
252
253 fn read_before_execution(
254 &self,
255 context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
256 '_,
257 ::aws_smithy_runtime_api::client::interceptors::context::Input,
258 ::aws_smithy_runtime_api::client::interceptors::context::Output,
259 ::aws_smithy_runtime_api::client::interceptors::context::Error,
260 >,
261 cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
262 ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
263 let ::std::option::Option::Some(requested) = cfg
265 .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
266 .filter(|r| !r.is_empty())
267 else {
268 return ::std::result::Result::Ok(());
269 };
270
271 let ::std::option::Option::Some(input) = context.input().downcast_ref::<UpdateConnectionAliasPermissionInput>() else {
272 return ::std::result::Result::Ok(());
274 };
275
276 let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
277 if requested.should_capture("AliasId") {
278 if let ::std::option::Option::Some(value) = input.alias_id.as_deref() {
279 captured.insert("AliasId", value);
280 }
281 }
282
283 cfg.interceptor_state().store_put(captured);
284 ::std::result::Result::Ok(())
285 }
286}
287#[derive(Debug)]
288struct UpdateConnectionAliasPermissionResponseDeserializer;
289impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for UpdateConnectionAliasPermissionResponseDeserializer {
290 fn deserialize_nonstreaming_with_config(
291 &self,
292 response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
293 _cfg: &::aws_smithy_types::config_bag::ConfigBag,
294 ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
295 let (success, status) = (response.status().is_success(), response.status().as_u16());
296 #[allow(unused_variables)]
301 let body = response.body().bytes().expect("body loaded");
302 let headers = response.headers();
303 #[allow(unused_mut)]
304 let mut force_error = false;
305 ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
306 if !success && status != 200 || force_error {
307 let protocol = _cfg
308 .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
309 .expect("a SharedClientProtocol is required");
310 #[allow(unused_mut)]
311 let mut generic_builder = protocol.parse_error_metadata(response, _cfg).map_err(|e| {
312 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(::aws_smithy_runtime_api::box_error::BoxError::from(e))
313 })?;
314 generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, headers);
315 let generic = generic_builder.build();
316 let error_code = match generic.code() {
317 ::std::option::Option::Some(code) => code,
318 ::std::option::Option::None => {
319 return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
320 ::aws_smithy_runtime_api::box_error::BoxError::from(
321 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError::unhandled(generic),
322 ),
323 ))
324 }
325 };
326 let _error_message = generic.message().map(|msg| msg.to_owned());
327 let err = match error_code {
328 "AccessDeniedException" => {
329 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError::AccessDeniedException({
330 let mut deser = protocol.deserialize_error_response(response, _cfg).map_err(|e| {
331 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
332 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
333 )
334 })?;
335 let mut tmp = <crate::types::error::builders::AccessDeniedExceptionBuilder>::default();
336 tmp.deserialize_members(&mut *deser).map_err(|e| {
337 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
338 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
339 )
340 })?;
341 if tmp.message.is_none() {
342 tmp.message = _error_message;
343 }
344 let tmp = tmp.meta(generic);
345 tmp.build()
346 })
347 }
348 "InvalidParameterValuesException" => {
349 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError::InvalidParameterValuesException({
350 let mut deser = protocol.deserialize_error_response(response, _cfg).map_err(|e| {
351 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
352 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
353 )
354 })?;
355 let mut tmp = <crate::types::error::builders::InvalidParameterValuesExceptionBuilder>::default();
356 tmp.deserialize_members(&mut *deser).map_err(|e| {
357 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
358 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
359 )
360 })?;
361 if tmp.message.is_none() {
362 tmp.message = _error_message;
363 }
364 let tmp = tmp.meta(generic);
365 tmp.build()
366 })
367 }
368 "InvalidResourceStateException" => {
369 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError::InvalidResourceStateException({
370 let mut deser = protocol.deserialize_error_response(response, _cfg).map_err(|e| {
371 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
372 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
373 )
374 })?;
375 let mut tmp = <crate::types::error::builders::InvalidResourceStateExceptionBuilder>::default();
376 tmp.deserialize_members(&mut *deser).map_err(|e| {
377 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
378 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
379 )
380 })?;
381 if tmp.message.is_none() {
382 tmp.message = _error_message;
383 }
384 let tmp = tmp.meta(generic);
385 tmp.build()
386 })
387 }
388 "OperationNotSupportedException" => {
389 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError::OperationNotSupportedException({
390 let mut deser = protocol.deserialize_error_response(response, _cfg).map_err(|e| {
391 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
392 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
393 )
394 })?;
395 let mut tmp = <crate::types::error::builders::OperationNotSupportedExceptionBuilder>::default();
396 tmp.deserialize_members(&mut *deser).map_err(|e| {
397 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
398 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
399 )
400 })?;
401 if tmp.message.is_none() {
402 tmp.message = _error_message;
403 }
404 let tmp = tmp.meta(generic);
405 tmp.build()
406 })
407 }
408 "ResourceAssociatedException" => {
409 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError::ResourceAssociatedException({
410 let mut deser = protocol.deserialize_error_response(response, _cfg).map_err(|e| {
411 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
412 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
413 )
414 })?;
415 let mut tmp = <crate::types::error::builders::ResourceAssociatedExceptionBuilder>::default();
416 tmp.deserialize_members(&mut *deser).map_err(|e| {
417 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
418 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
419 )
420 })?;
421 if tmp.message.is_none() {
422 tmp.message = _error_message;
423 }
424 let tmp = tmp.meta(generic);
425 tmp.build()
426 })
427 }
428 "ResourceLimitExceededException" => {
429 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError::ResourceLimitExceededException({
430 let mut deser = protocol.deserialize_error_response(response, _cfg).map_err(|e| {
431 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
432 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
433 )
434 })?;
435 let mut tmp = <crate::types::error::builders::ResourceLimitExceededExceptionBuilder>::default();
436 tmp.deserialize_members(&mut *deser).map_err(|e| {
437 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
438 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
439 )
440 })?;
441 if tmp.message.is_none() {
442 tmp.message = _error_message;
443 }
444 let tmp = tmp.meta(generic);
445 tmp.build()
446 })
447 }
448 "ResourceNotFoundException" => {
449 crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError::ResourceNotFoundException({
450 let mut deser = protocol.deserialize_error_response(response, _cfg).map_err(|e| {
451 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
452 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
453 )
454 })?;
455 let mut tmp = <crate::types::error::builders::ResourceNotFoundExceptionBuilder>::default();
456 tmp.deserialize_members(&mut *deser).map_err(|e| {
457 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
458 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
459 )
460 })?;
461 if tmp.message.is_none() {
462 tmp.message = _error_message;
463 }
464 let tmp = tmp.meta(generic);
465 tmp.build()
466 })
467 }
468 _ => {
469 match protocol
477 .deserialize_error_response(response, _cfg)
478 .ok()
479 .and_then(|mut deser| {
480 ::aws_smithy_schema::registry::reify_error(
481 crate::operation::update_connection_alias_permission::error_registry::REGISTRY
482 .or(&crate::error_type_registry::REGISTRY),
483 error_code,
484 &mut *deser,
485 )
486 }) {
487 ::std::option::Option::Some(source) => <crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError as ::aws_smithy_runtime_api::client::result::CreateUnhandledError>::create_unhandled_error(source, ::std::option::Option::Some(generic)),
488 ::std::option::Option::None => crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError::generic(generic),
489 }
490 }
491 };
492 ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::operation(
493 ::aws_smithy_runtime_api::client::interceptors::context::Error::erase(err),
494 ))
495 } else {
496 let protocol = _cfg
497 .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
498 .expect("a SharedClientProtocol is required");
499 let mut deser = protocol
500 .deserialize_response(response, UpdateConnectionAliasPermission::OUTPUT_SCHEMA, _cfg)
501 .map_err(|e| {
502 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(::aws_smithy_runtime_api::box_error::BoxError::from(e))
503 })?;
504 let _response_headers = headers;
508 #[allow(unused_mut)]
512 let mut output =
513 <crate::operation::update_connection_alias_permission::builders::UpdateConnectionAliasPermissionOutputBuilder>::default();
514 output.deserialize_members(&mut *deser).map_err(|e| {
515 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(::aws_smithy_runtime_api::box_error::BoxError::from(e))
516 })?;
517 output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
518 let output = output.build();
519 ::std::result::Result::Ok(::aws_smithy_runtime_api::client::interceptors::context::Output::erase(output))
520 }
521 }
522}
523#[derive(Debug)]
524struct UpdateConnectionAliasPermissionRequestSerializer;
525impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for UpdateConnectionAliasPermissionRequestSerializer {
526 #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
527 fn serialize_input(
528 &self,
529 input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
530 _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
531 ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
532 let input = input
533 .downcast::<crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionInput>()
534 .expect("correct type");
535
536 let protocol = _cfg
537 .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
538 .expect("a SharedClientProtocol is required");
539 let mut request = protocol
540 .serialize_request(&input, UpdateConnectionAliasPermission::INPUT_SCHEMA, "/", _cfg)
541 .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
542
543 return ::std::result::Result::Ok(request);
544 }
545}
546#[derive(Debug)]
547struct UpdateConnectionAliasPermissionEndpointParamsInterceptor;
548
549#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
550impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateConnectionAliasPermissionEndpointParamsInterceptor {
551 fn name(&self) -> &'static str {
552 "UpdateConnectionAliasPermissionEndpointParamsInterceptor"
553 }
554
555 fn read_before_execution(
556 &self,
557 context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
558 '_,
559 ::aws_smithy_runtime_api::client::interceptors::context::Input,
560 ::aws_smithy_runtime_api::client::interceptors::context::Output,
561 ::aws_smithy_runtime_api::client::interceptors::context::Error,
562 >,
563 cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
564 ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
565 let _input = context
566 .input()
567 .downcast_ref::<UpdateConnectionAliasPermissionInput>()
568 .ok_or("failed to downcast to UpdateConnectionAliasPermissionInput")?;
569
570 let params = crate::config::endpoint::Params::builder()
571 .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
572 .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
573 .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
574 .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
575 .build()
576 .map_err(|err| {
577 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
578 })?;
579 cfg.interceptor_state()
580 .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
581 ::std::result::Result::Ok(())
582 }
583}
584
585#[non_exhaustive]
590#[derive(::std::fmt::Debug)]
591pub enum UpdateConnectionAliasPermissionError {
592 AccessDeniedException(crate::types::error::AccessDeniedException),
594 InvalidParameterValuesException(crate::types::error::InvalidParameterValuesException),
596 InvalidResourceStateException(crate::types::error::InvalidResourceStateException),
598 OperationNotSupportedException(crate::types::error::OperationNotSupportedException),
600 ResourceAssociatedException(crate::types::error::ResourceAssociatedException),
602 ResourceLimitExceededException(crate::types::error::ResourceLimitExceededException),
604 ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
606 #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
608 variable wildcard pattern and check `.code()`:
609 \
610 `err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
611 \
612 See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-UpdateConnectionAliasPermissionError) for what information is available for the error.")]
613 Unhandled(crate::error::sealed_unhandled::Unhandled),
614}
615impl UpdateConnectionAliasPermissionError {
616 pub fn unhandled(
618 err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
619 ) -> Self {
620 Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
621 source: err.into(),
622 meta: ::std::default::Default::default(),
623 })
624 }
625
626 pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
628 Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
629 source: err.clone().into(),
630 meta: err,
631 })
632 }
633 pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
638 match self {
639 Self::AccessDeniedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
640 Self::InvalidParameterValuesException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
641 Self::InvalidResourceStateException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
642 Self::OperationNotSupportedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
643 Self::ResourceAssociatedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
644 Self::ResourceLimitExceededException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
645 Self::ResourceNotFoundException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
646 Self::Unhandled(e) => &e.meta,
647 }
648 }
649 pub fn is_access_denied_exception(&self) -> bool {
651 matches!(self, Self::AccessDeniedException(_))
652 }
653 pub fn is_invalid_parameter_values_exception(&self) -> bool {
655 matches!(self, Self::InvalidParameterValuesException(_))
656 }
657 pub fn is_invalid_resource_state_exception(&self) -> bool {
659 matches!(self, Self::InvalidResourceStateException(_))
660 }
661 pub fn is_operation_not_supported_exception(&self) -> bool {
663 matches!(self, Self::OperationNotSupportedException(_))
664 }
665 pub fn is_resource_associated_exception(&self) -> bool {
667 matches!(self, Self::ResourceAssociatedException(_))
668 }
669 pub fn is_resource_limit_exceeded_exception(&self) -> bool {
671 matches!(self, Self::ResourceLimitExceededException(_))
672 }
673 pub fn is_resource_not_found_exception(&self) -> bool {
675 matches!(self, Self::ResourceNotFoundException(_))
676 }
677}
678impl ::std::error::Error for UpdateConnectionAliasPermissionError {
679 fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
680 match self {
681 Self::AccessDeniedException(_inner) => ::std::option::Option::Some(_inner),
682 Self::InvalidParameterValuesException(_inner) => ::std::option::Option::Some(_inner),
683 Self::InvalidResourceStateException(_inner) => ::std::option::Option::Some(_inner),
684 Self::OperationNotSupportedException(_inner) => ::std::option::Option::Some(_inner),
685 Self::ResourceAssociatedException(_inner) => ::std::option::Option::Some(_inner),
686 Self::ResourceLimitExceededException(_inner) => ::std::option::Option::Some(_inner),
687 Self::ResourceNotFoundException(_inner) => ::std::option::Option::Some(_inner),
688 Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
689 }
690 }
691}
692impl ::std::fmt::Display for UpdateConnectionAliasPermissionError {
693 fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
694 match self {
695 Self::AccessDeniedException(_inner) => _inner.fmt(f),
696 Self::InvalidParameterValuesException(_inner) => _inner.fmt(f),
697 Self::InvalidResourceStateException(_inner) => _inner.fmt(f),
698 Self::OperationNotSupportedException(_inner) => _inner.fmt(f),
699 Self::ResourceAssociatedException(_inner) => _inner.fmt(f),
700 Self::ResourceLimitExceededException(_inner) => _inner.fmt(f),
701 Self::ResourceNotFoundException(_inner) => _inner.fmt(f),
702 Self::Unhandled(_inner) => {
703 if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
704 write!(f, "unhandled error ({code})")
705 } else {
706 f.write_str("unhandled error")
707 }
708 }
709 }
710 }
711}
712impl ::aws_smithy_types::retry::ProvideErrorKind for UpdateConnectionAliasPermissionError {
713 fn code(&self) -> ::std::option::Option<&str> {
714 ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
715 }
716 fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
717 ::std::option::Option::None
718 }
719}
720impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for UpdateConnectionAliasPermissionError {
721 fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
722 match self {
723 Self::AccessDeniedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
724 Self::InvalidParameterValuesException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
725 Self::InvalidResourceStateException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
726 Self::OperationNotSupportedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
727 Self::ResourceAssociatedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
728 Self::ResourceLimitExceededException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
729 Self::ResourceNotFoundException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
730 Self::Unhandled(_inner) => &_inner.meta,
731 }
732 }
733}
734impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for UpdateConnectionAliasPermissionError {
735 fn create_unhandled_error(
736 source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
737 meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
738 ) -> Self {
739 Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
740 source,
741 meta: meta.unwrap_or_default(),
742 })
743 }
744}
745impl ::aws_types::request_id::RequestId for crate::operation::update_connection_alias_permission::UpdateConnectionAliasPermissionError {
746 fn request_id(&self) -> Option<&str> {
747 self.meta().request_id()
748 }
749}
750
751pub use crate::operation::update_connection_alias_permission::_update_connection_alias_permission_input::UpdateConnectionAliasPermissionInput;
752
753pub use crate::operation::update_connection_alias_permission::_update_connection_alias_permission_output::UpdateConnectionAliasPermissionOutput;
754
755mod _update_connection_alias_permission_input;
756
757mod _update_connection_alias_permission_output;
758
759pub mod builders;