AWS SDK

tmp-codegen-diff/aws-sdk/sdk/timestreamquery/src/operation/update_account_settings.rs

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

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

@@ -124,128 +253,388 @@

↥ Expand context

         });
-129
         ::std::option::Option::Some(cfg.freeze())
-131
+    }
-132
     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("UpdateAccountSettings")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(UpdateAccountSettingsEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::update_account_settings::UpdateAccountSettingsError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::update_account_settings::UpdateAccountSettingsError,
             >::new())
             .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<

                 crate::operation::update_account_settings::UpdateAccountSettingsError,
             >::new());
-150
         ::std::borrow::Cow::Owned(rcb)
-152
+    }
-153
+}
-154
 #[derive(Debug)]
 struct UpdateAccountSettingsResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for UpdateAccountSettingsResponseDeserializer {
     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_update_account_settings::de_update_account_settings_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::update_account_settings::UpdateAccountSettingsError::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 {
                 "AccessDeniedException" => crate::operation::update_account_settings::UpdateAccountSettingsError::AccessDeniedException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::AccessDeniedException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::AccessDeniedException::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
                 }),
                 "InternalServerException" => crate::operation::update_account_settings::UpdateAccountSettingsError::InternalServerException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InternalServerException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InternalServerException::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
                 }),
                 "InvalidEndpointException" => crate::operation::update_account_settings::UpdateAccountSettingsError::InvalidEndpointException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InvalidEndpointException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InvalidEndpointException::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
                 }),
                 "ThrottlingException" => crate::operation::update_account_settings::UpdateAccountSettingsError::ThrottlingException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ThrottlingException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ThrottlingException::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
                 }),
                 "ValidationException" => crate::operation::update_account_settings::UpdateAccountSettingsError::ValidationException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ValidationException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ValidationException::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::update_account_settings::UpdateAccountSettingsError::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_update_account_settings::de_update_account_settings_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, UpdateAccountSettings::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::update_account_settings::UpdateAccountSettingsOutput::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))
-+
+        }
-337
+    }
-338
+}
 #[derive(Debug)]
 struct UpdateAccountSettingsRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for UpdateAccountSettingsRequestSerializer {
     #[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::update_account_settings::UpdateAccountSettingsInput>()
             .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::update_account_settings::UpdateAccountSettingsInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
--
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::update_account_settings::UpdateAccountSettingsInput,
                 builder: ::http_1x::request::Builder,
             ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
--
+            }
             let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/x-amz-json-1.0");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http_1x::header::HeaderName::from_static("x-amz-target"),
                 "Timestream_20181101.UpdateAccountSettings",
             );
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_update_account_settings::ser_update_account_settings_input(
             &input,
         )?);
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
--
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
         let protocol = _cfg
             .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
             .expect("a SharedClientProtocol is required");
         let mut request = protocol
             .serialize_request(&input, UpdateAccountSettings::INPUT_SCHEMA, "", _cfg)
             .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
-+
         return ::std::result::Result::Ok(request);
-359
+    }
-360
+}
 #[derive(Debug)]
 struct UpdateAccountSettingsEndpointParamsInterceptor;
-363
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateAccountSettingsEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "UpdateAccountSettingsEndpointParamsInterceptor"
-367
+    }
-368

↧ 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::<UpdateAccountSettingsInput>()
             .ok_or("failed to downcast to UpdateAccountSettingsInput")?;
-383
         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/timestreamquery/src/operation/update_account_settings/_update_account_settings_input.rs

@@ -19,19 +166,177 @@

↥ Expand context

     /// <p>The maximum number of compute units the service will use at any point in time to serve your queries. To run queries, you must set a minimum capacity of 4 TCU. You can set the maximum number of TCU in multiples of 4, for example, 4, 8, 16, 32, and so on. The maximum value supported for <code>MaxQueryTCU</code> is 1000. To request an increase to this soft limit, contact Amazon Web Services Support. For information about the default quota for maxQueryTCU, see Default quotas. This configuration is applicable only for on-demand usage of Timestream Compute Units (TCUs).</p>
     /// <p>The maximum value supported for <code>MaxQueryTCU</code> is 1000. To request an increase to this soft limit, contact Amazon Web Services Support. For information about the default quota for <code>maxQueryTCU</code>, see <a href="https://docs.aws.amazon.com/timestream/latest/developerguide/ts-limits.html#limits.default">Default quotas</a>.</p>
     pub fn max_query_tcu(&self) -> ::std::option::Option<i32> {
         self.max_query_tcu
-23
+    }
     /// <p>The pricing model for queries in an account.</p><note>
     /// <p>The <code>QueryPricingModel</code> parameter is used by several Timestream operations; however, the <code>UpdateAccountSettings</code> API operation doesn't recognize any values other than <code>COMPUTE_UNITS</code>.</p>
     /// </note>
     pub fn query_pricing_model(&self) -> ::std::option::Option<&crate::types::QueryPricingModel> {
         self.query_pricing_model.as_ref()
-29
+    }
     /// <p>Modifies the query compute settings configured in your account, including the query pricing model and provisioned Timestream Compute Units (TCUs) in your account.</p><note>
     /// <p>This API is idempotent, meaning that making the same request multiple times will have the same effect as making the request once.</p>
     /// </note>
     pub fn query_compute(&self) -> ::std::option::Option<&crate::types::QueryComputeRequest> {
         self.query_compute.as_ref()
-35
+    }
-36
+}
 static UPDATEACCOUNTSETTINGSINPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.timestreamquery.synthetic#UpdateAccountSettingsInput",

     "com.amazonaws.timestreamquery.synthetic",
     "UpdateAccountSettingsInput",
 );
 static UPDATEACCOUNTSETTINGSINPUT_MEMBER_MAX_QUERY_TCU: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.timestreamquery.synthetic#UpdateAccountSettingsInput$MaxQueryTCU",
         "com.amazonaws.timestreamquery.synthetic",
         "UpdateAccountSettingsInput",
     ),
     ::aws_smithy_schema::ShapeType::Integer,
     "max_query_tcu",
     "MaxQueryTCU",
 ,
 );
 static UPDATEACCOUNTSETTINGSINPUT_MEMBER_QUERY_PRICING_MODEL: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.timestreamquery.synthetic#UpdateAccountSettingsInput$QueryPricingModel",
         "com.amazonaws.timestreamquery.synthetic",
         "UpdateAccountSettingsInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "query_pricing_model",
     "QueryPricingModel",
 ,
 );
 static UPDATEACCOUNTSETTINGSINPUT_MEMBER_QUERY_COMPUTE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.timestreamquery.synthetic#UpdateAccountSettingsInput$QueryCompute",
         "com.amazonaws.timestreamquery.synthetic",
         "UpdateAccountSettingsInput",
     ),
     ::aws_smithy_schema::ShapeType::Structure,
     "query_compute",
     "QueryCompute",
 ,
 );
 static UPDATEACCOUNTSETTINGSINPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     UPDATEACCOUNTSETTINGSINPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &UPDATEACCOUNTSETTINGSINPUT_MEMBER_MAX_QUERY_TCU,
         &UPDATEACCOUNTSETTINGSINPUT_MEMBER_QUERY_PRICING_MODEL,
         &UPDATEACCOUNTSETTINGSINPUT_MEMBER_QUERY_COMPUTE,
     ],
 );
 impl UpdateAccountSettingsInput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &UPDATEACCOUNTSETTINGSINPUT_SCHEMA;
-84
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for UpdateAccountSettingsInput {
     #[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.max_query_tcu {
             ser.write_integer(&UPDATEACCOUNTSETTINGSINPUT_MEMBER_MAX_QUERY_TCU, *val)?;
-93
+        }
         if let Some(ref val) = self.query_pricing_model {
             ser.write_string(&UPDATEACCOUNTSETTINGSINPUT_MEMBER_QUERY_PRICING_MODEL, val.as_str())?;
-96
+        }
         if let Some(ref val) = self.query_compute {
             ser.write_struct(&UPDATEACCOUNTSETTINGSINPUT_MEMBER_QUERY_COMPUTE, val)?;
-99
+        }
         Ok(())
-101
+    }
-102
+}
 impl UpdateAccountSettingsInput {
     /// 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(&UPDATEACCOUNTSETTINGSINPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&UPDATEACCOUNTSETTINGSINPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.max_query_tcu = Some(deser.read_integer(member)?);
-121
+                }
                 Some(1) => {
                     builder.query_pricing_model = Some(crate::types::QueryPricingModel::from(deser.read_string(member)?.as_str()));
-124
+                }
                 Some(2) => {
                     builder.query_compute = Some(crate::types::QueryComputeRequest::deserialize(deser)?);
-127
+                }
                 _ => {}
-129
+            }
             Ok(())
         })?;
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-135
+    }
-136
+}
 impl UpdateAccountSettingsInput {
     /// 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 UpdateAccountSettingsInput {
     /// Creates a new builder-style object to manufacture [`UpdateAccountSettingsInput`](crate::operation::update_account_settings::UpdateAccountSettingsInput).
     pub fn builder() -> crate::operation::update_account_settings::builders::UpdateAccountSettingsInputBuilder {
         crate::operation::update_account_settings::builders::UpdateAccountSettingsInputBuilder::default()
-152
+    }
-153
+}
-154
 /// A builder for [`UpdateAccountSettingsInput`](crate::operation::update_account_settings::UpdateAccountSettingsInput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]

↧ Expand context

 pub struct UpdateAccountSettingsInputBuilder {
     pub(crate) max_query_tcu: ::std::option::Option<i32>,
     pub(crate) query_pricing_model: ::std::option::Option<crate::types::QueryPricingModel>,
     pub(crate) query_compute: ::std::option::Option<crate::types::QueryComputeRequest>,
-162
+}
 impl UpdateAccountSettingsInputBuilder {
     /// <p>The maximum number of compute units the service will use at any point in time to serve your queries. To run queries, you must set a minimum capacity of 4 TCU. You can set the maximum number of TCU in multiples of 4, for example, 4, 8, 16, 32, and so on. The maximum value supported for <code>MaxQueryTCU</code> is 1000. To request an increase to this soft limit, contact Amazon Web Services Support. For information about the default quota for maxQueryTCU, see Default quotas. This configuration is applicable only for on-demand usage of Timestream Compute Units (TCUs).</p>
     /// <p>The maximum value supported for <code>MaxQueryTCU</code> is 1000. To request an increase to this soft limit, contact Amazon Web Services Support. For information about the default quota for <code>maxQueryTCU</code>, see <a href="https://docs.aws.amazon.com/timestream/latest/developerguide/ts-limits.html#limits.default">Default quotas</a>.</p>
     pub fn max_query_tcu(mut self, input: i32) -> Self {
         self.max_query_tcu = ::std::option::Option::Some(input);
         self
-169
+    }
     /// <p>The maximum number of compute units the service will use at any point in time to serve your queries. To run queries, you must set a minimum capacity of 4 TCU. You can set the maximum number of TCU in multiples of 4, for example, 4, 8, 16, 32, and so on. The maximum value supported for <code>MaxQueryTCU</code> is 1000. To request an increase to this soft limit, contact Amazon Web Services Support. For information about the default quota for maxQueryTCU, see Default quotas. This configuration is applicable only for on-demand usage of Timestream Compute Units (TCUs).</p>
     /// <p>The maximum value supported for <code>MaxQueryTCU</code> is 1000. To request an increase to this soft limit, contact Amazon Web Services Support. For information about the default quota for <code>maxQueryTCU</code>, see <a href="https://docs.aws.amazon.com/timestream/latest/developerguide/ts-limits.html#limits.default">Default quotas</a>.</p>
     pub fn set_max_query_tcu(mut self, input: ::std::option::Option<i32>) -> Self {
         self.max_query_tcu = input;
         self
-175
+    }
     /// <p>The maximum number of compute units the service will use at any point in time to serve your queries. To run queries, you must set a minimum capacity of 4 TCU. You can set the maximum number of TCU in multiples of 4, for example, 4, 8, 16, 32, and so on. The maximum value supported for <code>MaxQueryTCU</code> is 1000. To request an increase to this soft limit, contact Amazon Web Services Support. For information about the default quota for maxQueryTCU, see Default quotas. This configuration is applicable only for on-demand usage of Timestream Compute Units (TCUs).</p>
     /// <p>The maximum value supported for <code>MaxQueryTCU</code> is 1000. To request an increase to this soft limit, contact Amazon Web Services Support. For information about the default quota for <code>maxQueryTCU</code>, see <a href="https://docs.aws.amazon.com/timestream/latest/developerguide/ts-limits.html#limits.default">Default quotas</a>.</p>

tmp-codegen-diff/aws-sdk/sdk/timestreamquery/src/operation/update_account_settings/_update_account_settings_output.rs

@@ -10,10 +138,189 @@

↥ Expand context

     /// <p>Confirms the updated account settings for querying data in your account.</p>
     pub query_compute: ::std::option::Option<crate::types::QueryComputeResponse>,
     _request_id: Option<String>,
-13
+}
 impl UpdateAccountSettingsOutput {
     /// <p>The configured maximum number of compute units the service will use at any point in time to serve your queries.</p>
     pub fn max_query_tcu(&self) -> ::std::option::Option<i32> {
         self.max_query_tcu
-18
+    }
     /// <p>The pricing model for an account.</p>
     pub fn query_pricing_model(&self) -> ::std::option::Option<&crate::types::QueryPricingModel> {
         self.query_pricing_model.as_ref()
-22
+    }
     /// <p>Confirms the updated account settings for querying data in your account.</p>
     pub fn query_compute(&self) -> ::std::option::Option<&crate::types::QueryComputeResponse> {
         self.query_compute.as_ref()
-26
+    }
-27
+}
 static UPDATEACCOUNTSETTINGSOUTPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.timestreamquery.synthetic#UpdateAccountSettingsOutput",

     "com.amazonaws.timestreamquery.synthetic",
     "UpdateAccountSettingsOutput",
 );
 static UPDATEACCOUNTSETTINGSOUTPUT_MEMBER_MAX_QUERY_TCU: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.timestreamquery.synthetic#UpdateAccountSettingsOutput$MaxQueryTCU",
         "com.amazonaws.timestreamquery.synthetic",
         "UpdateAccountSettingsOutput",
     ),
     ::aws_smithy_schema::ShapeType::Integer,
     "max_query_tcu",
     "MaxQueryTCU",
 ,
 );
 static UPDATEACCOUNTSETTINGSOUTPUT_MEMBER_QUERY_PRICING_MODEL: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.timestreamquery.synthetic#UpdateAccountSettingsOutput$QueryPricingModel",
         "com.amazonaws.timestreamquery.synthetic",
         "UpdateAccountSettingsOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "query_pricing_model",
     "QueryPricingModel",
 ,
 );
 static UPDATEACCOUNTSETTINGSOUTPUT_MEMBER_QUERY_COMPUTE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.timestreamquery.synthetic#UpdateAccountSettingsOutput$QueryCompute",
         "com.amazonaws.timestreamquery.synthetic",
         "UpdateAccountSettingsOutput",
     ),
     ::aws_smithy_schema::ShapeType::Structure,
     "query_compute",
     "QueryCompute",
 ,
 );
 static UPDATEACCOUNTSETTINGSOUTPUT_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 UPDATEACCOUNTSETTINGSOUTPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     UPDATEACCOUNTSETTINGSOUTPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &UPDATEACCOUNTSETTINGSOUTPUT_MEMBER_MAX_QUERY_TCU,
         &UPDATEACCOUNTSETTINGSOUTPUT_MEMBER_QUERY_PRICING_MODEL,
         &UPDATEACCOUNTSETTINGSOUTPUT_MEMBER_QUERY_COMPUTE,
         &UPDATEACCOUNTSETTINGSOUTPUT_MEMBER__REQUEST_ID,
     ],
 );
 impl UpdateAccountSettingsOutput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &UPDATEACCOUNTSETTINGSOUTPUT_SCHEMA;
-83
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for UpdateAccountSettingsOutput {
     #[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.max_query_tcu {
             ser.write_integer(&UPDATEACCOUNTSETTINGSOUTPUT_MEMBER_MAX_QUERY_TCU, *val)?;
-92
+        }
         if let Some(ref val) = self.query_pricing_model {
             ser.write_string(&UPDATEACCOUNTSETTINGSOUTPUT_MEMBER_QUERY_PRICING_MODEL, val.as_str())?;
-95
+        }
         if let Some(ref val) = self.query_compute {
             ser.write_struct(&UPDATEACCOUNTSETTINGSOUTPUT_MEMBER_QUERY_COMPUTE, val)?;
-98
+        }
         Ok(())
-100
+    }
-101
+}
 impl UpdateAccountSettingsOutput {
     /// 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(&UPDATEACCOUNTSETTINGSOUTPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&UPDATEACCOUNTSETTINGSOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.max_query_tcu = Some(deser.read_integer(member)?);
-+
+                }
                 Some(1) => {
                     builder.query_pricing_model = Some(crate::types::QueryPricingModel::from(deser.read_string(member)?.as_str()));
-+
+                }
                 Some(2) => {
                     builder.query_compute = Some(crate::types::QueryComputeResponse::deserialize(deser)?);
-+
+                }
                 Some(3) => {
                     builder._request_id = Some(deser.read_string(member)?);
-+
+                }
                 _ => {}
-+
+            }
             Ok(())
         })?;
         Ok(builder.build())
-+
+    }
-+
+}
 impl UpdateAccountSettingsOutput {
     /// 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(&UPDATEACCOUNTSETTINGSOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.max_query_tcu = Some(deser.read_integer(member)?);
-163
+                }
                 Some(1) => {
                     builder.query_pricing_model = Some(crate::types::QueryPricingModel::from(deser.read_string(member)?.as_str()));
-166
+                }
                 Some(2) => {
                     builder.query_compute = Some(crate::types::QueryComputeResponse::deserialize(deser)?);
-169
+                }

↧ Expand context

                 _ => {}
-171
+            }
             Ok(())
         })?;
         Ok(builder.build())
-175
+    }
-176
+}
 impl ::aws_types::request_id::RequestId for UpdateAccountSettingsOutput {
     fn request_id(&self) -> Option<&str> {
         self._request_id.as_deref()
-180
+    }
-181
+}
 impl UpdateAccountSettingsOutput {
     /// Creates a new builder-style object to manufacture [`UpdateAccountSettingsOutput`](crate::operation::update_account_settings::UpdateAccountSettingsOutput).
     pub fn builder() -> crate::operation::update_account_settings::builders::UpdateAccountSettingsOutputBuilder {
         crate::operation::update_account_settings::builders::UpdateAccountSettingsOutputBuilder::default()
-186
+    }
-187
+}
-188
 /// A builder for [`UpdateAccountSettingsOutput`](crate::operation::update_account_settings::UpdateAccountSettingsOutput).

tmp-codegen-diff/aws-sdk/sdk/timestreamquery/src/operation/update_scheduled_query.rs

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

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

@@ -124,128 +253,412 @@

↥ Expand context

         });
-129
         ::std::option::Option::Some(cfg.freeze())
-131
+    }
-132
     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("UpdateScheduledQuery")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(UpdateScheduledQueryEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::update_scheduled_query::UpdateScheduledQueryError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::update_scheduled_query::UpdateScheduledQueryError,
             >::new())
             .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<

                 crate::operation::update_scheduled_query::UpdateScheduledQueryError,
             >::new());
-150
         ::std::borrow::Cow::Owned(rcb)
-152
+    }
-153
+}
-154
 #[derive(Debug)]
 struct UpdateScheduledQueryResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for UpdateScheduledQueryResponseDeserializer {
     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_update_scheduled_query::de_update_scheduled_query_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::update_scheduled_query::UpdateScheduledQueryError::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 {
                 "AccessDeniedException" => crate::operation::update_scheduled_query::UpdateScheduledQueryError::AccessDeniedException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::AccessDeniedException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::AccessDeniedException::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
                 }),
                 "InternalServerException" => crate::operation::update_scheduled_query::UpdateScheduledQueryError::InternalServerException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InternalServerException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InternalServerException::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
                 }),
                 "InvalidEndpointException" => crate::operation::update_scheduled_query::UpdateScheduledQueryError::InvalidEndpointException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::InvalidEndpointException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::InvalidEndpointException::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::update_scheduled_query::UpdateScheduledQueryError::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
                 }),
                 "ThrottlingException" => crate::operation::update_scheduled_query::UpdateScheduledQueryError::ThrottlingException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ThrottlingException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ThrottlingException::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
                 }),
                 "ValidationException" => crate::operation::update_scheduled_query::UpdateScheduledQueryError::ValidationException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ValidationException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ValidationException::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::update_scheduled_query::UpdateScheduledQueryError::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_update_scheduled_query::de_update_scheduled_query_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, UpdateScheduledQuery::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::update_scheduled_query::UpdateScheduledQueryOutput::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))
-+
+        }
-361
+    }
-362
+}
 #[derive(Debug)]
 struct UpdateScheduledQueryRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for UpdateScheduledQueryRequestSerializer {
     #[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::update_scheduled_query::UpdateScheduledQueryInput>()
             .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::update_scheduled_query::UpdateScheduledQueryInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
--
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::update_scheduled_query::UpdateScheduledQueryInput,
                 builder: ::http_1x::request::Builder,
             ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
--
+            }
             let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/x-amz-json-1.0");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http_1x::header::HeaderName::from_static("x-amz-target"),
                 "Timestream_20181101.UpdateScheduledQuery",
             );
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_update_scheduled_query::ser_update_scheduled_query_input(
             &input,
         )?);
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
--
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
         let protocol = _cfg
             .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
             .expect("a SharedClientProtocol is required");
         let mut request = protocol
             .serialize_request(&input, UpdateScheduledQuery::INPUT_SCHEMA, "", _cfg)
             .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
-+
         return ::std::result::Result::Ok(request);
-383
+    }
-384
+}
 #[derive(Debug)]
 struct UpdateScheduledQueryEndpointParamsInterceptor;
-387
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateScheduledQueryEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "UpdateScheduledQueryEndpointParamsInterceptor"
-391
+    }
-392

↧ 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::<UpdateScheduledQueryInput>()
             .ok_or("failed to downcast to UpdateScheduledQueryInput")?;
-407
         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/timestreamquery/src/operation/update_scheduled_query/_update_scheduled_query_input.rs

@@ -3,3 +133,145 @@

↥ Expand context

 #[non_exhaustive]
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct UpdateScheduledQueryInput {
     /// <p>ARN of the scheuled query.</p>
     pub scheduled_query_arn: ::std::option::Option<::std::string::String>,
     /// <p>State of the scheduled query.</p>
     pub state: ::std::option::Option<crate::types::ScheduledQueryState>,
-10
+}
 impl UpdateScheduledQueryInput {
     /// <p>ARN of the scheuled query.</p>
     pub fn scheduled_query_arn(&self) -> ::std::option::Option<&str> {
         self.scheduled_query_arn.as_deref()
-15
+    }
     /// <p>State of the scheduled query.</p>
     pub fn state(&self) -> ::std::option::Option<&crate::types::ScheduledQueryState> {
         self.state.as_ref()
-19
+    }
-20
+}
 static UPDATESCHEDULEDQUERYINPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.timestreamquery.synthetic#UpdateScheduledQueryInput",

     "com.amazonaws.timestreamquery.synthetic",
     "UpdateScheduledQueryInput",
 );
 static UPDATESCHEDULEDQUERYINPUT_MEMBER_SCHEDULED_QUERY_ARN: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.timestreamquery.synthetic#UpdateScheduledQueryInput$ScheduledQueryArn",
         "com.amazonaws.timestreamquery.synthetic",
         "UpdateScheduledQueryInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "scheduled_query_arn",
     "ScheduledQueryArn",
 ,
 );
 static UPDATESCHEDULEDQUERYINPUT_MEMBER_STATE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.timestreamquery.synthetic#UpdateScheduledQueryInput$State",
         "com.amazonaws.timestreamquery.synthetic",
         "UpdateScheduledQueryInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "state",
     "State",
 ,
 );
 static UPDATESCHEDULEDQUERYINPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     UPDATESCHEDULEDQUERYINPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &UPDATESCHEDULEDQUERYINPUT_MEMBER_SCHEDULED_QUERY_ARN,
         &UPDATESCHEDULEDQUERYINPUT_MEMBER_STATE,
     ],
 );
 impl UpdateScheduledQueryInput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &UPDATESCHEDULEDQUERYINPUT_SCHEMA;
-57
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for UpdateScheduledQueryInput {
     #[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.scheduled_query_arn {
             ser.write_string(&UPDATESCHEDULEDQUERYINPUT_MEMBER_SCHEDULED_QUERY_ARN, val)?;
-66
+        }
         if let Some(ref val) = self.state {
             ser.write_string(&UPDATESCHEDULEDQUERYINPUT_MEMBER_STATE, val.as_str())?;
-69
+        }
         Ok(())
-71
+    }
-72
+}
 impl UpdateScheduledQueryInput {
     /// 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(&UPDATESCHEDULEDQUERYINPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&UPDATESCHEDULEDQUERYINPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.scheduled_query_arn = Some(deser.read_string(member)?);
-91
+                }
                 Some(1) => {
                     builder.state = Some(crate::types::ScheduledQueryState::from(deser.read_string(member)?.as_str()));
-94
+                }
                 _ => {}
-96
+            }
             Ok(())
         })?;
         builder.scheduled_query_arn = builder.scheduled_query_arn.or(Some(String::new()));
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-103
+    }
-104
+}
 impl UpdateScheduledQueryInput {
     /// 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 UpdateScheduledQueryInput {
     /// Creates a new builder-style object to manufacture [`UpdateScheduledQueryInput`](crate::operation::update_scheduled_query::UpdateScheduledQueryInput).
     pub fn builder() -> crate::operation::update_scheduled_query::builders::UpdateScheduledQueryInputBuilder {
         crate::operation::update_scheduled_query::builders::UpdateScheduledQueryInputBuilder::default()
-120
+    }
-121
+}
-122
 /// A builder for [`UpdateScheduledQueryInput`](crate::operation::update_scheduled_query::UpdateScheduledQueryInput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]

↧ Expand context

 pub struct UpdateScheduledQueryInputBuilder {
     pub(crate) scheduled_query_arn: ::std::option::Option<::std::string::String>,
     pub(crate) state: ::std::option::Option<crate::types::ScheduledQueryState>,
-129
+}
 impl UpdateScheduledQueryInputBuilder {
     /// <p>ARN of the scheuled query.</p>
     /// This field is required.
     pub fn scheduled_query_arn(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         self.scheduled_query_arn = ::std::option::Option::Some(input.into());
         self
-136
+    }
     /// <p>ARN of the scheuled query.</p>
     pub fn set_scheduled_query_arn(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         self.scheduled_query_arn = input;
         self
-141
+    }
     /// <p>ARN of the scheuled query.</p>
     pub fn get_scheduled_query_arn(&self) -> &::std::option::Option<::std::string::String> {
         &self.scheduled_query_arn
-145
+    }

tmp-codegen-diff/aws-sdk/sdk/timestreamquery/src/operation/update_scheduled_query/_update_scheduled_query_output.rs

@@ -1,1 +80,111 @@

↥ Expand context

 #[non_exhaustive]
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct UpdateScheduledQueryOutput {
     _request_id: Option<String>,
-7
+}
 static UPDATESCHEDULEDQUERYOUTPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.timestreamquery.synthetic#UpdateScheduledQueryOutput",
     "com.amazonaws.timestreamquery.synthetic",
     "UpdateScheduledQueryOutput",
 );
 static UPDATESCHEDULEDQUERYOUTPUT_SCHEMA: ::aws_smithy_schema::Schema =
     ::aws_smithy_schema::Schema::new_struct(UPDATESCHEDULEDQUERYOUTPUT_SCHEMA_ID, ::aws_smithy_schema::ShapeType::Structure, &[]);
 static UPDATESCHEDULEDQUERYOUTPUT_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 UPDATESCHEDULEDQUERYOUTPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     UPDATESCHEDULEDQUERYOUTPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[&UPDATESCHEDULEDQUERYOUTPUT_MEMBER__REQUEST_ID],
 );
 impl UpdateScheduledQueryOutput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &UPDATESCHEDULEDQUERYOUTPUT_SCHEMA;
-28
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for UpdateScheduledQueryOutput {
     #[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> {
         Ok(())
-36
+    }
-37
+}
 impl UpdateScheduledQueryOutput {
     /// 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(&UPDATESCHEDULEDQUERYOUTPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&UPDATESCHEDULEDQUERYOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder._request_id = Some(deser.read_string(member)?);
-+
+                }
                 _ => {}
-58
+            }
             Ok(())
         })?;
         Ok(builder.build())
-62
+    }
-63
+}
 impl UpdateScheduledQueryOutput {
     /// 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());
-+
+        }
         Ok(builder.build())
-+
+    }
-+
+}
 impl ::aws_types::request_id::RequestId for UpdateScheduledQueryOutput {
     fn request_id(&self) -> Option<&str> {
         self._request_id.as_deref()
-85
+    }
-86
+}
 impl UpdateScheduledQueryOutput {
     /// Creates a new builder-style object to manufacture [`UpdateScheduledQueryOutput`](crate::operation::update_scheduled_query::UpdateScheduledQueryOutput).
     pub fn builder() -> crate::operation::update_scheduled_query::builders::UpdateScheduledQueryOutputBuilder {
         crate::operation::update_scheduled_query::builders::UpdateScheduledQueryOutputBuilder::default()
-91
+    }

↧ Expand context

-92
+}
-93
 /// A builder for [`UpdateScheduledQueryOutput`](crate::operation::update_scheduled_query::UpdateScheduledQueryOutput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct UpdateScheduledQueryOutputBuilder {
     _request_id: Option<String>,
-99
+}
 impl UpdateScheduledQueryOutputBuilder {
     pub(crate) fn _request_id(mut self, request_id: impl Into<String>) -> Self {
         self._request_id = Some(request_id.into());
         self
-104
+    }
-105
     pub(crate) fn _set_request_id(&mut self, request_id: Option<String>) -> &mut Self {
         self._request_id = request_id;
         self
-109
+    }
     /// Consumes the builder and constructs a [`UpdateScheduledQueryOutput`](crate::operation::update_scheduled_query::UpdateScheduledQueryOutput).
     pub fn build(self) -> crate::operation::update_scheduled_query::UpdateScheduledQueryOutput {

tmp-codegen-diff/aws-sdk/sdk/timestreamquery/src/protocol_serde.rs

@@ -1,1 +220,0 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub(crate) fn type_erase_result<O, E>(
     result: ::std::result::Result<O, E>,
 ) -> ::std::result::Result<
     ::aws_smithy_runtime_api::client::interceptors::context::Output,
     ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError<::aws_smithy_runtime_api::client::interceptors::context::Error>,
--
+>
 where
     O: ::std::fmt::Debug + ::std::marker::Send + ::std::marker::Sync + 'static,
     E: ::std::error::Error + std::fmt::Debug + ::std::marker::Send + ::std::marker::Sync + 'static,
--
+{
     result
         .map(|output| ::aws_smithy_runtime_api::client::interceptors::context::Output::erase(output))
         .map_err(|error| ::aws_smithy_runtime_api::client::interceptors::context::Error::erase(error))
         .map_err(::std::convert::Into::into)
--
+}
--
 pub fn parse_http_error_metadata(
     _response_status: u16,
     response_headers: &::aws_smithy_runtime_api::http::Headers,
     response_body: &[u8],
 ) -> ::std::result::Result<::aws_smithy_types::error::metadata::Builder, ::aws_smithy_json::deserialize::error::DeserializeError> {
     crate::json_errors::parse_error_metadata(response_body, response_headers)
-8
+}
--
 pub(crate) mod shape_cancel_query;
--
 pub(crate) mod shape_create_scheduled_query;
--
 pub(crate) mod shape_delete_scheduled_query;
--
 pub(crate) mod shape_describe_account_settings;
--
 pub(crate) mod shape_describe_endpoints;
--
 pub(crate) mod shape_describe_scheduled_query;
--
 pub(crate) mod shape_execute_scheduled_query;
--
 pub(crate) mod shape_list_scheduled_queries;
--
 pub(crate) mod shape_list_tags_for_resource;
--
 pub(crate) mod shape_prepare_query;
--
 pub(crate) mod shape_query;
--
 pub(crate) mod shape_tag_resource;
--
 pub(crate) mod shape_untag_resource;
--
 pub(crate) mod shape_update_account_settings;
--
 pub(crate) mod shape_update_scheduled_query;
--
 pub(crate) fn or_empty_doc(data: &[u8]) -> &[u8] {
     if data.is_empty() {
         b"{}"
     } else {
         data
--
+    }
--
+}
--
 pub(crate) mod shape_access_denied_exception;
--
 pub(crate) mod shape_cancel_query_input;
--
 pub(crate) mod shape_conflict_exception;
--
 pub(crate) mod shape_create_scheduled_query_input;
--
 pub(crate) mod shape_delete_scheduled_query_input;
--
 pub(crate) mod shape_describe_scheduled_query_input;
--
 pub(crate) mod shape_execute_scheduled_query_input;
--
 pub(crate) mod shape_internal_server_exception;
--
 pub(crate) mod shape_invalid_endpoint_exception;
--
 pub(crate) mod shape_list_scheduled_queries_input;
--
 pub(crate) mod shape_list_tags_for_resource_input;
--
 pub(crate) mod shape_prepare_query_input;
--
 pub(crate) mod shape_query_execution_exception;
--
 pub(crate) mod shape_query_input;
--
 pub(crate) mod shape_resource_not_found_exception;
--
 pub(crate) mod shape_service_quota_exceeded_exception;
--
 pub(crate) mod shape_tag_resource_input;
--
 pub(crate) mod shape_throttling_exception;
--
 pub(crate) mod shape_untag_resource_input;
--
 pub(crate) mod shape_update_account_settings_input;
--
 pub(crate) mod shape_update_scheduled_query_input;
--
 pub(crate) mod shape_validation_exception;
--
 pub(crate) mod shape_column_info_list;
--
 pub(crate) mod shape_endpoints;
--
 pub(crate) mod shape_error_report_configuration;
--
 pub(crate) mod shape_notification_configuration;
--
 pub(crate) mod shape_parameter_mapping_list;
--
 pub(crate) mod shape_query_compute_request;
--
 pub(crate) mod shape_query_compute_response;
--
 pub(crate) mod shape_query_insights;
--
 pub(crate) mod shape_query_insights_response;
--
 pub(crate) mod shape_query_status;
--
 pub(crate) mod shape_row_list;
--
 pub(crate) mod shape_schedule_configuration;
--
 pub(crate) mod shape_scheduled_query_description;
--
 pub(crate) mod shape_scheduled_query_insights;
--
 pub(crate) mod shape_scheduled_query_list;
--
 pub(crate) mod shape_select_column_list;
--
 pub(crate) mod shape_tag;
--
 pub(crate) mod shape_tag_list;
--
 pub(crate) mod shape_target_configuration;
--
 pub(crate) mod shape_column_info;
--
 pub(crate) mod shape_endpoint;
--
 pub(crate) mod shape_parameter_mapping;
--
 pub(crate) mod shape_provisioned_capacity_request;
--
 pub(crate) mod shape_provisioned_capacity_response;
--
 pub(crate) mod shape_query_spatial_coverage;
--
 pub(crate) mod shape_query_temporal_range;
--
 pub(crate) mod shape_row;
--
 pub(crate) mod shape_s3_configuration;
--
 pub(crate) mod shape_scheduled_query;
--
 pub(crate) mod shape_scheduled_query_run_summary;
--
 pub(crate) mod shape_scheduled_query_run_summary_list;
--
 pub(crate) mod shape_select_column;
--
 pub(crate) mod shape_sns_configuration;
--
 pub(crate) mod shape_timestream_configuration;
--
 pub(crate) mod shape_account_settings_notification_configuration;
--
 pub(crate) mod shape_datum_list;
--
 pub(crate) mod shape_dimension_mapping;
--
 pub(crate) mod shape_error_report_location;
--
 pub(crate) mod shape_execution_stats;
--
 pub(crate) mod shape_last_update;
--
 pub(crate) mod shape_mixed_measure_mapping;
--
 pub(crate) mod shape_multi_measure_mappings;
--
 pub(crate) mod shape_query_spatial_coverage_max;
--
 pub(crate) mod shape_query_temporal_range_max;
--
 pub(crate) mod shape_scheduled_query_insights_response;
--
 pub(crate) mod shape_target_destination;
--
 pub(crate) mod shape_type;
--
 pub(crate) mod shape_datum;
--
 pub(crate) mod shape_dimension_mapping_list;
--
 pub(crate) mod shape_mixed_measure_mapping_list;
--
 pub(crate) mod shape_multi_measure_attribute_mapping;
--
 pub(crate) mod shape_partition_key_list;
--
 pub(crate) mod shape_s3_report_location;
--
 pub(crate) mod shape_timestream_destination;
--
 pub(crate) mod shape_multi_measure_attribute_mapping_list;
--
 pub(crate) mod shape_time_series_data_point_list;
--
 pub(crate) mod shape_time_series_data_point;

tmp-codegen-diff/aws-sdk/sdk/timestreamquery/src/protocol_serde/shape_access_denied_exception.rs

@@ -1,0 +35,0 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub(crate) fn de_access_denied_exception_json_err(
     _value: &[u8],
     mut builder: crate::types::error::builders::AccessDeniedExceptionBuilder,
 ) -> ::std::result::Result<crate::types::error::builders::AccessDeniedExceptionBuilder, ::aws_smithy_json::deserialize::error::DeserializeError> {
     let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(_value)).peekable();
     let tokens = &mut tokens_owned;
     ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
     loop {
         match tokens.next().transpose()? {
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
                 "Message" => {
                     builder = builder.set_message(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                     );
--
+                }
                 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
             },
             other => {
                 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                     "expected object key or end object, found: {other:?}"
                 )))
--
+            }
--
+        }
--
+    }
     if tokens.next().is_some() {
         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "found more JSON tokens after completing parsing",
         ));
--
+    }
     Ok(builder)
--
+}

tmp-codegen-diff/aws-sdk/sdk/timestreamquery/src/protocol_serde/shape_account_settings_notification_configuration.rs

@@ -1,0 +64,0 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub fn ser_account_settings_notification_configuration(
     object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
     input: &crate::types::AccountSettingsNotificationConfiguration,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
     if let Some(var_1) = &input.sns_configuration {
         #[allow(unused_mut)]
         let mut object_2 = object.key("SnsConfiguration").start_object();
         crate::protocol_serde::shape_sns_configuration::ser_sns_configuration(&mut object_2, var_1)?;
         object_2.finish();
--
+    }
--
+    {
         object.key("RoleArn").string(input.role_arn.as_str());
--
+    }
     Ok(())
--
+}
--
 pub(crate) fn de_account_settings_notification_configuration<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
     _value: &'a [u8],
 ) -> ::std::result::Result<Option<crate::types::AccountSettingsNotificationConfiguration>, ::aws_smithy_json::deserialize::error::DeserializeError>
 where
     I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
--
+{
     match tokens.next().transpose()? {
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
             #[allow(unused_mut)]
             let mut builder = crate::types::builders::AccountSettingsNotificationConfigurationBuilder::default();
             loop {
                 match tokens.next().transpose()? {
                     Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
                     Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
                         "SnsConfiguration" => {
                             builder =
                                 builder.set_sns_configuration(crate::protocol_serde::shape_sns_configuration::de_sns_configuration(tokens, _value)?);
--
+                        }
                         "RoleArn" => {
                             builder = builder.set_role_arn(
                                 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                     .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                     .transpose()?,
                             );
--
+                        }
                         _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
                     },
                     other => {
                         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                             "expected object key or end object, found: {other:?}"
                         )))
--
+                    }
--
+                }
--
+            }
             Ok(Some(
                 crate::serde_util::account_settings_notification_configuration_correct_errors(builder)
                     .build()
                     .map_err(|err| ::aws_smithy_json::deserialize::error::DeserializeError::custom_source("Response was invalid", err))?,
             ))
--
+        }
         _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "expected start object or null",
         )),
--
+    }
--
+}

tmp-codegen-diff/aws-sdk/sdk/timestreamquery/src/protocol_serde/shape_cancel_query.rs

@@ -1,0 +159,0 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_cancel_query_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<crate::operation::cancel_query::CancelQueryOutput, crate::operation::cancel_query::CancelQueryError> {
     #[allow(unused_mut)]
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::cancel_query::CancelQueryError::unhandled)?;
     generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
     let generic = generic_builder.build();
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::cancel_query::CancelQueryError::unhandled(generic)),
     };
--
     let _error_message = generic.message().map(|msg| msg.to_owned());
     Err(match error_code {
         "AccessDeniedException" => crate::operation::cancel_query::CancelQueryError::AccessDeniedException({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::AccessDeniedExceptionBuilder::default();
                 output = crate::protocol_serde::shape_access_denied_exception::de_access_denied_exception_json_err(_response_body, output)
                     .map_err(crate::operation::cancel_query::CancelQueryError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
--
+            }
             tmp
         }),
         "InternalServerException" => crate::operation::cancel_query::CancelQueryError::InternalServerException({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::InternalServerExceptionBuilder::default();
                 output = crate::protocol_serde::shape_internal_server_exception::de_internal_server_exception_json_err(_response_body, output)
                     .map_err(crate::operation::cancel_query::CancelQueryError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
--
+            }
             tmp
         }),
         "InvalidEndpointException" => crate::operation::cancel_query::CancelQueryError::InvalidEndpointException({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::InvalidEndpointExceptionBuilder::default();
                 output = crate::protocol_serde::shape_invalid_endpoint_exception::de_invalid_endpoint_exception_json_err(_response_body, output)
                     .map_err(crate::operation::cancel_query::CancelQueryError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
--
+            }
             tmp
         }),
         "ThrottlingException" => crate::operation::cancel_query::CancelQueryError::ThrottlingException({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ThrottlingExceptionBuilder::default();
                 output = crate::protocol_serde::shape_throttling_exception::de_throttling_exception_json_err(_response_body, output)
                     .map_err(crate::operation::cancel_query::CancelQueryError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
--
+            }
             tmp
         }),
         "ValidationException" => crate::operation::cancel_query::CancelQueryError::ValidationException({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ValidationExceptionBuilder::default();
                 output = crate::protocol_serde::shape_validation_exception::de_validation_exception_json_err(_response_body, output)
                     .map_err(crate::operation::cancel_query::CancelQueryError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
--
+            }
             tmp
         }),
         _ => crate::operation::cancel_query::CancelQueryError::generic(generic),
     })
--
+}
--
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_cancel_query_http_response(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<crate::operation::cancel_query::CancelQueryOutput, crate::operation::cancel_query::CancelQueryError> {
     Ok({
         #[allow(unused_mut)]
         let mut output = crate::operation::cancel_query::builders::CancelQueryOutputBuilder::default();
         output = crate::protocol_serde::shape_cancel_query::de_cancel_query(_response_body, output)
             .map_err(crate::operation::cancel_query::CancelQueryError::unhandled)?;
         output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
         output.build()
     })
--
+}
--
 pub fn ser_cancel_query_input(
     input: &crate::operation::cancel_query::CancelQueryInput,
 ) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
     let mut out = String::new();
     let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
     crate::protocol_serde::shape_cancel_query_input::ser_cancel_query_input_input(&mut object, input)?;
     object.finish();
     Ok(::aws_smithy_types::body::SdkBody::from(out))
--
+}
--
 pub(crate) fn de_cancel_query(
     _value: &[u8],
     mut builder: crate::operation::cancel_query::builders::CancelQueryOutputBuilder,
 ) -> ::std::result::Result<crate::operation::cancel_query::builders::CancelQueryOutputBuilder, ::aws_smithy_json::deserialize::error::DeserializeError>
--
+{
     let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(_value)).peekable();
     let tokens = &mut tokens_owned;
     ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
     loop {
         match tokens.next().transpose()? {
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
                 "CancellationMessage" => {
                     builder = builder.set_cancellation_message(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                     );
--
+                }
                 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
             },
             other => {
                 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                     "expected object key or end object, found: {other:?}"
                 )))
--
+            }
--
+        }
--
+    }
     if tokens.next().is_some() {
         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "found more JSON tokens after completing parsing",
         ));
--
+    }
     Ok(builder)
--
+}

1 1	`// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.`
2 2	`#[allow(missing_docs)] // documentation missing in model`

AWS SDK

Files changed: