aws_sdk_eventbridgev2/operation/
update_event_source.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `UpdateEventSource`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct UpdateEventSource;
6impl UpdateEventSource {
7    /// Creates a new `UpdateEventSource`
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::UpdateEventSourceInput,
14    ) -> ::std::result::Result<
15        crate::operation::update_event_source::UpdateEventSourceOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::update_event_source::UpdateEventSourceError,
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::UpdateEventSourceError>()
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::UpdateEventSourceOutput>()
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::UpdateEventSourceInput,
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("EventBridgeV2", "UpdateEventSource", 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                "EventBridgeV2.UpdateEventSource",
59                "rpc.service" = "EventBridgeV2",
60                "rpc.method" = "UpdateEventSource",
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 UpdateEventSource {
88    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
89        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("UpdateEventSource");
90
91        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
92            UpdateEventSourceRequestSerializer,
93        ));
94        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
95            UpdateEventSourceResponseDeserializer,
96        ));
97
98        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
99            crate::config::auth::Params::builder()
100                .operation_name("UpdateEventSource")
101                .build()
102                .expect("required fields set"),
103        ));
104
105        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
106            "UpdateEventSource",
107            "EventBridgeV2",
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("UpdateEventSource")
129            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
130                UpdateEventSourceTelemetryInputCaptureInterceptor,
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                UpdateEventSourceEndpointParamsInterceptor,
137            ))
138            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
139                crate::operation::update_event_source::UpdateEventSourceError,
140            >::new())
141            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
142                crate::operation::update_event_source::UpdateEventSourceError,
143            >::new())
144            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
145                crate::operation::update_event_source::UpdateEventSourceError,
146            >::new())
147            .with_retry_classifier(::aws_runtime::service_clock_skew::ServiceClockSkewClassifier::<
148                crate::operation::update_event_source::UpdateEventSourceError,
149            >::new());
150
151        ::std::borrow::Cow::Owned(rcb)
152    }
153}
154
155#[derive(Debug)]
156struct UpdateEventSourceTelemetryInputCaptureInterceptor;
157
158#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
159impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateEventSourceTelemetryInputCaptureInterceptor {
160    fn name(&self) -> &'static str {
161        "UpdateEventSourceTelemetryInputCaptureInterceptor"
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::<UpdateEventSourceInput>() 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("EventSourceArn") {
189            if let ::std::option::Option::Some(value) = input.event_source_arn.as_deref() {
190                captured.insert("EventSourceArn", value);
191            }
192        }
193        if requested.should_capture("Description") {
194            if let ::std::option::Option::Some(value) = input.description.as_deref() {
195                captured.insert("Description", value);
196            }
197        }
198
199        cfg.interceptor_state().store_put(captured);
200        ::std::result::Result::Ok(())
201    }
202}
203#[derive(Debug)]
204struct UpdateEventSourceResponseDeserializer;
205impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for UpdateEventSourceResponseDeserializer {
206    fn deserialize_nonstreaming_with_config(
207        &self,
208        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
209        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
210    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
211        let (success, status) = (response.status().is_success(), response.status().as_u16());
212        let headers = response.headers();
213        let body = response.body().bytes().expect("body loaded");
214        #[allow(unused_mut)]
215        let mut force_error = false;
216        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
217        let parse_result = if !success && status != 200 || force_error {
218            crate::protocol_serde::shape_update_event_source::de_update_event_source_http_error(status, headers, body, _cfg)
219        } else {
220            crate::protocol_serde::shape_update_event_source::de_update_event_source_http_response(status, headers, body, _cfg)
221        };
222        crate::protocol_serde::type_erase_result(parse_result)
223    }
224}
225#[derive(Debug)]
226struct UpdateEventSourceRequestSerializer;
227impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for UpdateEventSourceRequestSerializer {
228    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
229    fn serialize_input(
230        &self,
231        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
232        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
233    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
234        let input = input
235            .downcast::<crate::operation::update_event_source::UpdateEventSourceInput>()
236            .expect("correct type");
237        let _header_serialization_settings = _cfg
238            .load::<crate::serialization_settings::HeaderSerializationSettings>()
239            .cloned()
240            .unwrap_or_default();
241        let mut request_builder = {
242            #[allow(clippy::uninlined_format_args)]
243            fn uri_base(
244                _input: &crate::operation::update_event_source::UpdateEventSourceInput,
245                output: &mut ::std::string::String,
246            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
247                use ::std::fmt::Write as _;
248                ::std::write!(output, "/service/AWSEventsV2/operation/UpdateEventSource").expect("formatting should succeed");
249                ::std::result::Result::Ok(())
250            }
251            #[allow(clippy::unnecessary_wraps)]
252            fn update_http_builder(
253                input: &crate::operation::update_event_source::UpdateEventSourceInput,
254                builder: ::http_1x::request::Builder,
255            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
256                let mut uri = ::std::string::String::new();
257                uri_base(input, &mut uri)?;
258                ::std::result::Result::Ok(builder.method("POST").uri(uri))
259            }
260            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
261            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/cbor");
262            builder = _header_serialization_settings.set_default_header(
263                builder,
264                ::http_1x::header::HeaderName::from_static("smithy-protocol"),
265                "rpc-v2-cbor",
266            );
267            builder =
268                _header_serialization_settings.set_default_header(builder, ::http_1x::header::HeaderName::from_static("accept"), "application/cbor");
269            builder
270        };
271        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_update_event_source::ser_update_event_source_input(&input)?);
272        if let Some(content_length) = body.content_length() {
273            let content_length = content_length.to_string();
274            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
275        }
276        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
277    }
278}
279#[derive(Debug)]
280struct UpdateEventSourceEndpointParamsInterceptor;
281
282#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
283impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateEventSourceEndpointParamsInterceptor {
284    fn name(&self) -> &'static str {
285        "UpdateEventSourceEndpointParamsInterceptor"
286    }
287
288    fn read_before_execution(
289        &self,
290        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
291            '_,
292            ::aws_smithy_runtime_api::client::interceptors::context::Input,
293            ::aws_smithy_runtime_api::client::interceptors::context::Output,
294            ::aws_smithy_runtime_api::client::interceptors::context::Error,
295        >,
296        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
297    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
298        let _input = context
299            .input()
300            .downcast_ref::<UpdateEventSourceInput>()
301            .ok_or("failed to downcast to UpdateEventSourceInput")?;
302
303        let params = crate::config::endpoint::Params::builder()
304            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
305            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
306            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
307            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
308            .build()
309            .map_err(|err| {
310                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
311            })?;
312        cfg.interceptor_state()
313            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
314        ::std::result::Result::Ok(())
315    }
316}
317
318// The get_* functions below are generated from JMESPath expressions in the
319// operationContextParams trait. They target the operation's input shape.
320
321/// Error type for the `UpdateEventSourceError` operation.
322#[non_exhaustive]
323#[derive(::std::fmt::Debug)]
324pub enum UpdateEventSourceError {
325    /// Another change to the resource is already in progress. Retry the request.
326    ConcurrentModificationException(crate::types::error::ConcurrentModificationException),
327    /// The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
328    InvalidStateException(crate::types::error::InvalidStateException),
329    /// The resource does not exist.
330    ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
331    /// The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
332    AccessDeniedException(crate::types::error::AccessDeniedException),
333    /// The request failed because of an internal service error. Retry the request.
334    InternalException(crate::types::error::InternalException),
335    /// A request parameter is missing or not valid.
336    InvalidInputException(crate::types::error::InvalidInputException),
337    /// The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
338    ThrottlingException(crate::types::error::ThrottlingException),
339    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
340    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
341    variable wildcard pattern and check `.code()`:
342     \
343    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
344     \
345    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-UpdateEventSourceError) for what information is available for the error.")]
346    Unhandled(crate::error::sealed_unhandled::Unhandled),
347}
348impl UpdateEventSourceError {
349    /// Creates the `UpdateEventSourceError::Unhandled` variant from any error type.
350    pub fn unhandled(
351        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
352    ) -> Self {
353        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
354            source: err.into(),
355            meta: ::std::default::Default::default(),
356        })
357    }
358
359    /// Creates the `UpdateEventSourceError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
360    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
361        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
362            source: err.clone().into(),
363            meta: err,
364        })
365    }
366    ///
367    /// Returns error metadata, which includes the error code, message,
368    /// request ID, and potentially additional information.
369    ///
370    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
371        match self {
372            Self::ConcurrentModificationException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
373            Self::InvalidStateException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
374            Self::ResourceNotFoundException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
375            Self::AccessDeniedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
376            Self::InternalException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
377            Self::InvalidInputException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
378            Self::ThrottlingException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
379            Self::Unhandled(e) => &e.meta,
380        }
381    }
382    /// Returns `true` if the error kind is `UpdateEventSourceError::ConcurrentModificationException`.
383    pub fn is_concurrent_modification_exception(&self) -> bool {
384        matches!(self, Self::ConcurrentModificationException(_))
385    }
386    /// Returns `true` if the error kind is `UpdateEventSourceError::InvalidStateException`.
387    pub fn is_invalid_state_exception(&self) -> bool {
388        matches!(self, Self::InvalidStateException(_))
389    }
390    /// Returns `true` if the error kind is `UpdateEventSourceError::ResourceNotFoundException`.
391    pub fn is_resource_not_found_exception(&self) -> bool {
392        matches!(self, Self::ResourceNotFoundException(_))
393    }
394    /// Returns `true` if the error kind is `UpdateEventSourceError::AccessDeniedException`.
395    pub fn is_access_denied_exception(&self) -> bool {
396        matches!(self, Self::AccessDeniedException(_))
397    }
398    /// Returns `true` if the error kind is `UpdateEventSourceError::InternalException`.
399    pub fn is_internal_exception(&self) -> bool {
400        matches!(self, Self::InternalException(_))
401    }
402    /// Returns `true` if the error kind is `UpdateEventSourceError::InvalidInputException`.
403    pub fn is_invalid_input_exception(&self) -> bool {
404        matches!(self, Self::InvalidInputException(_))
405    }
406    /// Returns `true` if the error kind is `UpdateEventSourceError::ThrottlingException`.
407    pub fn is_throttling_exception(&self) -> bool {
408        matches!(self, Self::ThrottlingException(_))
409    }
410}
411impl ::std::error::Error for UpdateEventSourceError {
412    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
413        match self {
414            Self::ConcurrentModificationException(_inner) => ::std::option::Option::Some(_inner),
415            Self::InvalidStateException(_inner) => ::std::option::Option::Some(_inner),
416            Self::ResourceNotFoundException(_inner) => ::std::option::Option::Some(_inner),
417            Self::AccessDeniedException(_inner) => ::std::option::Option::Some(_inner),
418            Self::InternalException(_inner) => ::std::option::Option::Some(_inner),
419            Self::InvalidInputException(_inner) => ::std::option::Option::Some(_inner),
420            Self::ThrottlingException(_inner) => ::std::option::Option::Some(_inner),
421            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
422        }
423    }
424}
425impl ::std::fmt::Display for UpdateEventSourceError {
426    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
427        match self {
428            Self::ConcurrentModificationException(_inner) => _inner.fmt(f),
429            Self::InvalidStateException(_inner) => _inner.fmt(f),
430            Self::ResourceNotFoundException(_inner) => _inner.fmt(f),
431            Self::AccessDeniedException(_inner) => _inner.fmt(f),
432            Self::InternalException(_inner) => _inner.fmt(f),
433            Self::InvalidInputException(_inner) => _inner.fmt(f),
434            Self::ThrottlingException(_inner) => _inner.fmt(f),
435            Self::Unhandled(_inner) => {
436                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
437                    write!(f, "unhandled error ({code})")
438                } else {
439                    f.write_str("unhandled error")
440                }
441            }
442        }
443    }
444}
445impl ::aws_smithy_types::retry::ProvideErrorKind for UpdateEventSourceError {
446    fn code(&self) -> ::std::option::Option<&str> {
447        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
448    }
449    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
450        match self {
451            Self::ConcurrentModificationException(inner) => ::std::option::Option::Some(inner.retryable_error_kind()),
452            Self::InternalException(inner) => ::std::option::Option::Some(inner.retryable_error_kind()),
453            Self::ThrottlingException(inner) => ::std::option::Option::Some(inner.retryable_error_kind()),
454            _ => ::std::option::Option::None,
455        }
456    }
457}
458impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for UpdateEventSourceError {
459    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
460        match self {
461            Self::ConcurrentModificationException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
462            Self::InvalidStateException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
463            Self::ResourceNotFoundException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
464            Self::AccessDeniedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
465            Self::InternalException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
466            Self::InvalidInputException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
467            Self::ThrottlingException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
468            Self::Unhandled(_inner) => &_inner.meta,
469        }
470    }
471}
472impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for UpdateEventSourceError {
473    fn create_unhandled_error(
474        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
475        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
476    ) -> Self {
477        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
478            source,
479            meta: meta.unwrap_or_default(),
480        })
481    }
482}
483impl ::aws_types::request_id::RequestId for crate::operation::update_event_source::UpdateEventSourceError {
484    fn request_id(&self) -> Option<&str> {
485        self.meta().request_id()
486    }
487}
488
489pub use crate::operation::update_event_source::_update_event_source_input::UpdateEventSourceInput;
490
491pub use crate::operation::update_event_source::_update_event_source_output::UpdateEventSourceOutput;
492
493mod _update_event_source_input;
494
495mod _update_event_source_output;
496
497/// Builders
498pub mod builders;
aws_sdk_eventbridgev2/operation/update_event_source.rs

aws_sdk_eventbridgev2/operation/
update_event_source.rs
