AWS SDK

tmp-codegen-diff/aws-sdk/sdk/lambda/src/operation/invoke.rs

@@ -1,1 +40,44 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// Orchestration and serialization glue logic for `Invoke`.
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct Invoke;
 impl Invoke {
     /// Creates a new `Invoke`
     pub fn new() -> Self {
         Self
-10
+    }
     /// The schema for this operation's input shape.
     pub const INPUT_SCHEMA: &'static ::aws_smithy_schema::Schema = crate::operation::invoke::InvokeInput::SCHEMA;
     /// The schema for this operation's output shape.
     pub const OUTPUT_SCHEMA: &'static ::aws_smithy_schema::Schema = crate::operation::invoke::InvokeOutput::SCHEMA;
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::invoke::InvokeInput,
     ) -> ::std::result::Result<
         crate::operation::invoke::InvokeOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::invoke::InvokeError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {

↧ Expand context

         let map_err =
             |err: ::aws_smithy_runtime_api::client::result::SdkError<
                 ::aws_smithy_runtime_api::client::interceptors::context::Error,
                 ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
             >| { err.map_service_error(|err| err.downcast::<crate::operation::invoke::InvokeError>().expect("correct error type")) };
         let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
             .await
             .map_err(map_err)?;
         let output = context.finalize().map_err(map_err)?;
         ::std::result::Result::Ok(output.downcast::<crate::operation::invoke::InvokeOutput>().expect("correct output type"))
-35
+    }
-36
     pub(crate) async fn orchestrate_with_stop_point(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::invoke::InvokeInput,
         stop_point: ::aws_smithy_runtime::client::orchestrator::StopPoint,
     ) -> ::std::result::Result<
         ::aws_smithy_runtime_api::client::interceptors::context::InterceptorContext,
         ::aws_smithy_runtime_api::client::result::SdkError<
             ::aws_smithy_runtime_api::client::interceptors::context::Error,

@@ -107,111 +253,974 @@

↥ Expand context

             ..::std::default::Default::default()
         });
-113
         ::std::option::Option::Some(cfg.freeze())
-115
+    }
-116
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("Invoke")
             .with_interceptor(InvokeEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::invoke::InvokeError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::invoke::InvokeError,
             >::new())
             .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<

                 crate::operation::invoke::InvokeError,
             >::new());
-133
         ::std::borrow::Cow::Owned(rcb)
-135
+    }
-136
+}
-137
 #[derive(Debug)]
 struct InvokeResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for InvokeResponseDeserializer {
     fn deserialize_nonstreaming(
     fn deserialize_nonstreaming_with_config(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         _cfg: &::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         let (success, status) = (response.status().is_success(), response.status().as_u16());
         let headers = response.headers();
         let body = response.body().bytes().expect("body loaded");
         #[allow(unused_mut)]
         let mut force_error = false;
         ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_invoke::de_invoke_http_error(status, headers, body)
         if !success && status != 200 || force_error {
             let headers = response.headers();
             let body = response.body().bytes().expect("body loaded");
             #[allow(unused_mut)]
             let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(status, headers, body).map_err(|e| {
                 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(::aws_smithy_runtime_api::box_error::BoxError::from(e))
             })?;
             generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, headers);
             let generic = generic_builder.build();
             let error_code = match generic.code() {
                 ::std::option::Option::Some(code) => code,
                 ::std::option::Option::None => {
                     return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                         ::aws_smithy_runtime_api::box_error::BoxError::from(crate::operation::invoke::InvokeError::unhandled(generic)),
                     ))
-+
+                }
             };
             let _error_message = generic.message().map(|msg| msg.to_owned());
             let protocol = _cfg
                 .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
                 .expect("a SharedClientProtocol is required");
             let err = match error_code {
                 "EC2AccessDeniedException" => crate::operation::invoke::InvokeError::Ec2AccessDeniedException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::Ec2AccessDeniedException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::Ec2AccessDeniedException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "EC2ThrottledException" => crate::operation::invoke::InvokeError::Ec2ThrottledException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::Ec2ThrottledException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::Ec2ThrottledException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "EC2UnexpectedException" => crate::operation::invoke::InvokeError::Ec2UnexpectedException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::Ec2UnexpectedException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::Ec2UnexpectedException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "EFSIOException" => crate::operation::invoke::InvokeError::EfsioException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::EfsioException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::EfsioException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "EFSMountConnectivityException" => crate::operation::invoke::InvokeError::EfsMountConnectivityException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::EfsMountConnectivityException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::EfsMountConnectivityException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "EFSMountFailureException" => crate::operation::invoke::InvokeError::EfsMountFailureException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::EfsMountFailureException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::EfsMountFailureException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "EFSMountTimeoutException" => crate::operation::invoke::InvokeError::EfsMountTimeoutException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::EfsMountTimeoutException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::EfsMountTimeoutException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "ENILimitReachedException" => crate::operation::invoke::InvokeError::EniLimitReachedException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::EniLimitReachedException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::EniLimitReachedException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "InvalidParameterValueException" => crate::operation::invoke::InvokeError::InvalidParameterValueException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InvalidParameterValueException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InvalidParameterValueException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "InvalidRequestContentException" => crate::operation::invoke::InvokeError::InvalidRequestContentException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InvalidRequestContentException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InvalidRequestContentException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "InvalidRuntimeException" => crate::operation::invoke::InvokeError::InvalidRuntimeException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InvalidRuntimeException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InvalidRuntimeException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "InvalidSecurityGroupIDException" => crate::operation::invoke::InvokeError::InvalidSecurityGroupIdException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InvalidSecurityGroupIdException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InvalidSecurityGroupIdException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "InvalidSubnetIDException" => crate::operation::invoke::InvokeError::InvalidSubnetIdException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InvalidSubnetIdException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InvalidSubnetIdException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "InvalidZipFileException" => crate::operation::invoke::InvokeError::InvalidZipFileException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InvalidZipFileException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InvalidZipFileException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "KMSAccessDeniedException" => crate::operation::invoke::InvokeError::KmsAccessDeniedException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::KmsAccessDeniedException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::KmsAccessDeniedException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "KMSDisabledException" => crate::operation::invoke::InvokeError::KmsDisabledException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::KmsDisabledException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::KmsDisabledException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "KMSInvalidStateException" => crate::operation::invoke::InvokeError::KmsInvalidStateException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::KmsInvalidStateException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::KmsInvalidStateException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "KMSNotFoundException" => crate::operation::invoke::InvokeError::KmsNotFoundException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::KmsNotFoundException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::KmsNotFoundException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "RecursiveInvocationException" => crate::operation::invoke::InvokeError::RecursiveInvocationException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::RecursiveInvocationException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::RecursiveInvocationException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "RequestTooLargeException" => crate::operation::invoke::InvokeError::RequestTooLargeException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::RequestTooLargeException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::RequestTooLargeException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "ResourceConflictException" => crate::operation::invoke::InvokeError::ResourceConflictException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ResourceConflictException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ResourceConflictException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "ResourceNotFoundException" => crate::operation::invoke::InvokeError::ResourceNotFoundException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ResourceNotFoundException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ResourceNotFoundException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "ResourceNotReadyException" => crate::operation::invoke::InvokeError::ResourceNotReadyException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ResourceNotReadyException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ResourceNotReadyException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "ServiceException" => crate::operation::invoke::InvokeError::ServiceException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ServiceException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ServiceException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "SnapStartException" => crate::operation::invoke::InvokeError::SnapStartException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::SnapStartException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::SnapStartException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "SnapStartNotReadyException" => crate::operation::invoke::InvokeError::SnapStartNotReadyException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::SnapStartNotReadyException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::SnapStartNotReadyException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "SnapStartTimeoutException" => crate::operation::invoke::InvokeError::SnapStartTimeoutException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::SnapStartTimeoutException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::SnapStartTimeoutException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "SubnetIPAddressLimitReachedException" => crate::operation::invoke::InvokeError::SubnetIpAddressLimitReachedException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::SubnetIpAddressLimitReachedException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::SubnetIpAddressLimitReachedException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "TooManyRequestsException" => crate::operation::invoke::InvokeError::TooManyRequestsException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::TooManyRequestsException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::TooManyRequestsException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "UnsupportedMediaTypeException" => crate::operation::invoke::InvokeError::UnsupportedMediaTypeException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::UnsupportedMediaTypeException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::UnsupportedMediaTypeException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 _ => crate::operation::invoke::InvokeError::generic(generic),
             };
             ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::operation(
                 ::aws_smithy_runtime_api::client::interceptors::context::Error::erase(err),
             ))
         } else {
             crate::protocol_serde::shape_invoke::de_invoke_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
             let protocol = _cfg
                 .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
                 .expect("a SharedClientProtocol is required");
             let mut deser = protocol.deserialize_response(response, Invoke::OUTPUT_SCHEMA, _cfg).map_err(|e| {
                 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(::aws_smithy_runtime_api::box_error::BoxError::from(e))
             })?;
             let body = response.body().bytes().expect("body loaded");
             let output =
                 crate::operation::invoke::InvokeOutput::deserialize_with_response(&mut *deser, response.headers(), response.status().into(), body)
                     .map_err(|e| {
                         ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(::aws_smithy_runtime_api::box_error::BoxError::from(
                             e,
                         ))
                     })?;
             ::std::result::Result::Ok(::aws_smithy_runtime_api::client::interceptors::context::Output::erase(output))
-+
+        }
-914
+    }
-915
+}
 #[derive(Debug)]
 struct InvokeRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for InvokeRequestSerializer {
     #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
     fn serialize_input(
         &self,
         input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
         _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
         let input = input.downcast::<crate::operation::invoke::InvokeInput>().expect("correct type");
         let _header_serialization_settings = _cfg
             .load::<crate::serialization_settings::HeaderSerializationSettings>()
             .cloned()
             .unwrap_or_default();
         let mut request_builder = {
             #[allow(clippy::uninlined_format_args)]
             fn uri_base(
                 _input: &crate::operation::invoke::InvokeInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 let input_1 = &_input.function_name;
                 let input_1 = input_1
                     .as_ref()
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("function_name", "cannot be empty or unset"))?;
                 let function_name = ::aws_smithy_http::label::fmt_string(input_1, ::aws_smithy_http::label::EncodingStrategy::Default);
                 if function_name.is_empty() {
                     return ::std::result::Result::Err(::aws_smithy_types::error::operation::BuildError::missing_field(
                         "function_name",
                         "cannot be empty or unset",
                     ));
--
+                }
                 ::std::write!(output, "/2015-03-31/functions/{FunctionName}/invocations", FunctionName = function_name)
                     .expect("formatting should succeed");
                 ::std::result::Result::Ok(())
         let protocol = _cfg
             .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
             .expect("a SharedClientProtocol is required");
         let mut input = input;
         let payload = input.payload.take();
         let mut request = protocol
             .serialize_request(&input, Invoke::INPUT_SCHEMA, "", _cfg)
             .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
         if let ::std::option::Option::Some(payload) = payload {
             *request.body_mut() = ::aws_smithy_types::body::SdkBody::from(payload.into_inner());
             if !request.headers().contains_key("Content-Type") {
                 request.headers_mut().insert("Content-Type", "application/octet-stream");
-938
+            }
             fn uri_query(
                 _input: &crate::operation::invoke::InvokeInput,
                 mut output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 let mut query = ::aws_smithy_http::query::Writer::new(output);
                 if let ::std::option::Option::Some(inner_2) = &_input.qualifier {
--
+                    {
                         query.push_kv("Qualifier", &::aws_smithy_http::query::fmt_string(inner_2));
--
+                    }
--
+                }
                 ::std::result::Result::Ok(())
             if let ::std::option::Option::Some(content_length) = request.body().content_length() {
                 request.headers_mut().insert("Content-Length", content_length.to_string());
-941
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::invoke::InvokeInput,
                 builder: ::http_1x::request::Builder,
             ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 uri_query(input, &mut uri)?;
                 let builder = crate::protocol_serde::shape_invoke::ser_invoke_headers(input, builder)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
--
+            }
             let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/octet-stream");
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_invoke_input::ser_payload_http_payload(input.payload)?);
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
-942
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-+
         return ::std::result::Result::Ok(request);
-945
+    }
-946
+}
 #[derive(Debug)]
 struct InvokeEndpointParamsInterceptor;
-949
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for InvokeEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "InvokeEndpointParamsInterceptor"
-953
+    }
-954

↧ Expand context

     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context.input().downcast_ref::<InvokeInput>().ok_or("failed to downcast to InvokeInput")?;
-966
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

tmp-codegen-diff/aws-sdk/sdk/lambda/src/operation/invoke/_invoke_input.rs

@@ -77,77 +276,311 @@

↥ Expand context

-77
+    }
     /// <p>Specify a version or alias to invoke a published version of the function.</p>
     pub fn qualifier(&self) -> ::std::option::Option<&str> {
         self.qualifier.as_deref()
-81
+    }
-82
+}
 impl ::std::fmt::Debug for InvokeInput {
     fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         let mut formatter = f.debug_struct("InvokeInput");
         formatter.field("function_name", &self.function_name);
         formatter.field("invocation_type", &self.invocation_type);
         formatter.field("log_type", &self.log_type);
         formatter.field("client_context", &self.client_context);
         formatter.field("payload", &"*** Sensitive Data Redacted ***");
         formatter.field("qualifier", &self.qualifier);
         formatter.finish()
-93
+    }
-94
+}
 static INVOKEINPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.lambda.synthetic#InvokeInput",

     "com.amazonaws.lambda.synthetic",
     "InvokeInput",
 );
 static INVOKEINPUT_MEMBER_FUNCTION_NAME: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#InvokeInput$FunctionName",
         "com.amazonaws.lambda.synthetic",
         "InvokeInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "function_name",
     "FunctionName",
 ,
-109
+)
 .with_http_label();
 static INVOKEINPUT_MEMBER_INVOCATION_TYPE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#InvokeInput$InvocationType",
         "com.amazonaws.lambda.synthetic",
         "InvokeInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "invocation_type",
     "InvocationType",
 ,
-120
+)
 .with_http_header("X-Amz-Invocation-Type");
 static INVOKEINPUT_MEMBER_LOG_TYPE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#InvokeInput$LogType",
         "com.amazonaws.lambda.synthetic",
         "InvokeInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "log_type",
     "LogType",
 ,
-131
+)
 .with_http_header("X-Amz-Log-Type");
 static INVOKEINPUT_MEMBER_CLIENT_CONTEXT: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#InvokeInput$ClientContext",
         "com.amazonaws.lambda.synthetic",
         "InvokeInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "client_context",
     "ClientContext",
 ,
-142
+)
 .with_http_header("X-Amz-Client-Context");
 static INVOKEINPUT_MEMBER_PAYLOAD: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#InvokeInput$Payload",
         "com.amazonaws.lambda.synthetic",
         "InvokeInput",
     ),
     ::aws_smithy_schema::ShapeType::Blob,
     "payload",
     "Payload",
 ,
-153
+)
 .with_http_payload();
 static INVOKEINPUT_MEMBER_QUALIFIER: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#InvokeInput$Qualifier",
         "com.amazonaws.lambda.synthetic",
         "InvokeInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "qualifier",
     "Qualifier",
 ,
-164
+)
 .with_http_query("Qualifier");
 static INVOKEINPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     INVOKEINPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &INVOKEINPUT_MEMBER_FUNCTION_NAME,
         &INVOKEINPUT_MEMBER_INVOCATION_TYPE,
         &INVOKEINPUT_MEMBER_LOG_TYPE,
         &INVOKEINPUT_MEMBER_CLIENT_CONTEXT,
         &INVOKEINPUT_MEMBER_PAYLOAD,
         &INVOKEINPUT_MEMBER_QUALIFIER,
     ],
 );
-+
+)
 .with_http(aws_smithy_schema::traits::HttpTrait::new(
     "POST",
     "/2015-03-31/functions/{FunctionName}/invocations",
     None,
 ));
 impl InvokeInput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &INVOKEINPUT_SCHEMA;
-186
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for InvokeInput {
     #[allow(unused_variables, clippy::diverging_sub_expression)]
     fn serialize_members(
         &self,
         ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer,
     ) -> ::std::result::Result<(), ::aws_smithy_schema::serde::SerdeError> {
         if let Some(ref val) = self.function_name {
             ser.write_string(&INVOKEINPUT_MEMBER_FUNCTION_NAME, val)?;
-195
+        }
         if let Some(ref val) = self.invocation_type {
             ser.write_string(&INVOKEINPUT_MEMBER_INVOCATION_TYPE, val.as_str())?;
-198
+        }
         if let Some(ref val) = self.log_type {
             ser.write_string(&INVOKEINPUT_MEMBER_LOG_TYPE, val.as_str())?;
-201
+        }
         if let Some(ref val) = self.client_context {
             ser.write_string(&INVOKEINPUT_MEMBER_CLIENT_CONTEXT, val)?;
-204
+        }
         if let Some(ref val) = self.payload {
             ser.write_blob(&INVOKEINPUT_MEMBER_PAYLOAD, val)?;
-207
+        }
         if let Some(ref val) = self.qualifier {
             ser.write_string(&INVOKEINPUT_MEMBER_QUALIFIER, val)?;
-210
+        }
         Ok(())
-212
+    }
-213
+}
 impl InvokeInput {
     /// Deserializes this structure from a [`ShapeDeserializer`].
     pub fn deserialize<D: ::aws_smithy_schema::serde::ShapeDeserializer>(
         deserializer: &mut D,
     pub fn deserialize(
         deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
     ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
         #[allow(unused_variables, unused_mut)]
         let mut builder = Self::builder();
         #[allow(
             unused_variables,
             unreachable_code,
             clippy::single_match,
             clippy::match_single_binding,
             clippy::diverging_sub_expression
         )]
         deserializer.read_struct(&INVOKEINPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&INVOKEINPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.function_name = Some(deser.read_string(member)?);
-232
+                }
                 Some(1) => {
                     builder.invocation_type = Some(crate::types::InvocationType::from(deser.read_string(member)?.as_str()));
-235
+                }
                 Some(2) => {
                     builder.log_type = Some(crate::types::LogType::from(deser.read_string(member)?.as_str()));
-238
+                }
                 Some(3) => {
                     builder.client_context = Some(deser.read_string(member)?);
-241
+                }
                 Some(4) => {
                     builder.payload = Some(deser.read_blob(member)?);
-244
+                }
                 Some(5) => {
                     builder.qualifier = Some(deser.read_string(member)?);
-247
+                }
                 _ => {}
-249
+            }
             Ok(())
         })?;
         builder.function_name = builder.function_name.or(Some(String::new()));
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-+
+    }
-+
+}
 impl InvokeInput {
     /// Deserializes this structure from a body deserializer and HTTP response headers.
     /// Header-bound members are read directly from headers, avoiding runtime
     /// member iteration overhead. Body members are read via the deserializer.
     pub fn deserialize_with_response(
         _deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
         headers: &::aws_smithy_runtime_api::http::Headers,
         _status: u16,
         body: &[u8],
     ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
         #[allow(unused_variables, unused_mut)]
         let mut builder = Self::builder();
         if let Some(val) = headers.get("X-Amz-Invocation-Type") {
             builder.invocation_type = Some(crate::types::InvocationType::from(val));
-+
+        }
         if let Some(val) = headers.get("X-Amz-Log-Type") {
             builder.log_type = Some(crate::types::LogType::from(val));
-+
+        }
         if let Some(val) = headers.get("X-Amz-Client-Context") {
             builder.client_context = Some(val.to_string());
-+
+        }
         if !body.is_empty() {
             builder.payload = Some(::aws_smithy_types::Blob::new(body.to_vec()));
-+
+        }
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-285
+    }
-286
+}
 impl InvokeInput {
     /// Creates a new builder-style object to manufacture [`InvokeInput`](crate::operation::invoke::InvokeInput).
     pub fn builder() -> crate::operation::invoke::builders::InvokeInputBuilder {
         crate::operation::invoke::builders::InvokeInputBuilder::default()
-291
+    }

↧ Expand context

-292
+}
-293
 /// A builder for [`InvokeInput`](crate::operation::invoke::InvokeInput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default)]
 #[non_exhaustive]
 pub struct InvokeInputBuilder {
     pub(crate) function_name: ::std::option::Option<::std::string::String>,
     pub(crate) invocation_type: ::std::option::Option<crate::types::InvocationType>,
     pub(crate) log_type: ::std::option::Option<crate::types::LogType>,
     pub(crate) client_context: ::std::option::Option<::std::string::String>,
     pub(crate) payload: ::std::option::Option<::aws_smithy_types::Blob>,
     pub(crate) qualifier: ::std::option::Option<::std::string::String>,
-304
+}
 impl InvokeInputBuilder {
     /// <p>The name or ARN of the Lambda function, version, or alias.</p>
     /// <p class="title"><b>Name formats</b></p>
     /// <ul>
     /// <li>
     /// <p><b>Function name</b> – <code>my-function</code> (name-only), <code>my-function:v1</code> (with alias).</p></li>
     /// <li>

tmp-codegen-diff/aws-sdk/sdk/lambda/src/operation/invoke/_invoke_output.rs

@@ -34,34 +219,261 @@

↥ Expand context

-34
+    }
     /// <p>The version of the function that executed. When you invoke a function with an alias, this indicates which version the alias resolved to.</p>
     pub fn executed_version(&self) -> ::std::option::Option<&str> {
         self.executed_version.as_deref()
-38
+    }
-39
+}
 impl ::std::fmt::Debug for InvokeOutput {
     fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         let mut formatter = f.debug_struct("InvokeOutput");
         formatter.field("status_code", &self.status_code);
         formatter.field("function_error", &self.function_error);
         formatter.field("log_result", &self.log_result);
         formatter.field("payload", &"*** Sensitive Data Redacted ***");
         formatter.field("executed_version", &self.executed_version);
         formatter.field("_request_id", &self._request_id);
         formatter.finish()
-50
+    }
-51
+}
 static INVOKEOUTPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.lambda.synthetic#InvokeOutput",

     "com.amazonaws.lambda.synthetic",
     "InvokeOutput",
 );
 static INVOKEOUTPUT_MEMBER_STATUS_CODE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#InvokeOutput$StatusCode",
         "com.amazonaws.lambda.synthetic",
         "InvokeOutput",
     ),
     ::aws_smithy_schema::ShapeType::Integer,
     "status_code",
     "StatusCode",
 ,
-66
+)
 .with_http_response_code();
 static INVOKEOUTPUT_MEMBER_FUNCTION_ERROR: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#InvokeOutput$FunctionError",
         "com.amazonaws.lambda.synthetic",
         "InvokeOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "function_error",
     "FunctionError",
 ,
-77
+)
 .with_http_header("X-Amz-Function-Error");
 static INVOKEOUTPUT_MEMBER_LOG_RESULT: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#InvokeOutput$LogResult",
         "com.amazonaws.lambda.synthetic",
         "InvokeOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "log_result",
     "LogResult",
 ,
-88
+)
 .with_http_header("X-Amz-Log-Result");
 static INVOKEOUTPUT_MEMBER_PAYLOAD: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#InvokeOutput$Payload",
         "com.amazonaws.lambda.synthetic",
         "InvokeOutput",
     ),
     ::aws_smithy_schema::ShapeType::Blob,
     "payload",
     "Payload",
 ,
-99
+)
 .with_http_payload();
 static INVOKEOUTPUT_MEMBER_EXECUTED_VERSION: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#InvokeOutput$ExecutedVersion",
         "com.amazonaws.lambda.synthetic",
         "InvokeOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "executed_version",
     "ExecutedVersion",
 ,
-110
+)
 .with_http_header("X-Amz-Executed-Version");
 static INVOKEOUTPUT_MEMBER__REQUEST_ID: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static("synthetic#request_id", "synthetic", "request_id"),
     ::aws_smithy_schema::ShapeType::String,
     "request_id",
 ,
-+
+)
 .with_http_header("x-amzn-requestid");
 static INVOKEOUTPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     INVOKEOUTPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &INVOKEOUTPUT_MEMBER_STATUS_CODE,
         &INVOKEOUTPUT_MEMBER_FUNCTION_ERROR,
         &INVOKEOUTPUT_MEMBER_LOG_RESULT,
         &INVOKEOUTPUT_MEMBER_PAYLOAD,
         &INVOKEOUTPUT_MEMBER_EXECUTED_VERSION,
         &INVOKEOUTPUT_MEMBER__REQUEST_ID,
     ],
 );
 impl InvokeOutput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &INVOKEOUTPUT_SCHEMA;
-134
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for InvokeOutput {
     #[allow(unused_variables, clippy::diverging_sub_expression)]
     fn serialize_members(
         &self,
         ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer,
     ) -> ::std::result::Result<(), ::aws_smithy_schema::serde::SerdeError> {
-141
+        {
             let val = &self.status_code;
             ser.write_integer(&INVOKEOUTPUT_MEMBER_STATUS_CODE, *val)?;
-144
+        }
         if let Some(ref val) = self.function_error {
             ser.write_string(&INVOKEOUTPUT_MEMBER_FUNCTION_ERROR, val)?;
-147
+        }
         if let Some(ref val) = self.log_result {
             ser.write_string(&INVOKEOUTPUT_MEMBER_LOG_RESULT, val)?;
-150
+        }
         if let Some(ref val) = self.payload {
             ser.write_blob(&INVOKEOUTPUT_MEMBER_PAYLOAD, val)?;
-153
+        }
         if let Some(ref val) = self.executed_version {
             ser.write_string(&INVOKEOUTPUT_MEMBER_EXECUTED_VERSION, val)?;
-156
+        }
         Ok(())
-158
+    }
-159
+}
 impl InvokeOutput {
     /// Deserializes this structure from a [`ShapeDeserializer`].
     pub fn deserialize<D: ::aws_smithy_schema::serde::ShapeDeserializer>(
         deserializer: &mut D,
     pub fn deserialize(
         deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
     ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
         #[allow(unused_variables, unused_mut)]
         let mut builder = Self::builder();
         #[allow(
             unused_variables,
             unreachable_code,
             clippy::single_match,
             clippy::match_single_binding,
             clippy::diverging_sub_expression
         )]
         deserializer.read_struct(&INVOKEOUTPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&INVOKEOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.status_code = Some(deser.read_integer(member)?);
-178
+                }
                 Some(1) => {
                     builder.function_error = Some(deser.read_string(member)?);
-181
+                }
                 Some(2) => {
                     builder.log_result = Some(deser.read_string(member)?);
-184
+                }
                 Some(3) => {
                     builder.payload = Some(deser.read_blob(member)?);
-187
+                }
                 Some(4) => {
                     builder.executed_version = Some(deser.read_string(member)?);
-190
+                }
                 Some(5) => {
                     builder._request_id = Some(deser.read_string(member)?);
-+
+                }
                 _ => {}
-195
+            }
             Ok(())
         })?;
         Ok(builder.build())
-199
+    }
-200
+}
 impl InvokeOutput {
     /// Deserializes this structure from a body deserializer and HTTP response headers.
     /// Header-bound members are read directly from headers, avoiding runtime
     /// member iteration overhead. Body members are read via the deserializer.
     pub fn deserialize_with_response(
         _deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
         headers: &::aws_smithy_runtime_api::http::Headers,
         _status: u16,
         body: &[u8],
     ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
         #[allow(unused_variables, unused_mut)]
         let mut builder = Self::builder();
         if let Some(val) = headers.get("X-Amz-Function-Error") {
             builder.function_error = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("X-Amz-Log-Result") {
             builder.log_result = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("X-Amz-Executed-Version") {
             builder.executed_version = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-requestid") {
             builder._request_id = Some(val.to_string());
-+
+        }
         builder.status_code = Some(_status as i32);
         if !body.is_empty() {
             builder.payload = Some(::aws_smithy_types::Blob::new(body.to_vec()));
-+
+        }
         Ok(builder.build())
-+
+    }
-+
+}
 impl ::aws_types::request_id::RequestId for InvokeOutput {
     fn request_id(&self) -> Option<&str> {
         self._request_id.as_deref()
-235
+    }
-236
+}
 impl InvokeOutput {
     /// Creates a new builder-style object to manufacture [`InvokeOutput`](crate::operation::invoke::InvokeOutput).
     pub fn builder() -> crate::operation::invoke::builders::InvokeOutputBuilder {
         crate::operation::invoke::builders::InvokeOutputBuilder::default()
-241
+    }

↧ Expand context

-242
+}
-243
 /// A builder for [`InvokeOutput`](crate::operation::invoke::InvokeOutput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default)]
 #[non_exhaustive]
 pub struct InvokeOutputBuilder {
     pub(crate) status_code: ::std::option::Option<i32>,
     pub(crate) function_error: ::std::option::Option<::std::string::String>,
     pub(crate) log_result: ::std::option::Option<::std::string::String>,
     pub(crate) payload: ::std::option::Option<::aws_smithy_types::Blob>,
     pub(crate) executed_version: ::std::option::Option<::std::string::String>,
     _request_id: Option<String>,
-254
+}
 impl InvokeOutputBuilder {
     /// <p>The HTTP status code is in the 200 range for a successful request. For the <code>RequestResponse</code> invocation type, this status code is 200. For the <code>Event</code> invocation type, this status code is 202. For the <code>DryRun</code> invocation type, the status code is 204.</p>
     pub fn status_code(mut self, input: i32) -> Self {
         self.status_code = ::std::option::Option::Some(input);
         self
-260
+    }
     /// <p>The HTTP status code is in the 200 range for a successful request. For the <code>RequestResponse</code> invocation type, this status code is 200. For the <code>Event</code> invocation type, this status code is 202. For the <code>DryRun</code> invocation type, the status code is 204.</p>

tmp-codegen-diff/aws-sdk/sdk/lambda/src/operation/invoke_async.rs

@@ -1,1 +40,44 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// Orchestration and serialization glue logic for `InvokeAsync`.
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct InvokeAsync;
 impl InvokeAsync {
     /// Creates a new `InvokeAsync`
     pub fn new() -> Self {
         Self
-10
+    }
     /// The schema for this operation's input shape.
     pub const INPUT_SCHEMA: &'static ::aws_smithy_schema::Schema = crate::operation::invoke_async::InvokeAsyncInput::SCHEMA;
     /// The schema for this operation's output shape.
     pub const OUTPUT_SCHEMA: &'static ::aws_smithy_schema::Schema = crate::operation::invoke_async::InvokeAsyncOutput::SCHEMA;
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::invoke_async::InvokeAsyncInput,
     ) -> ::std::result::Result<
         crate::operation::invoke_async::InvokeAsyncOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::invoke_async::InvokeAsyncError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {

↧ Expand context

         let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >| {
             err.map_service_error(|err| {
                 err.downcast::<crate::operation::invoke_async::InvokeAsyncError>()
                     .expect("correct error type")
             })
         };
         let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
             .await
             .map_err(map_err)?;
         let output = context.finalize().map_err(map_err)?;
         ::std::result::Result::Ok(
             output
                 .downcast::<crate::operation::invoke_async::InvokeAsyncOutput>()
                 .expect("correct output type"),
-42
+        )
-43
+    }
-44

@@ -114,118 +248,380 @@

↥ Expand context

             ..::std::default::Default::default()
         });
-120
         ::std::option::Option::Some(cfg.freeze())
-122
+    }
-123
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("InvokeAsync")
             .with_interceptor(InvokeAsyncEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::invoke_async::InvokeAsyncError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::invoke_async::InvokeAsyncError,
             >::new())
             .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<

                 crate::operation::invoke_async::InvokeAsyncError,
             >::new());
-140
         ::std::borrow::Cow::Owned(rcb)
-142
+    }
-143
+}
-144
 #[derive(Debug)]
 struct InvokeAsyncResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for InvokeAsyncResponseDeserializer {
     fn deserialize_nonstreaming(
     fn deserialize_nonstreaming_with_config(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         _cfg: &::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         let (success, status) = (response.status().is_success(), response.status().as_u16());
         let headers = response.headers();
         let body = response.body().bytes().expect("body loaded");
         #[allow(unused_mut)]
         let mut force_error = false;
         ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
         let parse_result = if !success && status != 202 || force_error {
             crate::protocol_serde::shape_invoke_async::de_invoke_async_http_error(status, headers, body)
         if !success && status != 202 || force_error {
             let headers = response.headers();
             let body = response.body().bytes().expect("body loaded");
             #[allow(unused_mut)]
             let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(status, headers, body).map_err(|e| {
                 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(::aws_smithy_runtime_api::box_error::BoxError::from(e))
             })?;
             generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, headers);
             let generic = generic_builder.build();
             let error_code = match generic.code() {
                 ::std::option::Option::Some(code) => code,
                 ::std::option::Option::None => {
                     return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                         ::aws_smithy_runtime_api::box_error::BoxError::from(crate::operation::invoke_async::InvokeAsyncError::unhandled(generic)),
                     ))
-+
+                }
             };
             let _error_message = generic.message().map(|msg| msg.to_owned());
             let protocol = _cfg
                 .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
                 .expect("a SharedClientProtocol is required");
             let err = match error_code {
                 "InvalidRequestContentException" => crate::operation::invoke_async::InvokeAsyncError::InvalidRequestContentException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InvalidRequestContentException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InvalidRequestContentException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "InvalidRuntimeException" => crate::operation::invoke_async::InvokeAsyncError::InvalidRuntimeException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InvalidRuntimeException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InvalidRuntimeException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "ResourceConflictException" => crate::operation::invoke_async::InvokeAsyncError::ResourceConflictException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ResourceConflictException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ResourceConflictException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "ResourceNotFoundException" => crate::operation::invoke_async::InvokeAsyncError::ResourceNotFoundException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ResourceNotFoundException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ResourceNotFoundException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 "ServiceException" => crate::operation::invoke_async::InvokeAsyncError::ServiceException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ServiceException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ServiceException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 }),
                 _ => crate::operation::invoke_async::InvokeAsyncError::generic(generic),
             };
             ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::operation(
                 ::aws_smithy_runtime_api::client::interceptors::context::Error::erase(err),
             ))
         } else {
             crate::protocol_serde::shape_invoke_async::de_invoke_async_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
             let protocol = _cfg
                 .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
                 .expect("a SharedClientProtocol is required");
             let mut deser = protocol.deserialize_response(response, InvokeAsync::OUTPUT_SCHEMA, _cfg).map_err(|e| {
                 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(::aws_smithy_runtime_api::box_error::BoxError::from(e))
             })?;
             let body = response.body().bytes().expect("body loaded");
             let output = crate::operation::invoke_async::InvokeAsyncOutput::deserialize_with_response(
                 &mut *deser,
                 response.headers(),
                 response.status().into(),
                 body,
-+
+            )
             .map_err(|e| {
                 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(::aws_smithy_runtime_api::box_error::BoxError::from(e))
             })?;
             ::std::result::Result::Ok(::aws_smithy_runtime_api::client::interceptors::context::Output::erase(output))
-+
+        }
-323
+    }
-324
+}
 #[derive(Debug)]
 struct InvokeAsyncRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for InvokeAsyncRequestSerializer {
     #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
     fn serialize_input(
         &self,
         input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
         _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
         let input = input
             .downcast::<crate::operation::invoke_async::InvokeAsyncInput>()
             .expect("correct type");
         let _header_serialization_settings = _cfg
             .load::<crate::serialization_settings::HeaderSerializationSettings>()
             .cloned()
             .unwrap_or_default();
         let mut request_builder = {
             #[allow(clippy::uninlined_format_args)]
             fn uri_base(
                 _input: &crate::operation::invoke_async::InvokeAsyncInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 let input_1 = &_input.function_name;
                 let input_1 = input_1
                     .as_ref()
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("function_name", "cannot be empty or unset"))?;
                 let function_name = ::aws_smithy_http::label::fmt_string(input_1, ::aws_smithy_http::label::EncodingStrategy::Default);
                 if function_name.is_empty() {
                     return ::std::result::Result::Err(::aws_smithy_types::error::operation::BuildError::missing_field(
                         "function_name",
                         "cannot be empty or unset",
                     ));
--
+                }
                 ::std::write!(output, "/2014-11-13/functions/{FunctionName}/invoke-async", FunctionName = function_name)
                     .expect("formatting should succeed");
                 ::std::result::Result::Ok(())
--
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::invoke_async::InvokeAsyncInput,
                 builder: ::http_1x::request::Builder,
             ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
--
+            }
             let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/octet-stream");
             builder
         };
         let body = crate::protocol_serde::shape_invoke_async_input::ser_invoke_args_http_payload(input.invoke_args)?.into_inner();
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
         let protocol = _cfg
             .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
             .expect("a SharedClientProtocol is required");
         let mut request = protocol
             .serialize_request(&input, InvokeAsync::INPUT_SCHEMA, "", _cfg)
             .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
         // Streaming blob payload: replace the body with the raw ByteStream.
         *request.body_mut() = input.invoke_args.into_inner();
         request.headers_mut().insert("Content-Type", "application/octet-stream");
         if let ::std::option::Option::Some(content_length) = request.body().content_length() {
             request.headers_mut().insert("Content-Length", content_length.to_string());
-348
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-+
         return ::std::result::Result::Ok(request);
-351
+    }
-352
+}
 #[derive(Debug)]
 struct InvokeAsyncEndpointParamsInterceptor;
-355
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for InvokeAsyncEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "InvokeAsyncEndpointParamsInterceptor"
-359
+    }
-360

↧ Expand context

     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<InvokeAsyncInput>()
             .ok_or("failed to downcast to InvokeAsyncInput")?;
-375
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))

AWS SDK

Files changed:

tmp-codegen-diff/aws-sdk/sdk/lambda/src/operation/invoke.rs

tmp-codegen-diff/aws-sdk/sdk/lambda/src/operation/invoke/_invoke_input.rs

tmp-codegen-diff/aws-sdk/sdk/lambda/src/operation/invoke/_invoke_output.rs

tmp-codegen-diff/aws-sdk/sdk/lambda/src/operation/invoke_async.rs