aws_sdk_lambda/operation/
update_event_source_mapping.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `UpdateEventSourceMapping`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct UpdateEventSourceMapping;
6impl UpdateEventSourceMapping {
7    /// Creates a new `UpdateEventSourceMapping`
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_event_source_mapping::UpdateEventSourceMappingInput,
14    ) -> ::std::result::Result<
15        crate::operation::update_event_source_mapping::UpdateEventSourceMappingOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::update_event_source_mapping::UpdateEventSourceMappingError,
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_event_source_mapping::UpdateEventSourceMappingError>()
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_event_source_mapping::UpdateEventSourceMappingOutput>()
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_event_source_mapping::UpdateEventSourceMappingInput,
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("Lambda", "UpdateEventSourceMapping", 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                "Lambda.UpdateEventSourceMapping",
59                "rpc.service" = "Lambda",
60                "rpc.method" = "UpdateEventSourceMapping",
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 UpdateEventSourceMapping {
88    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
89        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("UpdateEventSourceMapping");
90
91        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
92            UpdateEventSourceMappingRequestSerializer,
93        ));
94        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
95            UpdateEventSourceMappingResponseDeserializer,
96        ));
97
98        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
99            crate::config::auth::Params::builder()
100                .operation_name("UpdateEventSourceMapping")
101                .build()
102                .expect("required fields set"),
103        ));
104
105        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
106            "UpdateEventSourceMapping",
107            "Lambda",
108        ));
109        let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
110        signing_options.double_uri_encode = true;
111        signing_options.content_sha256_header = false;
112        signing_options.normalize_uri_path = true;
113        signing_options.payload_override = None;
114
115        cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
116            signing_options,
117            ..::std::default::Default::default()
118        });
119
120        ::std::option::Option::Some(cfg.freeze())
121    }
122
123    fn runtime_components(
124        &self,
125        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
126    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
127        #[allow(unused_mut)]
128        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("UpdateEventSourceMapping")
129            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
130                UpdateEventSourceMappingTelemetryInputCaptureInterceptor,
131            ))
132            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
133                ::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default(),
134            ))
135            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
136                UpdateEventSourceMappingEndpointParamsInterceptor,
137            ))
138            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
139                crate::operation::update_event_source_mapping::UpdateEventSourceMappingError,
140            >::new())
141            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
142                crate::operation::update_event_source_mapping::UpdateEventSourceMappingError,
143            >::new())
144            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
145                crate::operation::update_event_source_mapping::UpdateEventSourceMappingError,
146            >::new())
147            .with_retry_classifier(::aws_runtime::service_clock_skew::ServiceClockSkewClassifier::<
148                crate::operation::update_event_source_mapping::UpdateEventSourceMappingError,
149            >::new());
150
151        ::std::borrow::Cow::Owned(rcb)
152    }
153}
154
155#[derive(Debug)]
156struct UpdateEventSourceMappingTelemetryInputCaptureInterceptor;
157
158#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
159impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateEventSourceMappingTelemetryInputCaptureInterceptor {
160    fn name(&self) -> &'static str {
161        "UpdateEventSourceMappingTelemetryInputCaptureInterceptor"
162    }
163
164    fn read_before_execution(
165        &self,
166        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
167            '_,
168            ::aws_smithy_runtime_api::client::interceptors::context::Input,
169            ::aws_smithy_runtime_api::client::interceptors::context::Output,
170            ::aws_smithy_runtime_api::client::interceptors::context::Error,
171        >,
172        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
173    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
174        // Nothing to do unless the customer opted in by naming members to record.
175        let ::std::option::Option::Some(requested) = cfg
176            .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
177            .filter(|r| !r.is_empty())
178        else {
179            return ::std::result::Result::Ok(());
180        };
181
182        let ::std::option::Option::Some(input) = context.input().downcast_ref::<UpdateEventSourceMappingInput>() else {
183            // A mismatched input is not this interceptor's concern; skip quietly.
184            return ::std::result::Result::Ok(());
185        };
186
187        let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
188        if requested.should_capture("UUID") {
189            if let ::std::option::Option::Some(value) = input.uuid.as_deref() {
190                captured.insert("UUID", value);
191            }
192        }
193        if requested.should_capture("FunctionName") {
194            if let ::std::option::Option::Some(value) = input.function_name.as_deref() {
195                captured.insert("FunctionName", value);
196            }
197        }
198        if requested.should_capture("KMSKeyArn") {
199            if let ::std::option::Option::Some(value) = input.kms_key_arn.as_deref() {
200                captured.insert("KMSKeyArn", value);
201            }
202        }
203
204        cfg.interceptor_state().store_put(captured);
205        ::std::result::Result::Ok(())
206    }
207}
208#[derive(Debug)]
209struct UpdateEventSourceMappingResponseDeserializer;
210impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for UpdateEventSourceMappingResponseDeserializer {
211    fn deserialize_nonstreaming_with_config(
212        &self,
213        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
214        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
215    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
216        let (success, status) = (response.status().is_success(), response.status().as_u16());
217        let headers = response.headers();
218        let body = response.body().bytes().expect("body loaded");
219        #[allow(unused_mut)]
220        let mut force_error = false;
221        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
222        let parse_result = if !success && status != 202 || force_error {
223            crate::protocol_serde::shape_update_event_source_mapping::de_update_event_source_mapping_http_error(status, headers, body)
224        } else {
225            crate::protocol_serde::shape_update_event_source_mapping::de_update_event_source_mapping_http_response(status, headers, body)
226        };
227        crate::protocol_serde::type_erase_result(parse_result)
228    }
229}
230#[derive(Debug)]
231struct UpdateEventSourceMappingRequestSerializer;
232impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for UpdateEventSourceMappingRequestSerializer {
233    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
234    fn serialize_input(
235        &self,
236        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
237        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
238    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
239        let input = input
240            .downcast::<crate::operation::update_event_source_mapping::UpdateEventSourceMappingInput>()
241            .expect("correct type");
242        let _header_serialization_settings = _cfg
243            .load::<crate::serialization_settings::HeaderSerializationSettings>()
244            .cloned()
245            .unwrap_or_default();
246        let mut request_builder = {
247            #[allow(clippy::uninlined_format_args)]
248            fn uri_base(
249                _input: &crate::operation::update_event_source_mapping::UpdateEventSourceMappingInput,
250                output: &mut ::std::string::String,
251            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
252                use ::std::fmt::Write as _;
253                let input_1 = &_input.uuid;
254                let input_1 = input_1
255                    .as_ref()
256                    .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("uuid", "cannot be empty or unset"))?;
257                let uuid = ::aws_smithy_http::label::fmt_string(input_1, ::aws_smithy_http::label::EncodingStrategy::Default);
258                if uuid.is_empty() {
259                    return ::std::result::Result::Err(::aws_smithy_types::error::operation::BuildError::missing_field(
260                        "uuid",
261                        "cannot be empty or unset",
262                    ));
263                }
264                ::std::write!(output, "/2015-03-31/event-source-mappings/{UUID}", UUID = uuid).expect("formatting should succeed");
265                ::std::result::Result::Ok(())
266            }
267            #[allow(clippy::unnecessary_wraps)]
268            fn update_http_builder(
269                input: &crate::operation::update_event_source_mapping::UpdateEventSourceMappingInput,
270                builder: ::http_1x::request::Builder,
271            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
272                let mut uri = ::std::string::String::new();
273                uri_base(input, &mut uri)?;
274                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
275            }
276            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
277            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/json");
278            builder
279        };
280        let body = ::aws_smithy_types::body::SdkBody::from(
281            crate::protocol_serde::shape_update_event_source_mapping::ser_update_event_source_mapping_input(&input)?,
282        );
283        if let Some(content_length) = body.content_length() {
284            let content_length = content_length.to_string();
285            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
286        }
287        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
288    }
289}
290#[derive(Debug)]
291struct UpdateEventSourceMappingEndpointParamsInterceptor;
292
293#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
294impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateEventSourceMappingEndpointParamsInterceptor {
295    fn name(&self) -> &'static str {
296        "UpdateEventSourceMappingEndpointParamsInterceptor"
297    }
298
299    fn read_before_execution(
300        &self,
301        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
302            '_,
303            ::aws_smithy_runtime_api::client::interceptors::context::Input,
304            ::aws_smithy_runtime_api::client::interceptors::context::Output,
305            ::aws_smithy_runtime_api::client::interceptors::context::Error,
306        >,
307        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
308    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
309        let _input = context
310            .input()
311            .downcast_ref::<UpdateEventSourceMappingInput>()
312            .ok_or("failed to downcast to UpdateEventSourceMappingInput")?;
313
314        let params = crate::config::endpoint::Params::builder()
315            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
316            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
317            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
318            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
319            .build()
320            .map_err(|err| {
321                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
322            })?;
323        cfg.interceptor_state()
324            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
325        ::std::result::Result::Ok(())
326    }
327}
328
329// The get_* functions below are generated from JMESPath expressions in the
330// operationContextParams trait. They target the operation's input shape.
331
332/// Error type for the `UpdateEventSourceMappingError` operation.
333#[non_exhaustive]
334#[derive(::std::fmt::Debug)]
335pub enum UpdateEventSourceMappingError {
336    /// <p>One of the parameters in the request is not valid.</p>
337    InvalidParameterValueException(crate::types::error::InvalidParameterValueException),
338    /// <p>The resource already exists, or another operation is in progress.</p>
339    ResourceConflictException(crate::types::error::ResourceConflictException),
340    /// <p>The operation conflicts with the resource's availability. For example, you tried to update an event source mapping in the CREATING state, or you tried to delete an event source mapping currently UPDATING.</p>
341    ResourceInUseException(crate::types::error::ResourceInUseException),
342    /// <p>The resource specified in the request does not exist.</p>
343    ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
344    /// <p>The Lambda service encountered an internal error.</p>
345    ServiceException(crate::types::error::ServiceException),
346    /// <p>The request throughput limit was exceeded. For more information, see <a href="https://docs.aws.amazon.com/lambda/latest/dg/gettingstarted-limits.html#api-requests">Lambda quotas</a>.</p>
347    TooManyRequestsException(crate::types::error::TooManyRequestsException),
348    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
349    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
350    variable wildcard pattern and check `.code()`:
351     \
352    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
353     \
354    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-UpdateEventSourceMappingError) for what information is available for the error.")]
355    Unhandled(crate::error::sealed_unhandled::Unhandled),
356}
357impl UpdateEventSourceMappingError {
358    /// Creates the `UpdateEventSourceMappingError::Unhandled` variant from any error type.
359    pub fn unhandled(
360        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
361    ) -> Self {
362        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
363            source: err.into(),
364            meta: ::std::default::Default::default(),
365        })
366    }
367
368    /// Creates the `UpdateEventSourceMappingError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
369    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
370        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
371            source: err.clone().into(),
372            meta: err,
373        })
374    }
375    ///
376    /// Returns error metadata, which includes the error code, message,
377    /// request ID, and potentially additional information.
378    ///
379    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
380        match self {
381            Self::InvalidParameterValueException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
382            Self::ResourceConflictException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
383            Self::ResourceInUseException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
384            Self::ResourceNotFoundException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
385            Self::ServiceException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
386            Self::TooManyRequestsException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
387            Self::Unhandled(e) => &e.meta,
388        }
389    }
390    /// Returns `true` if the error kind is `UpdateEventSourceMappingError::InvalidParameterValueException`.
391    pub fn is_invalid_parameter_value_exception(&self) -> bool {
392        matches!(self, Self::InvalidParameterValueException(_))
393    }
394    /// Returns `true` if the error kind is `UpdateEventSourceMappingError::ResourceConflictException`.
395    pub fn is_resource_conflict_exception(&self) -> bool {
396        matches!(self, Self::ResourceConflictException(_))
397    }
398    /// Returns `true` if the error kind is `UpdateEventSourceMappingError::ResourceInUseException`.
399    pub fn is_resource_in_use_exception(&self) -> bool {
400        matches!(self, Self::ResourceInUseException(_))
401    }
402    /// Returns `true` if the error kind is `UpdateEventSourceMappingError::ResourceNotFoundException`.
403    pub fn is_resource_not_found_exception(&self) -> bool {
404        matches!(self, Self::ResourceNotFoundException(_))
405    }
406    /// Returns `true` if the error kind is `UpdateEventSourceMappingError::ServiceException`.
407    pub fn is_service_exception(&self) -> bool {
408        matches!(self, Self::ServiceException(_))
409    }
410    /// Returns `true` if the error kind is `UpdateEventSourceMappingError::TooManyRequestsException`.
411    pub fn is_too_many_requests_exception(&self) -> bool {
412        matches!(self, Self::TooManyRequestsException(_))
413    }
414}
415impl ::std::error::Error for UpdateEventSourceMappingError {
416    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
417        match self {
418            Self::InvalidParameterValueException(_inner) => ::std::option::Option::Some(_inner),
419            Self::ResourceConflictException(_inner) => ::std::option::Option::Some(_inner),
420            Self::ResourceInUseException(_inner) => ::std::option::Option::Some(_inner),
421            Self::ResourceNotFoundException(_inner) => ::std::option::Option::Some(_inner),
422            Self::ServiceException(_inner) => ::std::option::Option::Some(_inner),
423            Self::TooManyRequestsException(_inner) => ::std::option::Option::Some(_inner),
424            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
425        }
426    }
427}
428impl ::std::fmt::Display for UpdateEventSourceMappingError {
429    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
430        match self {
431            Self::InvalidParameterValueException(_inner) => _inner.fmt(f),
432            Self::ResourceConflictException(_inner) => _inner.fmt(f),
433            Self::ResourceInUseException(_inner) => _inner.fmt(f),
434            Self::ResourceNotFoundException(_inner) => _inner.fmt(f),
435            Self::ServiceException(_inner) => _inner.fmt(f),
436            Self::TooManyRequestsException(_inner) => _inner.fmt(f),
437            Self::Unhandled(_inner) => {
438                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
439                    write!(f, "unhandled error ({code})")
440                } else {
441                    f.write_str("unhandled error")
442                }
443            }
444        }
445    }
446}
447impl ::aws_smithy_types::retry::ProvideErrorKind for UpdateEventSourceMappingError {
448    fn code(&self) -> ::std::option::Option<&str> {
449        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
450    }
451    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
452        ::std::option::Option::None
453    }
454}
455impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for UpdateEventSourceMappingError {
456    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
457        match self {
458            Self::InvalidParameterValueException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
459            Self::ResourceConflictException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
460            Self::ResourceInUseException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
461            Self::ResourceNotFoundException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
462            Self::ServiceException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
463            Self::TooManyRequestsException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
464            Self::Unhandled(_inner) => &_inner.meta,
465        }
466    }
467}
468impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for UpdateEventSourceMappingError {
469    fn create_unhandled_error(
470        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
471        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
472    ) -> Self {
473        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
474            source,
475            meta: meta.unwrap_or_default(),
476        })
477    }
478}
479impl ::aws_types::request_id::RequestId for crate::operation::update_event_source_mapping::UpdateEventSourceMappingError {
480    fn request_id(&self) -> Option<&str> {
481        self.meta().request_id()
482    }
483}
484
485pub use crate::operation::update_event_source_mapping::_update_event_source_mapping_input::UpdateEventSourceMappingInput;
486
487pub use crate::operation::update_event_source_mapping::_update_event_source_mapping_output::UpdateEventSourceMappingOutput;
488
489mod _update_event_source_mapping_input;
490
491mod _update_event_source_mapping_output;
492
493/// Builders
494pub mod builders;
aws_sdk_lambda/operation/update_event_source_mapping.rs

aws_sdk_lambda/operation/
update_event_source_mapping.rs
