AWS SDK

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/operation/update_delivery_configuration.rs

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

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

@@ -127,133 +253,420 @@

↥ Expand context

-133
+    }
-134
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("UpdateDeliveryConfiguration")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(UpdateDeliveryConfigurationEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::update_delivery_configuration::UpdateDeliveryConfigurationError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::update_delivery_configuration::UpdateDeliveryConfigurationError,
             >::new())
             .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
                 crate::operation::update_delivery_configuration::UpdateDeliveryConfigurationError,
             >::new());
-152

         ::std::borrow::Cow::Owned(rcb)
-154
+    }
-155
+}
-156
 #[derive(Debug)]
 struct UpdateDeliveryConfigurationResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for UpdateDeliveryConfigurationResponseDeserializer {
     fn deserialize_nonstreaming(
         &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_delivery_configuration::de_update_delivery_configuration_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_delivery_configuration::UpdateDeliveryConfigurationError::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_delivery_configuration::UpdateDeliveryConfigurationError::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
                     })
-+
+                }
                 "ConflictException" => crate::operation::update_delivery_configuration::UpdateDeliveryConfigurationError::ConflictException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ConflictException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ConflictException::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_delivery_configuration::UpdateDeliveryConfigurationError::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
                     })
-+
+                }
                 "ServiceUnavailableException" => {
                     crate::operation::update_delivery_configuration::UpdateDeliveryConfigurationError::ServiceUnavailableException({
                         let mut tmp = match protocol
                             .deserialize_response(response, crate::types::error::ServiceUnavailableException::SCHEMA, _cfg)
                             .and_then(|mut deser| {
                                 crate::types::error::ServiceUnavailableException::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_delivery_configuration::UpdateDeliveryConfigurationError::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_delivery_configuration::UpdateDeliveryConfigurationError::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_delivery_configuration::UpdateDeliveryConfigurationError::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_delivery_configuration::de_update_delivery_configuration_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, UpdateDeliveryConfiguration::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_delivery_configuration::UpdateDeliveryConfigurationOutput::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))
-+
+        }
-369
+    }
-370
+}
 #[derive(Debug)]
 struct UpdateDeliveryConfigurationRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for UpdateDeliveryConfigurationRequestSerializer {
     #[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_delivery_configuration::UpdateDeliveryConfigurationInput>()
             .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_delivery_configuration::UpdateDeliveryConfigurationInput,
                 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_delivery_configuration::UpdateDeliveryConfigurationInput,
                 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.1");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http_1x::header::HeaderName::from_static("x-amz-target"),
                 "Logs_20140328.UpdateDeliveryConfiguration",
             );
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(
             crate::protocol_serde::shape_update_delivery_configuration::ser_update_delivery_configuration_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, UpdateDeliveryConfiguration::INPUT_SCHEMA, "", _cfg)
             .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
-+
         return ::std::result::Result::Ok(request);
-391
+    }
-392
+}
 #[derive(Debug)]
 struct UpdateDeliveryConfigurationEndpointParamsInterceptor;
-395
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateDeliveryConfigurationEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "UpdateDeliveryConfigurationEndpointParamsInterceptor"
-399
+    }
-400

↧ 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::<UpdateDeliveryConfigurationInput>()
             .ok_or("failed to downcast to UpdateDeliveryConfigurationInput")?;
-415
         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/cloudwatchlogs/src/operation/update_delivery_configuration/_update_delivery_configuration_input.rs

@@ -27,27 +199,201 @@

↥ Expand context

     pub fn field_delimiter(&self) -> ::std::option::Option<&str> {
         self.field_delimiter.as_deref()
-29
+    }
     /// <p>This structure contains parameters that are valid only when the delivery's delivery destination is an S3 bucket.</p>
     pub fn s3_delivery_configuration(&self) -> ::std::option::Option<&crate::types::S3DeliveryConfiguration> {
         self.s3_delivery_configuration.as_ref()
-33
+    }
-34
+}
 static UPDATEDELIVERYCONFIGURATIONINPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.cloudwatchlogs.synthetic#UpdateDeliveryConfigurationInput",
     "com.amazonaws.cloudwatchlogs.synthetic",
     "UpdateDeliveryConfigurationInput",
 );
 static UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_ID: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.cloudwatchlogs.synthetic#UpdateDeliveryConfigurationInput$id",
         "com.amazonaws.cloudwatchlogs.synthetic",
         "UpdateDeliveryConfigurationInput",
     ),
     ::aws_smithy_schema::ShapeType::String,

     "id",
 ,
 );
 static UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_RECORD_FIELDS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.cloudwatchlogs.synthetic#UpdateDeliveryConfigurationInput$recordFields",
         "com.amazonaws.cloudwatchlogs.synthetic",
         "UpdateDeliveryConfigurationInput",
     ),
     ::aws_smithy_schema::ShapeType::List,
     "record_fields",
     "recordFields",
 ,
 );
 static UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_FIELD_DELIMITER: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.cloudwatchlogs.synthetic#UpdateDeliveryConfigurationInput$fieldDelimiter",
         "com.amazonaws.cloudwatchlogs.synthetic",
         "UpdateDeliveryConfigurationInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "field_delimiter",
     "fieldDelimiter",
 ,
 );
 static UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_S3_DELIVERY_CONFIGURATION: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.cloudwatchlogs.synthetic#UpdateDeliveryConfigurationInput$s3DeliveryConfiguration",
         "com.amazonaws.cloudwatchlogs.synthetic",
         "UpdateDeliveryConfigurationInput",
     ),
     ::aws_smithy_schema::ShapeType::Structure,
     "s3_delivery_configuration",
     "s3DeliveryConfiguration",
 ,
 );
 static UPDATEDELIVERYCONFIGURATIONINPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     UPDATEDELIVERYCONFIGURATIONINPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_ID,
         &UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_RECORD_FIELDS,
         &UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_FIELD_DELIMITER,
         &UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_S3_DELIVERY_CONFIGURATION,
     ],
 );
 impl UpdateDeliveryConfigurationInput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &UPDATEDELIVERYCONFIGURATIONINPUT_SCHEMA;
-93
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for UpdateDeliveryConfigurationInput {
     #[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.id {
             ser.write_string(&UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_ID, val)?;
-102
+        }
         if let Some(ref val) = self.record_fields {
             ser.write_list(
                 &UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_RECORD_FIELDS,
                 &|ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer| {
                     for item in val {
                         ser.write_string(&aws_smithy_schema::prelude::STRING, item)?;
-109
+                    }
                     Ok(())
                 },
             )?;
-113
+        }
         if let Some(ref val) = self.field_delimiter {
             ser.write_string(&UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_FIELD_DELIMITER, val)?;
-116
+        }
         if let Some(ref val) = self.s3_delivery_configuration {
             ser.write_struct(&UPDATEDELIVERYCONFIGURATIONINPUT_MEMBER_S3_DELIVERY_CONFIGURATION, val)?;
-119
+        }
         Ok(())
-121
+    }
-122
+}
 impl UpdateDeliveryConfigurationInput {
     /// 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(&UPDATEDELIVERYCONFIGURATIONINPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&UPDATEDELIVERYCONFIGURATIONINPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.id = Some(deser.read_string(member)?);
-141
+                }
                 Some(1) => {
                     builder.record_fields = Some({
                         let container = if let Some(cap) = deser.container_size() {
                             Vec::with_capacity(cap)
                         } else {
                             Vec::new()
                         };
                         deser.read_list(member, container, |mut list, deser| {
                             list.push(deser.read_string(member)?);
                             Ok(list)
                         })?
                     });
                     builder.record_fields = Some(deser.read_string_list(member)?);
-144
+                }
                 Some(2) => {
                     builder.field_delimiter = Some(deser.read_string(member)?);
-147
+                }
                 Some(3) => {
                     builder.s3_delivery_configuration = Some(crate::types::S3DeliveryConfiguration::deserialize(deser)?);
-150
+                }
                 _ => {}
-152
+            }
             Ok(())
         })?;
         builder.id = builder.id.or(Some(String::new()));
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-159
+    }
-160
+}
 impl UpdateDeliveryConfigurationInput {
     /// 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 UpdateDeliveryConfigurationInput {
     /// Creates a new builder-style object to manufacture [`UpdateDeliveryConfigurationInput`](crate::operation::update_delivery_configuration::UpdateDeliveryConfigurationInput).
     pub fn builder() -> crate::operation::update_delivery_configuration::builders::UpdateDeliveryConfigurationInputBuilder {
         crate::operation::update_delivery_configuration::builders::UpdateDeliveryConfigurationInputBuilder::default()
-176
+    }
-177
+}
-178
 /// A builder for [`UpdateDeliveryConfigurationInput`](crate::operation::update_delivery_configuration::UpdateDeliveryConfigurationInput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]

↧ Expand context

 pub struct UpdateDeliveryConfigurationInputBuilder {
     pub(crate) id: ::std::option::Option<::std::string::String>,
     pub(crate) record_fields: ::std::option::Option<::std::vec::Vec<::std::string::String>>,
     pub(crate) field_delimiter: ::std::option::Option<::std::string::String>,
     pub(crate) s3_delivery_configuration: ::std::option::Option<crate::types::S3DeliveryConfiguration>,
-187
+}
 impl UpdateDeliveryConfigurationInputBuilder {
     /// <p>The ID of the delivery to be updated by this request.</p>
     /// This field is required.
     pub fn id(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         self.id = ::std::option::Option::Some(input.into());
         self
-194
+    }
     /// <p>The ID of the delivery to be updated by this request.</p>
     pub fn set_id(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         self.id = input;
         self
-199
+    }
     /// <p>The ID of the delivery to be updated by this request.</p>
     pub fn get_id(&self) -> &::std::option::Option<::std::string::String> {

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/operation/update_delivery_configuration/_update_delivery_configuration_output.rs

@@ -1,1 +83,111 @@

↥ Expand context

 #[non_exhaustive]
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct UpdateDeliveryConfigurationOutput {
     _request_id: Option<String>,
-7
+}
 static UPDATEDELIVERYCONFIGURATIONOUTPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.cloudwatchlogs.synthetic#UpdateDeliveryConfigurationOutput",
     "com.amazonaws.cloudwatchlogs.synthetic",
     "UpdateDeliveryConfigurationOutput",
 );
 static UPDATEDELIVERYCONFIGURATIONOUTPUT_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 UPDATEDELIVERYCONFIGURATIONOUTPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     UPDATEDELIVERYCONFIGURATIONOUTPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[],
     &[&UPDATEDELIVERYCONFIGURATIONOUTPUT_MEMBER__REQUEST_ID],
 );
 impl UpdateDeliveryConfigurationOutput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &UPDATEDELIVERYCONFIGURATIONOUTPUT_SCHEMA;
-28
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for UpdateDeliveryConfigurationOutput {
     #[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 UpdateDeliveryConfigurationOutput {
     /// 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(&UPDATEDELIVERYCONFIGURATIONOUTPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&UPDATEDELIVERYCONFIGURATIONOUTPUT_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 UpdateDeliveryConfigurationOutput {
     /// 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 UpdateDeliveryConfigurationOutput {
     fn request_id(&self) -> Option<&str> {
         self._request_id.as_deref()
-85
+    }
-86
+}
 impl UpdateDeliveryConfigurationOutput {
     /// Creates a new builder-style object to manufacture [`UpdateDeliveryConfigurationOutput`](crate::operation::update_delivery_configuration::UpdateDeliveryConfigurationOutput).
     pub fn builder() -> crate::operation::update_delivery_configuration::builders::UpdateDeliveryConfigurationOutputBuilder {
         crate::operation::update_delivery_configuration::builders::UpdateDeliveryConfigurationOutputBuilder::default()
-91
+    }

↧ Expand context

-92
+}
-93
 /// A builder for [`UpdateDeliveryConfigurationOutput`](crate::operation::update_delivery_configuration::UpdateDeliveryConfigurationOutput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct UpdateDeliveryConfigurationOutputBuilder {
     _request_id: Option<String>,
-99
+}
 impl UpdateDeliveryConfigurationOutputBuilder {
     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 [`UpdateDeliveryConfigurationOutput`](crate::operation::update_delivery_configuration::UpdateDeliveryConfigurationOutput).
     pub fn build(self) -> crate::operation::update_delivery_configuration::UpdateDeliveryConfigurationOutput {

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/operation/update_log_anomaly_detector.rs

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

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

@@ -127,133 +253,374 @@

↥ Expand context

-133
+    }
-134
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("UpdateLogAnomalyDetector")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(UpdateLogAnomalyDetectorEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorError,
             >::new())
             .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
                 crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorError,
             >::new());
-152

         ::std::borrow::Cow::Owned(rcb)
-154
+    }
-155
+}
-156
 #[derive(Debug)]
 struct UpdateLogAnomalyDetectorResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for UpdateLogAnomalyDetectorResponseDeserializer {
     fn deserialize_nonstreaming(
         &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_log_anomaly_detector::de_update_log_anomaly_detector_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_log_anomaly_detector::UpdateLogAnomalyDetectorError::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 {
                 "InvalidParameterException" => {
                     crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorError::InvalidParameterException({
                         let mut tmp = match protocol
                             .deserialize_response(response, crate::types::error::InvalidParameterException::SCHEMA, _cfg)
                             .and_then(|mut deser| {
                                 crate::types::error::InvalidParameterException::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
                     })
-+
+                }
                 "OperationAbortedException" => {
                     crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorError::OperationAbortedException({
                         let mut tmp = match protocol
                             .deserialize_response(response, crate::types::error::OperationAbortedException::SCHEMA, _cfg)
                             .and_then(|mut deser| {
                                 crate::types::error::OperationAbortedException::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_log_anomaly_detector::UpdateLogAnomalyDetectorError::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
                     })
-+
+                }
                 "ServiceUnavailableException" => {
                     crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorError::ServiceUnavailableException({
                         let mut tmp = match protocol
                             .deserialize_response(response, crate::types::error::ServiceUnavailableException::SCHEMA, _cfg)
                             .and_then(|mut deser| {
                                 crate::types::error::ServiceUnavailableException::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_log_anomaly_detector::UpdateLogAnomalyDetectorError::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_log_anomaly_detector::de_update_log_anomaly_detector_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, UpdateLogAnomalyDetector::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_log_anomaly_detector::UpdateLogAnomalyDetectorOutput::deserialize_with_response(
                 &mut *deser,
                 response.headers(),
                 response.status().into(),
                 body,
-+
+            )
             .map_err(|e| {
                 ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(::aws_smithy_runtime_api::box_error::BoxError::from(e))
             })?;
             ::std::result::Result::Ok(::aws_smithy_runtime_api::client::interceptors::context::Output::erase(output))
-+
+        }
-323
+    }
-324
+}
 #[derive(Debug)]
 struct UpdateLogAnomalyDetectorRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for UpdateLogAnomalyDetectorRequestSerializer {
     #[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_log_anomaly_detector::UpdateLogAnomalyDetectorInput>()
             .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_log_anomaly_detector::UpdateLogAnomalyDetectorInput,
                 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_log_anomaly_detector::UpdateLogAnomalyDetectorInput,
                 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.1");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http_1x::header::HeaderName::from_static("x-amz-target"),
                 "Logs_20140328.UpdateLogAnomalyDetector",
             );
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(
             crate::protocol_serde::shape_update_log_anomaly_detector::ser_update_log_anomaly_detector_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, UpdateLogAnomalyDetector::INPUT_SCHEMA, "", _cfg)
             .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
-+
         return ::std::result::Result::Ok(request);
-345
+    }
-346
+}
 #[derive(Debug)]
 struct UpdateLogAnomalyDetectorEndpointParamsInterceptor;
-349
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateLogAnomalyDetectorEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "UpdateLogAnomalyDetectorEndpointParamsInterceptor"
-353
+    }
-354

↧ 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::<UpdateLogAnomalyDetectorInput>()
             .ok_or("failed to downcast to UpdateLogAnomalyDetectorInput")?;
-369
         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/cloudwatchlogs/src/operation/update_log_anomaly_detector/_update_log_anomaly_detector_input.rs

@@ -21,21 +202,215 @@

↥ Expand context

-21
+    }
     /// <p>Specifies how often the anomaly detector runs and look for anomalies. Set this value according to the frequency that the log group receives new logs. For example, if the log group receives new log events every 10 minutes, then setting <code>evaluationFrequency</code> to <code>FIFTEEN_MIN</code> might be appropriate.</p>
     pub fn evaluation_frequency(&self) -> ::std::option::Option<&crate::types::EvaluationFrequency> {
         self.evaluation_frequency.as_ref()
-25
+    }
     /// <p>A symbolic description of how CloudWatch Logs should interpret the data in each log event. For example, a log event can contain timestamps, IP addresses, strings, and so on. You use the filter pattern to specify what to look for in the log event message.</p>
     pub fn filter_pattern(&self) -> ::std::option::Option<&str> {
         self.filter_pattern.as_deref()
-29
+    }
     /// <p>The number of days to use as the life cycle of anomalies. After this time, anomalies are automatically baselined and the anomaly detector model will treat new occurrences of similar event as normal. Therefore, if you do not correct the cause of an anomaly during this time, it will be considered normal going forward and will not be detected.</p>
     pub fn anomaly_visibility_time(&self) -> ::std::option::Option<i64> {
         self.anomaly_visibility_time
-33
+    }
     /// <p>Use this parameter to pause or restart the anomaly detector.</p>
     pub fn enabled(&self) -> ::std::option::Option<bool> {
         self.enabled
-37
+    }
-38
+}
 static UPDATELOGANOMALYDETECTORINPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.cloudwatchlogs.synthetic#UpdateLogAnomalyDetectorInput",

     "com.amazonaws.cloudwatchlogs.synthetic",
     "UpdateLogAnomalyDetectorInput",
 );
 static UPDATELOGANOMALYDETECTORINPUT_MEMBER_ANOMALY_DETECTOR_ARN: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.cloudwatchlogs.synthetic#UpdateLogAnomalyDetectorInput$anomalyDetectorArn",
         "com.amazonaws.cloudwatchlogs.synthetic",
         "UpdateLogAnomalyDetectorInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "anomaly_detector_arn",
     "anomalyDetectorArn",
 ,
 );
 static UPDATELOGANOMALYDETECTORINPUT_MEMBER_EVALUATION_FREQUENCY: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.cloudwatchlogs.synthetic#UpdateLogAnomalyDetectorInput$evaluationFrequency",
         "com.amazonaws.cloudwatchlogs.synthetic",
         "UpdateLogAnomalyDetectorInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "evaluation_frequency",
     "evaluationFrequency",
 ,
 );
 static UPDATELOGANOMALYDETECTORINPUT_MEMBER_FILTER_PATTERN: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.cloudwatchlogs.synthetic#UpdateLogAnomalyDetectorInput$filterPattern",
         "com.amazonaws.cloudwatchlogs.synthetic",
         "UpdateLogAnomalyDetectorInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "filter_pattern",
     "filterPattern",
 ,
 );
 static UPDATELOGANOMALYDETECTORINPUT_MEMBER_ANOMALY_VISIBILITY_TIME: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.cloudwatchlogs.synthetic#UpdateLogAnomalyDetectorInput$anomalyVisibilityTime",
         "com.amazonaws.cloudwatchlogs.synthetic",
         "UpdateLogAnomalyDetectorInput",
     ),
     ::aws_smithy_schema::ShapeType::Long,
     "anomaly_visibility_time",
     "anomalyVisibilityTime",
 ,
 );
 static UPDATELOGANOMALYDETECTORINPUT_MEMBER_ENABLED: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.cloudwatchlogs.synthetic#UpdateLogAnomalyDetectorInput$enabled",
         "com.amazonaws.cloudwatchlogs.synthetic",
         "UpdateLogAnomalyDetectorInput",
     ),
     ::aws_smithy_schema::ShapeType::Boolean,
     "enabled",
 ,
 );
 static UPDATELOGANOMALYDETECTORINPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     UPDATELOGANOMALYDETECTORINPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &UPDATELOGANOMALYDETECTORINPUT_MEMBER_ANOMALY_DETECTOR_ARN,
         &UPDATELOGANOMALYDETECTORINPUT_MEMBER_EVALUATION_FREQUENCY,
         &UPDATELOGANOMALYDETECTORINPUT_MEMBER_FILTER_PATTERN,
         &UPDATELOGANOMALYDETECTORINPUT_MEMBER_ANOMALY_VISIBILITY_TIME,
         &UPDATELOGANOMALYDETECTORINPUT_MEMBER_ENABLED,
     ],
 );
 impl UpdateLogAnomalyDetectorInput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &UPDATELOGANOMALYDETECTORINPUT_SCHEMA;
-108
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for UpdateLogAnomalyDetectorInput {
     #[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.anomaly_detector_arn {
             ser.write_string(&UPDATELOGANOMALYDETECTORINPUT_MEMBER_ANOMALY_DETECTOR_ARN, val)?;
-117
+        }
         if let Some(ref val) = self.evaluation_frequency {
             ser.write_string(&UPDATELOGANOMALYDETECTORINPUT_MEMBER_EVALUATION_FREQUENCY, val.as_str())?;
-120
+        }
         if let Some(ref val) = self.filter_pattern {
             ser.write_string(&UPDATELOGANOMALYDETECTORINPUT_MEMBER_FILTER_PATTERN, val)?;
-123
+        }
         if let Some(ref val) = self.anomaly_visibility_time {
             ser.write_long(&UPDATELOGANOMALYDETECTORINPUT_MEMBER_ANOMALY_VISIBILITY_TIME, *val)?;
-126
+        }
         if let Some(ref val) = self.enabled {
             ser.write_boolean(&UPDATELOGANOMALYDETECTORINPUT_MEMBER_ENABLED, *val)?;
-129
+        }
         Ok(())
-131
+    }
-132
+}
 impl UpdateLogAnomalyDetectorInput {
     /// 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(&UPDATELOGANOMALYDETECTORINPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&UPDATELOGANOMALYDETECTORINPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.anomaly_detector_arn = Some(deser.read_string(member)?);
-151
+                }
                 Some(1) => {
                     builder.evaluation_frequency = Some(crate::types::EvaluationFrequency::from(deser.read_string(member)?.as_str()));
-154
+                }
                 Some(2) => {
                     builder.filter_pattern = Some(deser.read_string(member)?);
-157
+                }
                 Some(3) => {
                     builder.anomaly_visibility_time = Some(deser.read_long(member)?);
-160
+                }
                 Some(4) => {
                     builder.enabled = Some(deser.read_boolean(member)?);
-163
+                }
                 _ => {}
-165
+            }
             Ok(())
         })?;
         builder.anomaly_detector_arn = builder.anomaly_detector_arn.or(Some(String::new()));
         builder.enabled = builder.enabled.or(Some(false));
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-173
+    }
-174
+}
 impl UpdateLogAnomalyDetectorInput {
     /// 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 UpdateLogAnomalyDetectorInput {
     /// Creates a new builder-style object to manufacture [`UpdateLogAnomalyDetectorInput`](crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorInput).
     pub fn builder() -> crate::operation::update_log_anomaly_detector::builders::UpdateLogAnomalyDetectorInputBuilder {
         crate::operation::update_log_anomaly_detector::builders::UpdateLogAnomalyDetectorInputBuilder::default()
-190
+    }
-191
+}
-192
 /// A builder for [`UpdateLogAnomalyDetectorInput`](crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorInput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]

↧ Expand context

 pub struct UpdateLogAnomalyDetectorInputBuilder {
     pub(crate) anomaly_detector_arn: ::std::option::Option<::std::string::String>,
     pub(crate) evaluation_frequency: ::std::option::Option<crate::types::EvaluationFrequency>,
     pub(crate) filter_pattern: ::std::option::Option<::std::string::String>,
     pub(crate) anomaly_visibility_time: ::std::option::Option<i64>,
     pub(crate) enabled: ::std::option::Option<bool>,
-202
+}
 impl UpdateLogAnomalyDetectorInputBuilder {
     /// <p>The ARN of the anomaly detector that you want to update.</p>
     /// This field is required.
     pub fn anomaly_detector_arn(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         self.anomaly_detector_arn = ::std::option::Option::Some(input.into());
         self
-209
+    }
     /// <p>The ARN of the anomaly detector that you want to update.</p>
     pub fn set_anomaly_detector_arn(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         self.anomaly_detector_arn = input;
         self
-214
+    }
     /// <p>The ARN of the anomaly detector that you want to update.</p>

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/operation/update_log_anomaly_detector/_update_log_anomaly_detector_output.rs

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

↥ Expand context

 #[non_exhaustive]
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct UpdateLogAnomalyDetectorOutput {
     _request_id: Option<String>,
-7
+}
 static UPDATELOGANOMALYDETECTOROUTPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.cloudwatchlogs.synthetic#UpdateLogAnomalyDetectorOutput",
     "com.amazonaws.cloudwatchlogs.synthetic",
     "UpdateLogAnomalyDetectorOutput",
 );
 static UPDATELOGANOMALYDETECTOROUTPUT_SCHEMA: ::aws_smithy_schema::Schema =
     ::aws_smithy_schema::Schema::new_struct(UPDATELOGANOMALYDETECTOROUTPUT_SCHEMA_ID, ::aws_smithy_schema::ShapeType::Structure, &[]);
 static UPDATELOGANOMALYDETECTOROUTPUT_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 UPDATELOGANOMALYDETECTOROUTPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     UPDATELOGANOMALYDETECTOROUTPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[&UPDATELOGANOMALYDETECTOROUTPUT_MEMBER__REQUEST_ID],
 );
 impl UpdateLogAnomalyDetectorOutput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &UPDATELOGANOMALYDETECTOROUTPUT_SCHEMA;
-28
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for UpdateLogAnomalyDetectorOutput {
     #[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 UpdateLogAnomalyDetectorOutput {
     /// 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(&UPDATELOGANOMALYDETECTOROUTPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&UPDATELOGANOMALYDETECTOROUTPUT_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 UpdateLogAnomalyDetectorOutput {
     /// 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 UpdateLogAnomalyDetectorOutput {
     fn request_id(&self) -> Option<&str> {
         self._request_id.as_deref()
-85
+    }
-86
+}
 impl UpdateLogAnomalyDetectorOutput {
     /// Creates a new builder-style object to manufacture [`UpdateLogAnomalyDetectorOutput`](crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorOutput).
     pub fn builder() -> crate::operation::update_log_anomaly_detector::builders::UpdateLogAnomalyDetectorOutputBuilder {
         crate::operation::update_log_anomaly_detector::builders::UpdateLogAnomalyDetectorOutputBuilder::default()
-91
+    }

↧ Expand context

-92
+}
-93
 /// A builder for [`UpdateLogAnomalyDetectorOutput`](crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorOutput).
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct UpdateLogAnomalyDetectorOutputBuilder {
     _request_id: Option<String>,
-99
+}
 impl UpdateLogAnomalyDetectorOutputBuilder {
     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 [`UpdateLogAnomalyDetectorOutput`](crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorOutput).
     pub fn build(self) -> crate::operation::update_log_anomaly_detector::UpdateLogAnomalyDetectorOutput {

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

@@ -1,1 +762,68 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 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)
-+
+}
-+
 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>,
-15
+>
 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,
-19
+{
     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)
-24
+}
-25
 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)
--
+}
--
 pub(crate) mod shape_associate_kms_key;
--
 pub(crate) mod shape_cancel_export_task;
--
 pub(crate) mod shape_create_delivery;
--
 pub(crate) mod shape_create_export_task;
--
 pub(crate) mod shape_create_log_anomaly_detector;
--
 pub(crate) mod shape_create_log_group;
--
 pub(crate) mod shape_create_log_stream;
--
 pub(crate) mod shape_delete_account_policy;
--
 pub(crate) mod shape_delete_data_protection_policy;
--
 pub(crate) mod shape_delete_delivery;
--
 pub(crate) mod shape_delete_delivery_destination;
--
 pub(crate) mod shape_delete_delivery_destination_policy;
--
 pub(crate) mod shape_delete_delivery_source;
--
 pub(crate) mod shape_delete_destination;
--
 pub(crate) mod shape_delete_index_policy;
--
 pub(crate) mod shape_delete_integration;
--
 pub(crate) mod shape_delete_log_anomaly_detector;
--
 pub(crate) mod shape_delete_log_group;
--
 pub(crate) mod shape_delete_log_stream;
--
 pub(crate) mod shape_delete_metric_filter;
--
 pub(crate) mod shape_delete_query_definition;
--
 pub(crate) mod shape_delete_resource_policy;
--
 pub(crate) mod shape_delete_retention_policy;
--
 pub(crate) mod shape_delete_subscription_filter;
--
 pub(crate) mod shape_delete_transformer;
--
 pub(crate) mod shape_describe_account_policies;
--
 pub(crate) mod shape_describe_configuration_templates;
--
 pub(crate) mod shape_describe_deliveries;
--
 pub(crate) mod shape_describe_delivery_destinations;
--
 pub(crate) mod shape_describe_delivery_sources;
--
 pub(crate) mod shape_describe_destinations;
--
 pub(crate) mod shape_describe_export_tasks;
--
 pub(crate) mod shape_describe_field_indexes;
--
 pub(crate) mod shape_describe_index_policies;
--
 pub(crate) mod shape_describe_log_groups;
--
 pub(crate) mod shape_describe_log_streams;
--
 pub(crate) mod shape_describe_metric_filters;
--
 pub(crate) mod shape_describe_queries;
--
 pub(crate) mod shape_describe_query_definitions;
--
 pub(crate) mod shape_describe_resource_policies;
--
 pub(crate) mod shape_describe_subscription_filters;
--
 pub(crate) mod shape_disassociate_kms_key;
--
 pub(crate) mod shape_filter_log_events;
--
 pub(crate) mod shape_get_data_protection_policy;
--
 pub(crate) mod shape_get_delivery;
--
 pub(crate) mod shape_get_delivery_destination;
--
 pub(crate) mod shape_get_delivery_destination_policy;
--
 pub(crate) mod shape_get_delivery_source;
--
 pub(crate) mod shape_get_integration;
--
 pub(crate) mod shape_get_log_anomaly_detector;
--
 pub(crate) mod shape_get_log_events;
--
 pub(crate) mod shape_get_log_group_fields;
--
 pub(crate) mod shape_get_log_object;
-27
 pub(crate) mod shape_get_log_record;
--
 pub(crate) mod shape_get_query_results;
--
 pub(crate) mod shape_get_transformer;
--
 pub(crate) mod shape_list_anomalies;
--
 pub(crate) mod shape_list_integrations;
--
 pub(crate) mod shape_list_log_anomaly_detectors;
--
 pub(crate) mod shape_list_log_groups;
--
 pub(crate) mod shape_list_log_groups_for_query;
--
 pub(crate) mod shape_list_tags_for_resource;
--
 pub(crate) mod shape_list_tags_log_group;
--
 pub(crate) mod shape_put_account_policy;
--
 pub(crate) mod shape_put_data_protection_policy;
--
 pub(crate) mod shape_put_delivery_destination;
--
 pub(crate) mod shape_put_delivery_destination_policy;
--
 pub(crate) mod shape_put_delivery_source;
--
 pub(crate) mod shape_put_destination;
--
 pub(crate) mod shape_put_destination_policy;
--
 pub(crate) mod shape_put_index_policy;
--
 pub(crate) mod shape_put_integration;
--
 pub(crate) mod shape_put_log_events;
--
 pub(crate) mod shape_put_metric_filter;
--
 pub(crate) mod shape_put_query_definition;
--
 pub(crate) mod shape_put_resource_policy;
--
 pub(crate) mod shape_put_retention_policy;
--
 pub(crate) mod shape_put_subscription_filter;
--
 pub(crate) mod shape_put_transformer;
--
 pub(crate) mod shape_start_live_tail;
-29
 pub(crate) mod shape_start_query;
--
 pub(crate) mod shape_stop_query;
--
 pub(crate) mod shape_tag_log_group;
--
 pub(crate) mod shape_tag_resource;
--
 pub(crate) mod shape_test_metric_filter;
--
 pub(crate) mod shape_test_transformer;
--
 pub(crate) mod shape_untag_log_group;
--
 pub(crate) mod shape_untag_resource;
--
 pub(crate) mod shape_update_anomaly;
--
 pub(crate) mod shape_update_delivery_configuration;
--
 pub(crate) mod shape_update_log_anomaly_detector;
--
 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_associate_kms_key_input;
--
 pub(crate) mod shape_cancel_export_task_input;
--
 pub(crate) mod shape_conflict_exception;
--
 pub(crate) mod shape_create_delivery_input;
--
 pub(crate) mod shape_create_export_task_input;
--
 pub(crate) mod shape_create_log_anomaly_detector_input;
--
 pub(crate) mod shape_create_log_group_input;
--
 pub(crate) mod shape_create_log_stream_input;
--
 pub(crate) mod shape_data_already_accepted_exception;
--
 pub(crate) mod shape_delete_account_policy_input;
--
 pub(crate) mod shape_delete_data_protection_policy_input;
--
 pub(crate) mod shape_delete_delivery_destination_input;
--
 pub(crate) mod shape_delete_delivery_destination_policy_input;
--
 pub(crate) mod shape_delete_delivery_input;
--
 pub(crate) mod shape_delete_delivery_source_input;
--
 pub(crate) mod shape_delete_destination_input;
--
 pub(crate) mod shape_delete_index_policy_input;
--
 pub(crate) mod shape_delete_integration_input;
--
 pub(crate) mod shape_delete_log_anomaly_detector_input;
--
 pub(crate) mod shape_delete_log_group_input;
--
 pub(crate) mod shape_delete_log_stream_input;
--
 pub(crate) mod shape_delete_metric_filter_input;
--
 pub(crate) mod shape_delete_query_definition_input;
--
 pub(crate) mod shape_delete_resource_policy_input;
--
 pub(crate) mod shape_delete_retention_policy_input;
--
 pub(crate) mod shape_delete_subscription_filter_input;
--
 pub(crate) mod shape_delete_transformer_input;
--
 pub(crate) mod shape_describe_account_policies_input;
--
 pub(crate) mod shape_describe_configuration_templates_input;
--
 pub(crate) mod shape_describe_deliveries_input;
--
 pub(crate) mod shape_describe_delivery_destinations_input;
--
 pub(crate) mod shape_describe_delivery_sources_input;
--
 pub(crate) mod shape_describe_destinations_input;
--
 pub(crate) mod shape_describe_export_tasks_input;
--
 pub(crate) mod shape_describe_field_indexes_input;
--
 pub(crate) mod shape_describe_index_policies_input;
--
 pub(crate) mod shape_describe_log_groups_input;
--
 pub(crate) mod shape_describe_log_streams_input;
--
 pub(crate) mod shape_describe_metric_filters_input;
--
 pub(crate) mod shape_describe_queries_input;
--
 pub(crate) mod shape_describe_query_definitions_input;
--
 pub(crate) mod shape_describe_resource_policies_input;
--
 pub(crate) mod shape_describe_subscription_filters_input;
--
 pub(crate) mod shape_disassociate_kms_key_input;
--
 pub(crate) mod shape_filter_log_events_input;
--
 pub(crate) mod shape_get_data_protection_policy_input;
--
 pub(crate) mod shape_get_delivery_destination_input;
--
 pub(crate) mod shape_get_delivery_destination_policy_input;
--
 pub(crate) mod shape_get_delivery_input;
--
 pub(crate) mod shape_get_delivery_source_input;
--
 pub(crate) mod shape_get_integration_input;
--
 pub(crate) mod shape_get_log_anomaly_detector_input;
--
 pub(crate) mod shape_get_log_events_input;
--
 pub(crate) mod shape_get_log_group_fields_input;
--
 pub(crate) mod shape_get_log_object_input;
--
 pub(crate) mod shape_get_log_object_output;
-31
 pub(crate) mod shape_get_log_record_input;
--
 pub(crate) mod shape_get_query_results_input;
--
 pub(crate) mod shape_get_transformer_input;
--
 pub(crate) mod shape_internal_streaming_exception;
--
 pub(crate) mod shape_invalid_operation_exception;
--
 pub(crate) mod shape_invalid_parameter_exception;
--
 pub(crate) mod shape_invalid_sequence_token_exception;
--
 pub(crate) mod shape_limit_exceeded_exception;
--
 pub(crate) mod shape_list_anomalies_input;
--
 pub(crate) mod shape_list_integrations_input;
--
 pub(crate) mod shape_list_log_anomaly_detectors_input;
--
 pub(crate) mod shape_list_log_groups_for_query_input;
--
 pub(crate) mod shape_list_log_groups_input;
--
 pub(crate) mod shape_list_tags_for_resource_input;
--
 pub(crate) mod shape_list_tags_log_group_input;
--
 pub(crate) mod shape_malformed_query_exception;
--
 pub(crate) mod shape_operation_aborted_exception;
--
 pub(crate) mod shape_put_account_policy_input;
--
 pub(crate) mod shape_put_data_protection_policy_input;
--
 pub(crate) mod shape_put_delivery_destination_input;
--
 pub(crate) mod shape_put_delivery_destination_policy_input;
--
 pub(crate) mod shape_put_delivery_source_input;
--
 pub(crate) mod shape_put_destination_input;
--
 pub(crate) mod shape_put_destination_policy_input;
--
 pub(crate) mod shape_put_index_policy_input;
--
 pub(crate) mod shape_put_integration_input;
--
 pub(crate) mod shape_put_log_events_input;
--
 pub(crate) mod shape_put_metric_filter_input;
--
 pub(crate) mod shape_put_query_definition_input;
--
 pub(crate) mod shape_put_resource_policy_input;
--
 pub(crate) mod shape_put_retention_policy_input;
--
 pub(crate) mod shape_put_subscription_filter_input;
--
 pub(crate) mod shape_put_transformer_input;
--
 pub(crate) mod shape_resource_already_exists_exception;
--
 pub(crate) mod shape_resource_not_found_exception;
--
 pub(crate) mod shape_service_quota_exceeded_exception;
--
 pub(crate) mod shape_service_unavailable_exception;
--
 pub(crate) mod shape_session_streaming_exception;
--
 pub(crate) mod shape_session_timeout_exception;
--
 pub(crate) mod shape_start_live_tail_input;
--
 pub(crate) mod shape_start_live_tail_output;
-33
 pub(crate) mod shape_start_query_input;
--
 pub(crate) mod shape_stop_query_input;
--
 pub(crate) mod shape_tag_log_group_input;
--
 pub(crate) mod shape_tag_resource_input;
--
 pub(crate) mod shape_test_metric_filter_input;
--
 pub(crate) mod shape_test_transformer_input;
--
 pub(crate) mod shape_throttling_exception;
--
 pub(crate) mod shape_too_many_tags_exception;
--
 pub(crate) mod shape_unrecognized_client_exception;
--
 pub(crate) mod shape_untag_log_group_input;
--
 pub(crate) mod shape_untag_resource_input;
--
 pub(crate) mod shape_update_anomaly_input;
--
 pub(crate) mod shape_update_delivery_configuration_input;
--
 pub(crate) mod shape_update_log_anomaly_detector_input;
--
 pub(crate) mod shape_validation_exception;
--
 pub fn parse_event_stream_error_metadata(
     payload: &::bytes::Bytes,
 ) -> ::std::result::Result<::aws_smithy_types::error::metadata::Builder, ::aws_smithy_json::deserialize::error::DeserializeError> {
     crate::json_errors::parse_error_metadata(payload, &::aws_smithy_runtime_api::http::Headers::new())
-38
+}
-39
 pub(crate) mod shape_account_policies;
--
 pub(crate) mod shape_account_policy;
--
 pub(crate) mod shape_anomalies;
--
 pub(crate) mod shape_anomaly_detectors;
--
 pub(crate) mod shape_configuration_templates;
--
 pub(crate) mod shape_deliveries;
--
 pub(crate) mod shape_delivery;
--
 pub(crate) mod shape_delivery_destination;
--
 pub(crate) mod shape_delivery_destination_configuration;
--
 pub(crate) mod shape_delivery_destinations;
--
 pub(crate) mod shape_delivery_source;
--
 pub(crate) mod shape_delivery_sources;
--
 pub(crate) mod shape_destination;
--
 pub(crate) mod shape_destinations;
--
 pub(crate) mod shape_entity;
--
 pub(crate) mod shape_export_tasks;
--
 pub(crate) mod shape_field_indexes;
--
 pub(crate) mod shape_filtered_log_events;
--
 pub(crate) mod shape_index_policies;
--
 pub(crate) mod shape_index_policy;
--
 pub(crate) mod shape_input_log_event;
--
 pub(crate) mod shape_integration_details;
--
 pub(crate) mod shape_integration_summaries;
--
 pub(crate) mod shape_log_group_arn_list;
--
 pub(crate) mod shape_log_group_field_list;
--
 pub(crate) mod shape_log_group_identifiers;
--
 pub(crate) mod shape_log_group_summaries;
--
 pub(crate) mod shape_log_groups;
--
 pub(crate) mod shape_log_record;
--
 pub(crate) mod shape_log_streams;
--
 pub(crate) mod shape_metric_filter_matches;
--
 pub(crate) mod shape_metric_filters;
--
 pub(crate) mod shape_metric_transformation;
--
 pub(crate) mod shape_output_log_events;
--
 pub(crate) mod shape_policy;
--
 pub(crate) mod shape_processor;
--
 pub(crate) mod shape_processors;
--
 pub(crate) mod shape_query_compile_error;
--
 pub(crate) mod shape_query_definition_list;
--
 pub(crate) mod shape_query_info_list;
--
 pub(crate) mod shape_query_results;
--
 pub(crate) mod shape_query_statistics;
--
 pub(crate) mod shape_rejected_entity_info;
--
 pub(crate) mod shape_rejected_log_events_info;
--
 pub(crate) mod shape_resource_config;
--
 pub(crate) mod shape_resource_policies;
--
 pub(crate) mod shape_resource_policy;
--
 pub(crate) mod shape_s3_delivery_configuration;
--
 pub(crate) mod shape_searched_log_streams;
--
 pub(crate) mod shape_subscription_filters;
--
 pub(crate) mod shape_suppression_period;
--
 pub(crate) mod shape_tags;
--
 pub(crate) mod shape_transformed_logs;
--
 pub(crate) mod shape_add_keys;
--
 pub(crate) mod shape_anomaly;
--
 pub(crate) mod shape_anomaly_detector;
--
 pub(crate) mod shape_configuration_template;
--
 pub(crate) mod shape_copy_value;
--
 pub(crate) mod shape_csv;
--
 pub(crate) mod shape_date_time_converter;
--
 pub(crate) mod shape_delete_keys;
--
 pub(crate) mod shape_export_task;
--
 pub(crate) mod shape_field_index;
 pub(crate) fn or_empty_doc(data: &[u8]) -> &[u8] {
     if data.is_empty() {
         b"{}"
     } else {
         data
-+
+    }
-+
+}
-47
 pub(crate) mod shape_fields_data;
-49
 pub(crate) mod shape_filtered_log_event;
--
 pub(crate) mod shape_grok;
--
 pub(crate) mod shape_integration_summary;
--
 pub(crate) mod shape_list_to_map;
 pub(crate) mod shape_internal_streaming_exception;
-51
 pub(crate) mod shape_live_tail_session_start;
-53
 pub(crate) mod shape_live_tail_session_update;
-55
 pub(crate) mod shape_log_group;
--
 pub(crate) mod shape_log_group_field;
--
 pub(crate) mod shape_log_group_summary;
--
 pub(crate) mod shape_log_stream;
--
 pub(crate) mod shape_lower_case_string;
--
 pub(crate) mod shape_metric_filter;
--
 pub(crate) mod shape_metric_filter_match_record;
--
 pub(crate) mod shape_move_keys;
--
 pub(crate) mod shape_open_search_integration_details;
--
 pub(crate) mod shape_open_search_resource_config;
--
 pub(crate) mod shape_output_log_event;
--
 pub(crate) mod shape_parse_cloudfront;
--
 pub(crate) mod shape_parse_json;
--
 pub(crate) mod shape_parse_key_value;
--
 pub(crate) mod shape_parse_postgres;
--
 pub(crate) mod shape_parse_route53;
--
 pub(crate) mod shape_parse_to_ocsf;
--
 pub(crate) mod shape_parse_vpc;
--
 pub(crate) mod shape_parse_waf;
--
 pub(crate) mod shape_query_compile_error_location;
--
 pub(crate) mod shape_query_definition;
--
 pub(crate) mod shape_query_info;
--
 pub(crate) mod shape_record_fields;
--
 pub(crate) mod shape_rename_keys;
--
 pub(crate) mod shape_resource_arns;
--
 pub(crate) mod shape_result_rows;
--
 pub(crate) mod shape_searched_log_stream;
--
 pub(crate) mod shape_split_string;
--
 pub(crate) mod shape_subscription_filter;
--
 pub(crate) mod shape_substitute_string;
--
 pub(crate) mod shape_transformed_log_record;
--
 pub(crate) mod shape_trim_string;
--
 pub(crate) mod shape_type_converter;
--
 pub(crate) mod shape_upper_case_string;
--
 pub(crate) mod shape_add_key_entry;
--
 pub(crate) mod shape_allowed_field_delimiters;
--
 pub(crate) mod shape_allowed_fields;
--
 pub(crate) mod shape_configuration_template_delivery_config_values;
--
 pub(crate) mod shape_copy_value_entry;
--
 pub(crate) mod shape_emit_system_fields;
--
 pub(crate) mod shape_export_task_execution_info;
--
 pub(crate) mod shape_export_task_status;
--
 pub(crate) mod shape_extracted_values;
--
 pub(crate) mod shape_histogram;
--
 pub(crate) mod shape_inherited_properties;
--
 pub(crate) mod shape_log_group_names;
--
 pub(crate) mod shape_log_samples;
--
 pub(crate) mod shape_metric_transformations;
--
 pub(crate) mod shape_move_key_entry;
--
 pub(crate) mod shape_open_search_application;
--
 pub(crate) mod shape_open_search_collection;
--
 pub(crate) mod shape_open_search_data_access_policy;
--
 pub(crate) mod shape_open_search_data_source;
--
 pub(crate) mod shape_open_search_encryption_policy;
--
 pub(crate) mod shape_open_search_lifecycle_policy;
--
 pub(crate) mod shape_open_search_network_policy;
--
 pub(crate) mod shape_open_search_workspace;
--
 pub(crate) mod shape_output_formats;
--
 pub(crate) mod shape_pattern_tokens;
--
 pub(crate) mod shape_rename_key_entry;
--
 pub(crate) mod shape_result_field;
--
 pub(crate) mod shape_split_string_entry;
--
 pub(crate) mod shape_substitute_string_entry;
--
 pub(crate) mod shape_type_converter_entry;
--
 pub(crate) mod shape_add_key_entries;
--
 pub(crate) mod shape_columns;
--
 pub(crate) mod shape_copy_value_entries;
 pub(crate) mod shape_session_streaming_exception;
-57
 pub(crate) mod shape_delete_with_keys;
 pub(crate) mod shape_session_timeout_exception;
-59
 pub(crate) mod shape_input_log_stream_names;
-61
 pub(crate) mod shape_live_tail_session_metadata;
-63
 pub(crate) mod shape_live_tail_session_results;
-65
 pub(crate) mod shape_log_event;
--
 pub(crate) mod shape_lower_case_string_with_keys;
--
 pub(crate) mod shape_match_patterns;
--
 pub(crate) mod shape_move_key_entries;
--
 pub(crate) mod shape_open_search_resource_status;
--
 pub(crate) mod shape_pattern_token;
--
 pub(crate) mod shape_record_field;
--
 pub(crate) mod shape_rename_key_entries;
--
 pub(crate) mod shape_split_string_entries;
--
 pub(crate) mod shape_start_live_tail_log_group_identifiers;
-67
 pub(crate) mod shape_substitute_string_entries;
--
 pub(crate) mod shape_trim_string_with_keys;
--
 pub(crate) mod shape_type_converter_entries;
--
 pub(crate) mod shape_upper_case_string_with_keys;
--
 pub(crate) mod shape_dimensions;
--
 pub(crate) mod shape_enumerations;
--
 pub(crate) mod shape_live_tail_session_log_event;

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

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:

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/operation/update_delivery_configuration.rs

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/operation/update_delivery_configuration/_update_delivery_configuration_input.rs

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/operation/update_delivery_configuration/_update_delivery_configuration_output.rs

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/operation/update_log_anomaly_detector.rs

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/operation/update_log_anomaly_detector/_update_log_anomaly_detector_input.rs

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/operation/update_log_anomaly_detector/_update_log_anomaly_detector_output.rs

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