AWS SDK

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// Orchestration and serialization glue logic for `ListAliases`.
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct ListAliases;
 impl ListAliases {
     /// Creates a new `ListAliases`
     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::list_aliases::ListAliasesInput::SCHEMA;
     /// The schema for this operation's output shape.
     pub const OUTPUT_SCHEMA: &'static ::aws_smithy_schema::Schema = crate::operation::list_aliases::ListAliasesOutput::SCHEMA;
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::list_aliases::ListAliasesInput,
     ) -> ::std::result::Result<
         crate::operation::list_aliases::ListAliasesOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::list_aliases::ListAliasesError,
             ::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::list_aliases::ListAliasesError>()
                     .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::list_aliases::ListAliasesOutput>()
                 .expect("correct output type"),
-42
+        )
-43
+    }
-44

@@ -115,119 +268,351 @@

↥ Expand context

         });
-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("ListAliases")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(ListAliasesEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::list_aliases::ListAliasesError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::list_aliases::ListAliasesError,
             >::new())
             .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<

                 crate::operation::list_aliases::ListAliasesError,
             >::new());
-141
         ::std::borrow::Cow::Owned(rcb)
-143
+    }
-144
+}
-145
 #[derive(Debug)]
 struct ListAliasesResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for ListAliasesResponseDeserializer {
     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_list_aliases::de_list_aliases_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::list_aliases::ListAliasesError::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 {
                 "InvalidParameterValueException" => crate::operation::list_aliases::ListAliasesError::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
                 }),
                 "ResourceNotFoundException" => crate::operation::list_aliases::ListAliasesError::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::list_aliases::ListAliasesError::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
                 }),
                 "TooManyRequestsException" => crate::operation::list_aliases::ListAliasesError::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
                 }),
                 _ => crate::operation::list_aliases::ListAliasesError::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_list_aliases::de_list_aliases_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, ListAliases::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::list_aliases::ListAliasesOutput::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))
-+
+        }
-300
+    }
-301
+}
 #[derive(Debug)]
 struct ListAliasesRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for ListAliasesRequestSerializer {
     #[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::list_aliases::ListAliasesInput>()
             .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::list_aliases::ListAliasesInput,
                 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}/aliases", FunctionName = function_name)
                     .expect("formatting should succeed");
                 ::std::result::Result::Ok(())
--
+            }
             fn uri_query(
                 _input: &crate::operation::list_aliases::ListAliasesInput,
                 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.function_version {
--
+                    {
                         query.push_kv("FunctionVersion", &::aws_smithy_http::query::fmt_string(inner_2));
--
+                    }
--
+                }
                 if let ::std::option::Option::Some(inner_3) = &_input.marker {
--
+                    {
                         query.push_kv("Marker", &::aws_smithy_http::query::fmt_string(inner_3));
--
+                    }
--
+                }
                 if let ::std::option::Option::Some(inner_4) = &_input.max_items {
--
+                    {
                         query.push_kv("MaxItems", ::aws_smithy_types::primitive::Encoder::from(*inner_4).encode());
--
+                    }
--
+                }
                 ::std::result::Result::Ok(())
--
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::list_aliases::ListAliasesInput,
                 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)?;
                 ::std::result::Result::Ok(builder.method("GET").uri(uri))
--
+            }
             let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from("");
         let protocol = _cfg
             .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
             .expect("a SharedClientProtocol is required");
         let mut request = protocol
             .serialize_request(&input, ListAliases::INPUT_SCHEMA, "", _cfg)
             .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
-320
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
         return ::std::result::Result::Ok(request);
-322
+    }
-323
+}
 #[derive(Debug)]
 struct ListAliasesEndpointParamsInterceptor;
-326
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ListAliasesEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ListAliasesEndpointParamsInterceptor"
-330
+    }
-331

↧ 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::<ListAliasesInput>()
             .ok_or("failed to downcast to ListAliasesInput")?;
-346
         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()))

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

@@ -35,35 +203,220 @@

↥ Expand context

     /// </ul>
     /// <p>The length constraint applies only to the full ARN. If you specify only the function name, it is limited to 64 characters in length.</p>
     pub fn function_name(&self) -> ::std::option::Option<&str> {
         self.function_name.as_deref()
-39
+    }
     /// <p>Specify a function version to only list aliases that invoke that version.</p>
     pub fn function_version(&self) -> ::std::option::Option<&str> {
         self.function_version.as_deref()
-43
+    }
     /// <p>Specify the pagination token that's returned by a previous request to retrieve the next page of results.</p>
     pub fn marker(&self) -> ::std::option::Option<&str> {
         self.marker.as_deref()
-47
+    }
     /// <p>Limit the number of aliases returned.</p>
     pub fn max_items(&self) -> ::std::option::Option<i32> {
         self.max_items
-51
+    }
-52
+}
 static LISTALIASESINPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.lambda.synthetic#ListAliasesInput",

     "com.amazonaws.lambda.synthetic",
     "ListAliasesInput",
 );
 static LISTALIASESINPUT_MEMBER_FUNCTION_NAME: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListAliasesInput$FunctionName",
         "com.amazonaws.lambda.synthetic",
         "ListAliasesInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "function_name",
     "FunctionName",
 ,
-67
+)
 .with_http_label();
 static LISTALIASESINPUT_MEMBER_FUNCTION_VERSION: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListAliasesInput$FunctionVersion",
         "com.amazonaws.lambda.synthetic",
         "ListAliasesInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "function_version",
     "FunctionVersion",
 ,
-78
+)
 .with_http_query("FunctionVersion");
 static LISTALIASESINPUT_MEMBER_MARKER: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListAliasesInput$Marker",
         "com.amazonaws.lambda.synthetic",
         "ListAliasesInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "marker",
     "Marker",
 ,
-89
+)
 .with_http_query("Marker");
 static LISTALIASESINPUT_MEMBER_MAX_ITEMS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListAliasesInput$MaxItems",
         "com.amazonaws.lambda.synthetic",
         "ListAliasesInput",
     ),
     ::aws_smithy_schema::ShapeType::Integer,
     "max_items",
     "MaxItems",
 ,
-100
+)
 .with_http_query("MaxItems");
 static LISTALIASESINPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     LISTALIASESINPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &LISTALIASESINPUT_MEMBER_FUNCTION_NAME,
         &LISTALIASESINPUT_MEMBER_FUNCTION_VERSION,
         &LISTALIASESINPUT_MEMBER_MARKER,
         &LISTALIASESINPUT_MEMBER_MAX_ITEMS,
     ],
 );
-+
+)
 .with_http(aws_smithy_schema::traits::HttpTrait::new(
     "GET",
     "/2015-03-31/functions/{FunctionName}/aliases",
     None,
 ));
 impl ListAliasesInput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &LISTALIASESINPUT_SCHEMA;
-120
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for ListAliasesInput {
     #[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(&LISTALIASESINPUT_MEMBER_FUNCTION_NAME, val)?;
-129
+        }
         if let Some(ref val) = self.function_version {
             ser.write_string(&LISTALIASESINPUT_MEMBER_FUNCTION_VERSION, val)?;
-132
+        }
         if let Some(ref val) = self.marker {
             ser.write_string(&LISTALIASESINPUT_MEMBER_MARKER, val)?;
-135
+        }
         if let Some(ref val) = self.max_items {
             ser.write_integer(&LISTALIASESINPUT_MEMBER_MAX_ITEMS, *val)?;
-138
+        }
         Ok(())
-140
+    }
-141
+}
 impl ListAliasesInput {
     /// 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(&LISTALIASESINPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&LISTALIASESINPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.function_name = Some(deser.read_string(member)?);
-160
+                }
                 Some(1) => {
                     builder.function_version = Some(deser.read_string(member)?);
-163
+                }
                 Some(2) => {
                     builder.marker = Some(deser.read_string(member)?);
-166
+                }
                 Some(3) => {
                     builder.max_items = Some(deser.read_integer(member)?);
-169
+                }
                 _ => {}
-171
+            }
             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() })
-178
+    }
-179
+}
 impl ListAliasesInput {
     /// Deserializes this structure from a body deserializer and HTTP response.
     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> {
         Self::deserialize(deserializer)
-+
+    }
-+
+}
 impl ListAliasesInput {
     /// Creates a new builder-style object to manufacture [`ListAliasesInput`](crate::operation::list_aliases::ListAliasesInput).
     pub fn builder() -> crate::operation::list_aliases::builders::ListAliasesInputBuilder {
         crate::operation::list_aliases::builders::ListAliasesInputBuilder::default()
-195
+    }
-196
+}
-197
 /// A builder for [`ListAliasesInput`](crate::operation::list_aliases::ListAliasesInput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]

↧ Expand context

 pub struct ListAliasesInputBuilder {
     pub(crate) function_name: ::std::option::Option<::std::string::String>,
     pub(crate) function_version: ::std::option::Option<::std::string::String>,
     pub(crate) marker: ::std::option::Option<::std::string::String>,
     pub(crate) max_items: ::std::option::Option<i32>,
-206
+}
 impl ListAliasesInputBuilder {
     /// <p>The name or ARN of the Lambda function.</p>
     /// <p class="title"><b>Name formats</b></p>
     /// <ul>
     /// <li>
     /// <p><b>Function name</b> - <code>MyFunction</code>.</p></li>
     /// <li>
     /// <p><b>Function ARN</b> - <code>arn:aws:lambda:us-west-2:123456789012:function:MyFunction</code>.</p></li>
     /// <li>
     /// <p><b>Partial ARN</b> - <code>123456789012:function:MyFunction</code>.</p></li>
     /// </ul>
     /// <p>The length constraint applies only to the full ARN. If you specify only the function name, it is limited to 64 characters in length.</p>
     /// This field is required.
     pub fn function_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {

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

@@ -6,6 +140,195 @@

↥ Expand context

     /// <p>The pagination token that's included if more results are available.</p>
     pub next_marker: ::std::option::Option<::std::string::String>,
     /// <p>A list of aliases.</p>
     pub aliases: ::std::option::Option<::std::vec::Vec<crate::types::AliasConfiguration>>,
     _request_id: Option<String>,
-11
+}
 impl ListAliasesOutput {
     /// <p>The pagination token that's included if more results are available.</p>
     pub fn next_marker(&self) -> ::std::option::Option<&str> {
         self.next_marker.as_deref()
-16
+    }
     /// <p>A list of aliases.</p>
     ///
     /// If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use `.aliases.is_none()`.
     pub fn aliases(&self) -> &[crate::types::AliasConfiguration] {
         self.aliases.as_deref().unwrap_or_default()
-22
+    }
-23
+}
 static LISTALIASESOUTPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.lambda.synthetic#ListAliasesOutput",

     "com.amazonaws.lambda.synthetic",
     "ListAliasesOutput",
 );
 static LISTALIASESOUTPUT_MEMBER_NEXT_MARKER: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListAliasesOutput$NextMarker",
         "com.amazonaws.lambda.synthetic",
         "ListAliasesOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "next_marker",
     "NextMarker",
 ,
 );
 static LISTALIASESOUTPUT_MEMBER_ALIASES: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListAliasesOutput$Aliases",
         "com.amazonaws.lambda.synthetic",
         "ListAliasesOutput",
     ),
     ::aws_smithy_schema::ShapeType::List,
     "aliases",
     "Aliases",
 ,
 );
 static LISTALIASESOUTPUT_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 LISTALIASESOUTPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     LISTALIASESOUTPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[&LISTALIASESOUTPUT_MEMBER_NEXT_MARKER, &LISTALIASESOUTPUT_MEMBER_ALIASES],
     &[
         &LISTALIASESOUTPUT_MEMBER_NEXT_MARKER,
         &LISTALIASESOUTPUT_MEMBER_ALIASES,
         &LISTALIASESOUTPUT_MEMBER__REQUEST_ID,
     ],
 );
 impl ListAliasesOutput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &LISTALIASESOUTPUT_SCHEMA;
-68
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for ListAliasesOutput {
     #[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.next_marker {
             ser.write_string(&LISTALIASESOUTPUT_MEMBER_NEXT_MARKER, val)?;
-77
+        }
         if let Some(ref val) = self.aliases {
             ser.write_list(
                 &LISTALIASESOUTPUT_MEMBER_ALIASES,
                 &|ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer| {
                     for item in val {
                         ser.write_struct(crate::types::AliasConfiguration::SCHEMA, item)?;
-84
+                    }
                     Ok(())
                 },
             )?;
-88
+        }
         Ok(())
-90
+    }
-91
+}
 impl ListAliasesOutput {
     /// 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(&LISTALIASESOUTPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&LISTALIASESOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.next_marker = Some(deser.read_string(member)?);
-+
+                }
                 Some(1) => {
                     builder.aliases = Some({
                         let mut container = Vec::new();
                         deser.read_list(member, &mut |deser| {
                             container.push(crate::types::AliasConfiguration::deserialize(deser)?);
                             Ok(())
                         })?;
                         container
                     });
-+
+                }
                 Some(2) => {
                     builder._request_id = Some(deser.read_string(member)?);
-+
+                }
                 _ => {}
-+
+            }
             Ok(())
         })?;
         Ok(builder.build())
-+
+    }
-+
+}
 impl ListAliasesOutput {
     /// 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-amzn-requestid") {
             builder._request_id = Some(val.to_string());
-+
+        }
         #[allow(
             unused_variables,
             unreachable_code,
             clippy::single_match,
             clippy::match_single_binding,
             clippy::diverging_sub_expression
         )]
         deserializer.read_struct(&LISTALIASESOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.next_marker = Some(deser.read_string(member)?);
-157
+                }
                 Some(1) => {
                     builder.aliases = Some({
                         let container = if let Some(cap) = deser.container_size() {
                             Vec::with_capacity(cap)
                         } else {
                             Vec::new()
                         };
                         deser.read_list(member, container, |mut list, deser| {
                             list.push(crate::types::AliasConfiguration::deserialize(deser)?);
                             Ok(list)
                         })?
                         let mut container = Vec::new();
                         deser.read_list(member, &mut |deser| {
                             container.push(crate::types::AliasConfiguration::deserialize(deser)?);
                             Ok(())
                         })?;
                         container
                     });
-167
+                }
                 _ => {}
-169
+            }
             Ok(())
         })?;
         Ok(builder.build())
-173
+    }
-174
+}
 impl ::aws_types::request_id::RequestId for ListAliasesOutput {

↧ Expand context

     fn request_id(&self) -> Option<&str> {
         self._request_id.as_deref()
-178
+    }
-179
+}
 impl ListAliasesOutput {
     /// Creates a new builder-style object to manufacture [`ListAliasesOutput`](crate::operation::list_aliases::ListAliasesOutput).
     pub fn builder() -> crate::operation::list_aliases::builders::ListAliasesOutputBuilder {
         crate::operation::list_aliases::builders::ListAliasesOutputBuilder::default()
-184
+    }
-185
+}
-186
 /// A builder for [`ListAliasesOutput`](crate::operation::list_aliases::ListAliasesOutput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct ListAliasesOutputBuilder {
     pub(crate) next_marker: ::std::option::Option<::std::string::String>,
     pub(crate) aliases: ::std::option::Option<::std::vec::Vec<crate::types::AliasConfiguration>>,
     _request_id: Option<String>,
-194
+}
 impl ListAliasesOutputBuilder {

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// Orchestration and serialization glue logic for `ListCodeSigningConfigs`.
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct ListCodeSigningConfigs;
 impl ListCodeSigningConfigs {
     /// Creates a new `ListCodeSigningConfigs`
     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::list_code_signing_configs::ListCodeSigningConfigsInput::SCHEMA;
     /// The schema for this operation's output shape.
     pub const OUTPUT_SCHEMA: &'static ::aws_smithy_schema::Schema = crate::operation::list_code_signing_configs::ListCodeSigningConfigsOutput::SCHEMA;
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::list_code_signing_configs::ListCodeSigningConfigsInput,
     ) -> ::std::result::Result<
         crate::operation::list_code_signing_configs::ListCodeSigningConfigsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::list_code_signing_configs::ListCodeSigningConfigsError,
             ::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::list_code_signing_configs::ListCodeSigningConfigsError>()
                     .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::list_code_signing_configs::ListCodeSigningConfigsOutput>()
                 .expect("correct output type"),
-42
+        )
-43
+    }
-44

@@ -118,122 +254,312 @@

↥ Expand context

         });
-123
         ::std::option::Option::Some(cfg.freeze())
-125
+    }
-126
     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("ListCodeSigningConfigs")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(ListCodeSigningConfigsEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::list_code_signing_configs::ListCodeSigningConfigsError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::list_code_signing_configs::ListCodeSigningConfigsError,
             >::new())
             .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<

                 crate::operation::list_code_signing_configs::ListCodeSigningConfigsError,
             >::new());
-144
         ::std::borrow::Cow::Owned(rcb)
-146
+    }
-147
+}
-148
 #[derive(Debug)]
 struct ListCodeSigningConfigsResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for ListCodeSigningConfigsResponseDeserializer {
     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_list_code_signing_configs::de_list_code_signing_configs_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::list_code_signing_configs::ListCodeSigningConfigsError::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 {
                 "InvalidParameterValueException" => {
                     crate::operation::list_code_signing_configs::ListCodeSigningConfigsError::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
                     })
-+
+                }
                 "ServiceException" => crate::operation::list_code_signing_configs::ListCodeSigningConfigsError::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::list_code_signing_configs::ListCodeSigningConfigsError::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_list_code_signing_configs::de_list_code_signing_configs_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, ListCodeSigningConfigs::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::list_code_signing_configs::ListCodeSigningConfigsOutput::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))
-+
+        }
-261
+    }
-262
+}
 #[derive(Debug)]
 struct ListCodeSigningConfigsRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for ListCodeSigningConfigsRequestSerializer {
     #[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::list_code_signing_configs::ListCodeSigningConfigsInput>()
             .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::list_code_signing_configs::ListCodeSigningConfigsInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/2020-04-22/code-signing-configs").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
--
+            }
             fn uri_query(
                 _input: &crate::operation::list_code_signing_configs::ListCodeSigningConfigsInput,
                 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_1) = &_input.marker {
--
+                    {
                         query.push_kv("Marker", &::aws_smithy_http::query::fmt_string(inner_1));
--
+                    }
--
+                }
                 if let ::std::option::Option::Some(inner_2) = &_input.max_items {
--
+                    {
                         query.push_kv("MaxItems", ::aws_smithy_types::primitive::Encoder::from(*inner_2).encode());
--
+                    }
--
+                }
                 ::std::result::Result::Ok(())
--
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::list_code_signing_configs::ListCodeSigningConfigsInput,
                 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)?;
                 ::std::result::Result::Ok(builder.method("GET").uri(uri))
--
+            }
             let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from("");
         let protocol = _cfg
             .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
             .expect("a SharedClientProtocol is required");
         let mut request = protocol
             .serialize_request(&input, ListCodeSigningConfigs::INPUT_SCHEMA, "", _cfg)
             .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
-281
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
         return ::std::result::Result::Ok(request);
-283
+    }
-284
+}
 #[derive(Debug)]
 struct ListCodeSigningConfigsEndpointParamsInterceptor;
-287
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ListCodeSigningConfigsEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ListCodeSigningConfigsEndpointParamsInterceptor"
-291
+    }
-292

↧ 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::<ListCodeSigningConfigsInput>()
             .ok_or("failed to downcast to ListCodeSigningConfigsInput")?;
-307
         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()))

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

@@ -3,3 +132,144 @@

↥ Expand context

 #[non_exhaustive]
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct ListCodeSigningConfigsInput {
     /// <p>Specify the pagination token that's returned by a previous request to retrieve the next page of results.</p>
     pub marker: ::std::option::Option<::std::string::String>,
     /// <p>Maximum number of items to return.</p>
     pub max_items: ::std::option::Option<i32>,
-10
+}
 impl ListCodeSigningConfigsInput {
     /// <p>Specify the pagination token that's returned by a previous request to retrieve the next page of results.</p>
     pub fn marker(&self) -> ::std::option::Option<&str> {
         self.marker.as_deref()
-15
+    }
     /// <p>Maximum number of items to return.</p>
     pub fn max_items(&self) -> ::std::option::Option<i32> {
         self.max_items
-19
+    }
-20
+}
 static LISTCODESIGNINGCONFIGSINPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.lambda.synthetic#ListCodeSigningConfigsInput",

     "com.amazonaws.lambda.synthetic",
     "ListCodeSigningConfigsInput",
 );
 static LISTCODESIGNINGCONFIGSINPUT_MEMBER_MARKER: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListCodeSigningConfigsInput$Marker",
         "com.amazonaws.lambda.synthetic",
         "ListCodeSigningConfigsInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "marker",
     "Marker",
 ,
-35
+)
 .with_http_query("Marker");
 static LISTCODESIGNINGCONFIGSINPUT_MEMBER_MAX_ITEMS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListCodeSigningConfigsInput$MaxItems",
         "com.amazonaws.lambda.synthetic",
         "ListCodeSigningConfigsInput",
     ),
     ::aws_smithy_schema::ShapeType::Integer,
     "max_items",
     "MaxItems",
 ,
-46
+)
 .with_http_query("MaxItems");
 static LISTCODESIGNINGCONFIGSINPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     LISTCODESIGNINGCONFIGSINPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[&LISTCODESIGNINGCONFIGSINPUT_MEMBER_MARKER, &LISTCODESIGNINGCONFIGSINPUT_MEMBER_MAX_ITEMS],
 );
-+
+)
 .with_http(aws_smithy_schema::traits::HttpTrait::new("GET", "/2020-04-22/code-signing-configs", None));
 impl ListCodeSigningConfigsInput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &LISTCODESIGNINGCONFIGSINPUT_SCHEMA;
-57
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for ListCodeSigningConfigsInput {
     #[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.marker {
             ser.write_string(&LISTCODESIGNINGCONFIGSINPUT_MEMBER_MARKER, val)?;
-66
+        }
         if let Some(ref val) = self.max_items {
             ser.write_integer(&LISTCODESIGNINGCONFIGSINPUT_MEMBER_MAX_ITEMS, *val)?;
-69
+        }
         Ok(())
-71
+    }
-72
+}
 impl ListCodeSigningConfigsInput {
     /// 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(&LISTCODESIGNINGCONFIGSINPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&LISTCODESIGNINGCONFIGSINPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.marker = Some(deser.read_string(member)?);
-91
+                }
                 Some(1) => {
                     builder.max_items = Some(deser.read_integer(member)?);
-94
+                }
                 _ => {}
-96
+            }
             Ok(())
         })?;
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-102
+    }
-103
+}
 impl ListCodeSigningConfigsInput {
     /// Deserializes this structure from a body deserializer and HTTP response.
     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> {
         Self::deserialize(deserializer)
-+
+    }
-+
+}
 impl ListCodeSigningConfigsInput {
     /// Creates a new builder-style object to manufacture [`ListCodeSigningConfigsInput`](crate::operation::list_code_signing_configs::ListCodeSigningConfigsInput).
     pub fn builder() -> crate::operation::list_code_signing_configs::builders::ListCodeSigningConfigsInputBuilder {
         crate::operation::list_code_signing_configs::builders::ListCodeSigningConfigsInputBuilder::default()
-119
+    }
-120
+}
-121
 /// A builder for [`ListCodeSigningConfigsInput`](crate::operation::list_code_signing_configs::ListCodeSigningConfigsInput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]

↧ Expand context

 pub struct ListCodeSigningConfigsInputBuilder {
     pub(crate) marker: ::std::option::Option<::std::string::String>,
     pub(crate) max_items: ::std::option::Option<i32>,
-128
+}
 impl ListCodeSigningConfigsInputBuilder {
     /// <p>Specify the pagination token that's returned by a previous request to retrieve the next page of results.</p>
     pub fn marker(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         self.marker = ::std::option::Option::Some(input.into());
         self
-134
+    }
     /// <p>Specify the pagination token that's returned by a previous request to retrieve the next page of results.</p>
     pub fn set_marker(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         self.marker = input;
         self
-139
+    }
     /// <p>Specify the pagination token that's returned by a previous request to retrieve the next page of results.</p>
     pub fn get_marker(&self) -> &::std::option::Option<::std::string::String> {
         &self.marker
-143
+    }
     /// <p>Maximum number of items to return.</p>

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

@@ -6,6 +143,195 @@

↥ Expand context

     /// <p>The pagination token that's included if more results are available.</p>
     pub next_marker: ::std::option::Option<::std::string::String>,
     /// <p>The code signing configurations</p>
     pub code_signing_configs: ::std::option::Option<::std::vec::Vec<crate::types::CodeSigningConfig>>,
     _request_id: Option<String>,
-11
+}
 impl ListCodeSigningConfigsOutput {
     /// <p>The pagination token that's included if more results are available.</p>
     pub fn next_marker(&self) -> ::std::option::Option<&str> {
         self.next_marker.as_deref()
-16
+    }
     /// <p>The code signing configurations</p>
     ///
     /// If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use `.code_signing_configs.is_none()`.
     pub fn code_signing_configs(&self) -> &[crate::types::CodeSigningConfig] {
         self.code_signing_configs.as_deref().unwrap_or_default()
-22
+    }
-23
+}
 static LISTCODESIGNINGCONFIGSOUTPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.lambda.synthetic#ListCodeSigningConfigsOutput",

     "com.amazonaws.lambda.synthetic",
     "ListCodeSigningConfigsOutput",
 );
 static LISTCODESIGNINGCONFIGSOUTPUT_MEMBER_NEXT_MARKER: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListCodeSigningConfigsOutput$NextMarker",
         "com.amazonaws.lambda.synthetic",
         "ListCodeSigningConfigsOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "next_marker",
     "NextMarker",
 ,
 );
 static LISTCODESIGNINGCONFIGSOUTPUT_MEMBER_CODE_SIGNING_CONFIGS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListCodeSigningConfigsOutput$CodeSigningConfigs",
         "com.amazonaws.lambda.synthetic",
         "ListCodeSigningConfigsOutput",
     ),
     ::aws_smithy_schema::ShapeType::List,
     "code_signing_configs",
     "CodeSigningConfigs",
 ,
 );
 static LISTCODESIGNINGCONFIGSOUTPUT_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 LISTCODESIGNINGCONFIGSOUTPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     LISTCODESIGNINGCONFIGSOUTPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &LISTCODESIGNINGCONFIGSOUTPUT_MEMBER_NEXT_MARKER,
         &LISTCODESIGNINGCONFIGSOUTPUT_MEMBER_CODE_SIGNING_CONFIGS,
         &LISTCODESIGNINGCONFIGSOUTPUT_MEMBER__REQUEST_ID,
     ],
 );
 impl ListCodeSigningConfigsOutput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &LISTCODESIGNINGCONFIGSOUTPUT_SCHEMA;
-68
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for ListCodeSigningConfigsOutput {
     #[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.next_marker {
             ser.write_string(&LISTCODESIGNINGCONFIGSOUTPUT_MEMBER_NEXT_MARKER, val)?;
-77
+        }
         if let Some(ref val) = self.code_signing_configs {
             ser.write_list(
                 &LISTCODESIGNINGCONFIGSOUTPUT_MEMBER_CODE_SIGNING_CONFIGS,
                 &|ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer| {
                     for item in val {
                         ser.write_struct(crate::types::CodeSigningConfig::SCHEMA, item)?;
-84
+                    }
                     Ok(())
                 },
             )?;
-88
+        }
         Ok(())
-90
+    }
-91
+}
 impl ListCodeSigningConfigsOutput {
     /// 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(&LISTCODESIGNINGCONFIGSOUTPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&LISTCODESIGNINGCONFIGSOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.next_marker = Some(deser.read_string(member)?);
-+
+                }
                 Some(1) => {
                     builder.code_signing_configs = Some({
                         let mut container = Vec::new();
                         deser.read_list(member, &mut |deser| {
                             container.push(crate::types::CodeSigningConfig::deserialize(deser)?);
                             Ok(())
                         })?;
                         container
                     });
-+
+                }
                 Some(2) => {
                     builder._request_id = Some(deser.read_string(member)?);
-+
+                }
                 _ => {}
-+
+            }
             Ok(())
         })?;
         Ok(builder.build())
-+
+    }
-+
+}
 impl ListCodeSigningConfigsOutput {
     /// 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-amzn-requestid") {
             builder._request_id = Some(val.to_string());
-+
+        }
         #[allow(
             unused_variables,
             unreachable_code,
             clippy::single_match,
             clippy::match_single_binding,
             clippy::diverging_sub_expression
         )]
         deserializer.read_struct(&LISTCODESIGNINGCONFIGSOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.next_marker = Some(deser.read_string(member)?);
-157
+                }
                 Some(1) => {
                     builder.code_signing_configs = Some({
                         let container = if let Some(cap) = deser.container_size() {
                             Vec::with_capacity(cap)
                         } else {
                             Vec::new()
                         };
                         deser.read_list(member, container, |mut list, deser| {
                             list.push(crate::types::CodeSigningConfig::deserialize(deser)?);
                             Ok(list)
                         })?
                         let mut container = Vec::new();
                         deser.read_list(member, &mut |deser| {
                             container.push(crate::types::CodeSigningConfig::deserialize(deser)?);
                             Ok(())
                         })?;
                         container
                     });
-167
+                }
                 _ => {}
-169
+            }
             Ok(())
         })?;
         Ok(builder.build())
-173
+    }
-174
+}
 impl ::aws_types::request_id::RequestId for ListCodeSigningConfigsOutput {

↧ Expand context

     fn request_id(&self) -> Option<&str> {
         self._request_id.as_deref()
-178
+    }
-179
+}
 impl ListCodeSigningConfigsOutput {
     /// Creates a new builder-style object to manufacture [`ListCodeSigningConfigsOutput`](crate::operation::list_code_signing_configs::ListCodeSigningConfigsOutput).
     pub fn builder() -> crate::operation::list_code_signing_configs::builders::ListCodeSigningConfigsOutputBuilder {
         crate::operation::list_code_signing_configs::builders::ListCodeSigningConfigsOutputBuilder::default()
-184
+    }
-185
+}
-186
 /// A builder for [`ListCodeSigningConfigsOutput`](crate::operation::list_code_signing_configs::ListCodeSigningConfigsOutput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct ListCodeSigningConfigsOutputBuilder {
     pub(crate) next_marker: ::std::option::Option<::std::string::String>,
     pub(crate) code_signing_configs: ::std::option::Option<::std::vec::Vec<crate::types::CodeSigningConfig>>,
     _request_id: Option<String>,
-194
+}
 impl ListCodeSigningConfigsOutputBuilder {

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

@@ -1,1 +40,45 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// Orchestration and serialization glue logic for `ListEventSourceMappings`.
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct ListEventSourceMappings;
 impl ListEventSourceMappings {
     /// Creates a new `ListEventSourceMappings`
     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::list_event_source_mappings::ListEventSourceMappingsInput::SCHEMA;
     /// The schema for this operation's output shape.
     pub const OUTPUT_SCHEMA: &'static ::aws_smithy_schema::Schema =
         crate::operation::list_event_source_mappings::ListEventSourceMappingsOutput::SCHEMA;
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::list_event_source_mappings::ListEventSourceMappingsInput,
     ) -> ::std::result::Result<
         crate::operation::list_event_source_mappings::ListEventSourceMappingsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::list_event_source_mappings::ListEventSourceMappingsError,
             ::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::list_event_source_mappings::ListEventSourceMappingsError>()
                     .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::list_event_source_mappings::ListEventSourceMappingsOutput>()
                 .expect("correct output type"),
-43
+        )
-44
+    }
-45

@@ -118,123 +264,363 @@

↥ Expand context

         });
-124
         ::std::option::Option::Some(cfg.freeze())
-126
+    }
-127
     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("ListEventSourceMappings")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(ListEventSourceMappingsEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::list_event_source_mappings::ListEventSourceMappingsError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::list_event_source_mappings::ListEventSourceMappingsError,
             >::new())
             .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<

                 crate::operation::list_event_source_mappings::ListEventSourceMappingsError,
             >::new());
-145
         ::std::borrow::Cow::Owned(rcb)
-147
+    }
-148
+}
-149
 #[derive(Debug)]
 struct ListEventSourceMappingsResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for ListEventSourceMappingsResponseDeserializer {
     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_list_event_source_mappings::de_list_event_source_mappings_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::list_event_source_mappings::ListEventSourceMappingsError::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 {
                 "InvalidParameterValueException" => {
                     crate::operation::list_event_source_mappings::ListEventSourceMappingsError::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
                     })
-+
+                }
                 "ResourceNotFoundException" => {
                     crate::operation::list_event_source_mappings::ListEventSourceMappingsError::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::list_event_source_mappings::ListEventSourceMappingsError::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
                 }),
                 "TooManyRequestsException" => crate::operation::list_event_source_mappings::ListEventSourceMappingsError::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
                 }),
                 _ => crate::operation::list_event_source_mappings::ListEventSourceMappingsError::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_list_event_source_mappings::de_list_event_source_mappings_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, ListEventSourceMappings::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::list_event_source_mappings::ListEventSourceMappingsOutput::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))
-+
+        }
-312
+    }
-313
+}
 #[derive(Debug)]
 struct ListEventSourceMappingsRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for ListEventSourceMappingsRequestSerializer {
     #[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::list_event_source_mappings::ListEventSourceMappingsInput>()
             .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::list_event_source_mappings::ListEventSourceMappingsInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/2015-03-31/event-source-mappings").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
--
+            }
             fn uri_query(
                 _input: &crate::operation::list_event_source_mappings::ListEventSourceMappingsInput,
                 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_1) = &_input.event_source_arn {
--
+                    {
                         query.push_kv("EventSourceArn", &::aws_smithy_http::query::fmt_string(inner_1));
--
+                    }
--
+                }
                 if let ::std::option::Option::Some(inner_2) = &_input.function_name {
--
+                    {
                         query.push_kv("FunctionName", &::aws_smithy_http::query::fmt_string(inner_2));
--
+                    }
--
+                }
                 if let ::std::option::Option::Some(inner_3) = &_input.marker {
--
+                    {
                         query.push_kv("Marker", &::aws_smithy_http::query::fmt_string(inner_3));
--
+                    }
--
+                }
                 if let ::std::option::Option::Some(inner_4) = &_input.max_items {
--
+                    {
                         query.push_kv("MaxItems", ::aws_smithy_types::primitive::Encoder::from(*inner_4).encode());
--
+                    }
--
+                }
                 ::std::result::Result::Ok(())
--
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::list_event_source_mappings::ListEventSourceMappingsInput,
                 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)?;
                 ::std::result::Result::Ok(builder.method("GET").uri(uri))
--
+            }
             let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from("");
         let protocol = _cfg
             .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
             .expect("a SharedClientProtocol is required");
         let mut request = protocol
             .serialize_request(&input, ListEventSourceMappings::INPUT_SCHEMA, "", _cfg)
             .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
-332
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
         return ::std::result::Result::Ok(request);
-334
+    }
-335
+}
 #[derive(Debug)]
 struct ListEventSourceMappingsEndpointParamsInterceptor;
-338
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ListEventSourceMappingsEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ListEventSourceMappingsEndpointParamsInterceptor"
-342
+    }
-343

↧ 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::<ListEventSourceMappingsInput>()
             .ok_or("failed to downcast to ListEventSourceMappingsInput")?;
-358
         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()))

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

@@ -67,67 +235,251 @@

↥ Expand context

     /// <li>
     /// <p><b>Version or Alias ARN</b> – <code>arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD</code>.</p></li>
     /// <li>
     /// <p><b>Partial ARN</b> – <code>123456789012:function:MyFunction</code>.</p></li>
     /// </ul>
     /// <p>The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 characters in length.</p>
     pub fn function_name(&self) -> ::std::option::Option<&str> {
         self.function_name.as_deref()
-75
+    }
     /// <p>A pagination token returned by a previous call.</p>
     pub fn marker(&self) -> ::std::option::Option<&str> {
         self.marker.as_deref()
-79
+    }
     /// <p>The maximum number of event source mappings to return. Note that ListEventSourceMappings returns a maximum of 100 items in each response, even if you set the number higher.</p>
     pub fn max_items(&self) -> ::std::option::Option<i32> {
         self.max_items
-83
+    }
-84
+}
 static LISTEVENTSOURCEMAPPINGSINPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.lambda.synthetic#ListEventSourceMappingsInput",

     "com.amazonaws.lambda.synthetic",
     "ListEventSourceMappingsInput",
 );
 static LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_EVENT_SOURCE_ARN: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListEventSourceMappingsInput$EventSourceArn",
         "com.amazonaws.lambda.synthetic",
         "ListEventSourceMappingsInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "event_source_arn",
     "EventSourceArn",
 ,
-99
+)
 .with_http_query("EventSourceArn");
 static LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_FUNCTION_NAME: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListEventSourceMappingsInput$FunctionName",
         "com.amazonaws.lambda.synthetic",
         "ListEventSourceMappingsInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "function_name",
     "FunctionName",
 ,
-110
+)
 .with_http_query("FunctionName");
 static LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_MARKER: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListEventSourceMappingsInput$Marker",
         "com.amazonaws.lambda.synthetic",
         "ListEventSourceMappingsInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "marker",
     "Marker",
 ,
-121
+)
 .with_http_query("Marker");
 static LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_MAX_ITEMS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListEventSourceMappingsInput$MaxItems",
         "com.amazonaws.lambda.synthetic",
         "ListEventSourceMappingsInput",
     ),
     ::aws_smithy_schema::ShapeType::Integer,
     "max_items",
     "MaxItems",
 ,
-132
+)
 .with_http_query("MaxItems");
 static LISTEVENTSOURCEMAPPINGSINPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     LISTEVENTSOURCEMAPPINGSINPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_EVENT_SOURCE_ARN,
         &LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_FUNCTION_NAME,
         &LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_MARKER,
         &LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_MAX_ITEMS,
     ],
 );
-+
+)
 .with_http(aws_smithy_schema::traits::HttpTrait::new(
     "GET",
     "/2015-03-31/event-source-mappings",
     None,
 ));
 impl ListEventSourceMappingsInput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &LISTEVENTSOURCEMAPPINGSINPUT_SCHEMA;
-152
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for ListEventSourceMappingsInput {
     #[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.event_source_arn {
             ser.write_string(&LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_EVENT_SOURCE_ARN, val)?;
-161
+        }
         if let Some(ref val) = self.function_name {
             ser.write_string(&LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_FUNCTION_NAME, val)?;
-164
+        }
         if let Some(ref val) = self.marker {
             ser.write_string(&LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_MARKER, val)?;
-167
+        }
         if let Some(ref val) = self.max_items {
             ser.write_integer(&LISTEVENTSOURCEMAPPINGSINPUT_MEMBER_MAX_ITEMS, *val)?;
-170
+        }
         Ok(())
-172
+    }
-173
+}
 impl ListEventSourceMappingsInput {
     /// 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(&LISTEVENTSOURCEMAPPINGSINPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&LISTEVENTSOURCEMAPPINGSINPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.event_source_arn = Some(deser.read_string(member)?);
-192
+                }
                 Some(1) => {
                     builder.function_name = Some(deser.read_string(member)?);
-195
+                }
                 Some(2) => {
                     builder.marker = Some(deser.read_string(member)?);
-198
+                }
                 Some(3) => {
                     builder.max_items = Some(deser.read_integer(member)?);
-201
+                }
                 _ => {}
-203
+            }
             Ok(())
         })?;
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-209
+    }
-210
+}
 impl ListEventSourceMappingsInput {
     /// Deserializes this structure from a body deserializer and HTTP response.
     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> {
         Self::deserialize(deserializer)
-+
+    }
-+
+}
 impl ListEventSourceMappingsInput {
     /// Creates a new builder-style object to manufacture [`ListEventSourceMappingsInput`](crate::operation::list_event_source_mappings::ListEventSourceMappingsInput).
     pub fn builder() -> crate::operation::list_event_source_mappings::builders::ListEventSourceMappingsInputBuilder {
         crate::operation::list_event_source_mappings::builders::ListEventSourceMappingsInputBuilder::default()
-226
+    }
-227
+}
-228
 /// A builder for [`ListEventSourceMappingsInput`](crate::operation::list_event_source_mappings::ListEventSourceMappingsInput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]

↧ Expand context

 pub struct ListEventSourceMappingsInputBuilder {
     pub(crate) event_source_arn: ::std::option::Option<::std::string::String>,
     pub(crate) function_name: ::std::option::Option<::std::string::String>,
     pub(crate) marker: ::std::option::Option<::std::string::String>,
     pub(crate) max_items: ::std::option::Option<i32>,
-237
+}
 impl ListEventSourceMappingsInputBuilder {
     /// <p>The Amazon Resource Name (ARN) of the event source.</p>
     /// <ul>
     /// <li>
     /// <p><b>Amazon Kinesis</b> – The ARN of the data stream or a stream consumer.</p></li>
     /// <li>
     /// <p><b>Amazon DynamoDB Streams</b> – The ARN of the stream.</p></li>
     /// <li>
     /// <p><b>Amazon Simple Queue Service</b> – The ARN of the queue.</p></li>
     /// <li>
     /// <p><b>Amazon Managed Streaming for Apache Kafka</b> – The ARN of the cluster or the ARN of the VPC connection (for <a href="https://docs.aws.amazon.com/lambda/latest/dg/with-msk.html#msk-multi-vpc">cross-account event source mappings</a>).</p></li>
     /// <li>
     /// <p><b>Amazon MQ</b> – The ARN of the broker.</p></li>
     /// <li>

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

@@ -6,6 +143,195 @@

↥ Expand context

     /// <p>A pagination token that's returned when the response doesn't contain all event source mappings.</p>
     pub next_marker: ::std::option::Option<::std::string::String>,
     /// <p>A list of event source mappings.</p>
     pub event_source_mappings: ::std::option::Option<::std::vec::Vec<crate::types::EventSourceMappingConfiguration>>,
     _request_id: Option<String>,
-11
+}
 impl ListEventSourceMappingsOutput {
     /// <p>A pagination token that's returned when the response doesn't contain all event source mappings.</p>
     pub fn next_marker(&self) -> ::std::option::Option<&str> {
         self.next_marker.as_deref()
-16
+    }
     /// <p>A list of event source mappings.</p>
     ///
     /// If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use `.event_source_mappings.is_none()`.
     pub fn event_source_mappings(&self) -> &[crate::types::EventSourceMappingConfiguration] {
         self.event_source_mappings.as_deref().unwrap_or_default()
-22
+    }
-23
+}
 static LISTEVENTSOURCEMAPPINGSOUTPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.lambda.synthetic#ListEventSourceMappingsOutput",

     "com.amazonaws.lambda.synthetic",
     "ListEventSourceMappingsOutput",
 );
 static LISTEVENTSOURCEMAPPINGSOUTPUT_MEMBER_NEXT_MARKER: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListEventSourceMappingsOutput$NextMarker",
         "com.amazonaws.lambda.synthetic",
         "ListEventSourceMappingsOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "next_marker",
     "NextMarker",
 ,
 );
 static LISTEVENTSOURCEMAPPINGSOUTPUT_MEMBER_EVENT_SOURCE_MAPPINGS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.lambda.synthetic#ListEventSourceMappingsOutput$EventSourceMappings",
         "com.amazonaws.lambda.synthetic",
         "ListEventSourceMappingsOutput",
     ),
     ::aws_smithy_schema::ShapeType::List,
     "event_source_mappings",
     "EventSourceMappings",
 ,
 );
 static LISTEVENTSOURCEMAPPINGSOUTPUT_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 LISTEVENTSOURCEMAPPINGSOUTPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     LISTEVENTSOURCEMAPPINGSOUTPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &LISTEVENTSOURCEMAPPINGSOUTPUT_MEMBER_NEXT_MARKER,
         &LISTEVENTSOURCEMAPPINGSOUTPUT_MEMBER_EVENT_SOURCE_MAPPINGS,
         &LISTEVENTSOURCEMAPPINGSOUTPUT_MEMBER__REQUEST_ID,
     ],
 );
 impl ListEventSourceMappingsOutput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &LISTEVENTSOURCEMAPPINGSOUTPUT_SCHEMA;
-68
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for ListEventSourceMappingsOutput {
     #[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.next_marker {
             ser.write_string(&LISTEVENTSOURCEMAPPINGSOUTPUT_MEMBER_NEXT_MARKER, val)?;
-77
+        }
         if let Some(ref val) = self.event_source_mappings {
             ser.write_list(
                 &LISTEVENTSOURCEMAPPINGSOUTPUT_MEMBER_EVENT_SOURCE_MAPPINGS,
                 &|ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer| {
                     for item in val {
                         ser.write_struct(crate::types::EventSourceMappingConfiguration::SCHEMA, item)?;
-84
+                    }
                     Ok(())
                 },
             )?;
-88
+        }
         Ok(())
-90
+    }
-91
+}
 impl ListEventSourceMappingsOutput {
     /// 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(&LISTEVENTSOURCEMAPPINGSOUTPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&LISTEVENTSOURCEMAPPINGSOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.next_marker = Some(deser.read_string(member)?);
-+
+                }
                 Some(1) => {
                     builder.event_source_mappings = Some({
                         let mut container = Vec::new();
                         deser.read_list(member, &mut |deser| {
                             container.push(crate::types::EventSourceMappingConfiguration::deserialize(deser)?);
                             Ok(())
                         })?;
                         container
                     });
-+
+                }
                 Some(2) => {
                     builder._request_id = Some(deser.read_string(member)?);
-+
+                }
                 _ => {}
-+
+            }
             Ok(())
         })?;
         Ok(builder.build())
-+
+    }
-+
+}
 impl ListEventSourceMappingsOutput {
     /// 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-amzn-requestid") {
             builder._request_id = Some(val.to_string());
-+
+        }
         #[allow(
             unused_variables,
             unreachable_code,
             clippy::single_match,
             clippy::match_single_binding,
             clippy::diverging_sub_expression
         )]
         deserializer.read_struct(&LISTEVENTSOURCEMAPPINGSOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.next_marker = Some(deser.read_string(member)?);
-157
+                }
                 Some(1) => {
                     builder.event_source_mappings = Some({
                         let container = if let Some(cap) = deser.container_size() {
                             Vec::with_capacity(cap)
                         } else {
                             Vec::new()
                         };
                         deser.read_list(member, container, |mut list, deser| {
                             list.push(crate::types::EventSourceMappingConfiguration::deserialize(deser)?);
                             Ok(list)
                         })?
                         let mut container = Vec::new();
                         deser.read_list(member, &mut |deser| {
                             container.push(crate::types::EventSourceMappingConfiguration::deserialize(deser)?);
                             Ok(())
                         })?;
                         container
                     });
-167
+                }
                 _ => {}
-169
+            }
             Ok(())
         })?;
         Ok(builder.build())
-173
+    }
-174
+}
 impl ::aws_types::request_id::RequestId for ListEventSourceMappingsOutput {

↧ Expand context

     fn request_id(&self) -> Option<&str> {
         self._request_id.as_deref()
-178
+    }
-179
+}
 impl ListEventSourceMappingsOutput {
     /// Creates a new builder-style object to manufacture [`ListEventSourceMappingsOutput`](crate::operation::list_event_source_mappings::ListEventSourceMappingsOutput).
     pub fn builder() -> crate::operation::list_event_source_mappings::builders::ListEventSourceMappingsOutputBuilder {
         crate::operation::list_event_source_mappings::builders::ListEventSourceMappingsOutputBuilder::default()
-184
+    }
-185
+}
-186
 /// A builder for [`ListEventSourceMappingsOutput`](crate::operation::list_event_source_mappings::ListEventSourceMappingsOutput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct ListEventSourceMappingsOutputBuilder {
     pub(crate) next_marker: ::std::option::Option<::std::string::String>,
     pub(crate) event_source_mappings: ::std::option::Option<::std::vec::Vec<crate::types::EventSourceMappingConfiguration>>,
     _request_id: Option<String>,
-194
+}
 impl ListEventSourceMappingsOutputBuilder {

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

@@ -1,1 +40,46 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// Orchestration and serialization glue logic for `ListFunctionEventInvokeConfigs`.
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct ListFunctionEventInvokeConfigs;
 impl ListFunctionEventInvokeConfigs {
     /// Creates a new `ListFunctionEventInvokeConfigs`
     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::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsInput::SCHEMA;
     /// The schema for this operation's output shape.
     pub const OUTPUT_SCHEMA: &'static ::aws_smithy_schema::Schema =
         crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsOutput::SCHEMA;
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsInput,
     ) -> ::std::result::Result<
         crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsError,
             ::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::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsError>()
                     .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::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsOutput>()
                 .expect("correct output type"),
-44
+        )
-45
+    }
-46

@@ -124,130 +278,372 @@

↥ Expand context

         });
-131
         ::std::option::Option::Some(cfg.freeze())
-133
+    }
-134
     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("ListFunctionEventInvokeConfigs")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(ListFunctionEventInvokeConfigsEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsError,
             >::new())
             .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<

                 crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsError,
             >::new());
-152
         ::std::borrow::Cow::Owned(rcb)
-154
+    }
-155
+}
-156
 #[derive(Debug)]
 struct ListFunctionEventInvokeConfigsResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for ListFunctionEventInvokeConfigsResponseDeserializer {
     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_list_function_event_invoke_configs::de_list_function_event_invoke_configs_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::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsError::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 {
                 "InvalidParameterValueException" => {
                     crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsError::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
                     })
-+
+                }
                 "ResourceNotFoundException" => {
                     crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsError::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::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsError::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
                 }),
                 "TooManyRequestsException" => {
                     crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsError::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
                     })
-+
+                }
                 _ => crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsError::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_list_function_event_invoke_configs::de_list_function_event_invoke_configs_http_response(
                 status, headers, body,
             let protocol = _cfg
                 .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
                 .expect("a SharedClientProtocol is required");
             let mut deser = protocol
                 .deserialize_response(response, ListFunctionEventInvokeConfigs::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::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsOutput::deserialize_with_response(
                 &mut *deser,
                 response.headers(),
                 response.status().into(),
                 body,
-315
+            )
         };
         crate::protocol_serde::type_erase_result(parse_result)
             .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))
-+
+        }
-321
+    }
-322
+}
 #[derive(Debug)]
 struct ListFunctionEventInvokeConfigsRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for ListFunctionEventInvokeConfigsRequestSerializer {
     #[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::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsInput>()
             .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::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsInput,
                 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,
                     "/2019-09-25/functions/{FunctionName}/event-invoke-config/list",
                     FunctionName = function_name
--
+                )
                 .expect("formatting should succeed");
                 ::std::result::Result::Ok(())
--
+            }
             fn uri_query(
                 _input: &crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsInput,
                 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.marker {
--
+                    {
                         query.push_kv("Marker", &::aws_smithy_http::query::fmt_string(inner_2));
--
+                    }
--
+                }
                 if let ::std::option::Option::Some(inner_3) = &_input.max_items {
--
+                    {
                         query.push_kv("MaxItems", ::aws_smithy_types::primitive::Encoder::from(*inner_3).encode());
--
+                    }
--
+                }
                 ::std::result::Result::Ok(())
--
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::list_function_event_invoke_configs::ListFunctionEventInvokeConfigsInput,
                 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)?;
                 ::std::result::Result::Ok(builder.method("GET").uri(uri))
--
+            }
             let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from("");
         let protocol = _cfg
             .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
             .expect("a SharedClientProtocol is required");
         let mut request = protocol
             .serialize_request(&input, ListFunctionEventInvokeConfigs::INPUT_SCHEMA, "", _cfg)
             .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
-341
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
         return ::std::result::Result::Ok(request);
-343
+    }
-344
+}
 #[derive(Debug)]
 struct ListFunctionEventInvokeConfigsEndpointParamsInterceptor;
-347
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ListFunctionEventInvokeConfigsEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ListFunctionEventInvokeConfigsEndpointParamsInterceptor"
-351
+    }
-352

↧ 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::<ListFunctionEventInvokeConfigsInput>()
             .ok_or("failed to downcast to ListFunctionEventInvokeConfigsInput")?;
-367
         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: