AWS SDK

AWS SDK

rev. ee474c7509d7728618c23068f3741e8e5b339ef9

Files changed:

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/list_storage_lens_configurations.rs

@@ -183,183 +252,252 @@
  203    203   
                if let ::std::option::Option::Some(inner_1) = &_input.next_token {
  204    204   
                    {
  205    205   
                        query.push_kv("nextToken", &::aws_smithy_http::query::fmt_string(inner_1));
  206    206   
                    }
  207    207   
                }
  208    208   
                ::std::result::Result::Ok(())
  209    209   
            }
  210    210   
            #[allow(clippy::unnecessary_wraps)]
  211    211   
            fn update_http_builder(
  212    212   
                input: &crate::operation::list_storage_lens_configurations::ListStorageLensConfigurationsInput,
  213         -
                builder: ::http::request::Builder,
  214         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         213  +
                builder: ::http_1x::request::Builder,
         214  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  215    215   
                let mut uri = ::std::string::String::new();
  216    216   
                uri_base(input, &mut uri)?;
  217    217   
                uri_query(input, &mut uri)?;
  218    218   
                let builder =
  219    219   
                    crate::protocol_serde::shape_list_storage_lens_configurations::ser_list_storage_lens_configurations_headers(input, builder)?;
  220    220   
                ::std::result::Result::Ok(builder.method("GET").uri(uri))
  221    221   
            }
  222         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
         222  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
  223    223   
            builder
  224    224   
        };
  225    225   
        let body = ::aws_smithy_types::body::SdkBody::from("");
  226    226   
  227    227   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  228    228   
    }
  229    229   
}
  230    230   
#[derive(Debug)]
  231    231   
struct ListStorageLensConfigurationsEndpointParamsInterceptor;
  232    232   

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/list_storage_lens_groups.rs

@@ -177,177 +245,245 @@
  197    197   
                if let ::std::option::Option::Some(inner_1) = &_input.next_token {
  198    198   
                    {
  199    199   
                        query.push_kv("nextToken", &::aws_smithy_http::query::fmt_string(inner_1));
  200    200   
                    }
  201    201   
                }
  202    202   
                ::std::result::Result::Ok(())
  203    203   
            }
  204    204   
            #[allow(clippy::unnecessary_wraps)]
  205    205   
            fn update_http_builder(
  206    206   
                input: &crate::operation::list_storage_lens_groups::ListStorageLensGroupsInput,
  207         -
                builder: ::http::request::Builder,
  208         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         207  +
                builder: ::http_1x::request::Builder,
         208  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  209    209   
                let mut uri = ::std::string::String::new();
  210    210   
                uri_base(input, &mut uri)?;
  211    211   
                uri_query(input, &mut uri)?;
  212    212   
                let builder = crate::protocol_serde::shape_list_storage_lens_groups::ser_list_storage_lens_groups_headers(input, builder)?;
  213    213   
                ::std::result::Result::Ok(builder.method("GET").uri(uri))
  214    214   
            }
  215         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
         215  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
  216    216   
            builder
  217    217   
        };
  218    218   
        let body = ::aws_smithy_types::body::SdkBody::from("");
  219    219   
  220    220   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  221    221   
    }
  222    222   
}
  223    223   
#[derive(Debug)]
  224    224   
struct ListStorageLensGroupsEndpointParamsInterceptor;
  225    225   

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/list_tags_for_resource.rs

@@ -176,176 +243,243 @@
  196    196   
                        "resource_arn",
  197    197   
                        "cannot be empty or unset",
  198    198   
                    ));
  199    199   
                }
  200    200   
                ::std::write!(output, "/v20180820/tags/{ResourceArn}", ResourceArn = resource_arn).expect("formatting should succeed");
  201    201   
                ::std::result::Result::Ok(())
  202    202   
            }
  203    203   
            #[allow(clippy::unnecessary_wraps)]
  204    204   
            fn update_http_builder(
  205    205   
                input: &crate::operation::list_tags_for_resource::ListTagsForResourceInput,
  206         -
                builder: ::http::request::Builder,
  207         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         206  +
                builder: ::http_1x::request::Builder,
         207  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  208    208   
                let mut uri = ::std::string::String::new();
  209    209   
                uri_base(input, &mut uri)?;
  210    210   
                let builder = crate::protocol_serde::shape_list_tags_for_resource::ser_list_tags_for_resource_headers(input, builder)?;
  211    211   
                ::std::result::Result::Ok(builder.method("GET").uri(uri))
  212    212   
            }
  213         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
         213  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
  214    214   
            builder
  215    215   
        };
  216    216   
        let body = ::aws_smithy_types::body::SdkBody::from("");
  217    217   
  218    218   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  219    219   
    }
  220    220   
}
  221    221   
#[derive(Debug)]
  222    222   
struct ListTagsForResourceEndpointParamsInterceptor;
  223    223   

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_access_grants_instance_resource_policy.rs

@@ -175,175 +254,254 @@
  195    195   
                _input: &crate::operation::put_access_grants_instance_resource_policy::PutAccessGrantsInstanceResourcePolicyInput,
  196    196   
                output: &mut ::std::string::String,
  197    197   
            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
  198    198   
                use ::std::fmt::Write as _;
  199    199   
                ::std::write!(output, "/v20180820/accessgrantsinstance/resourcepolicy").expect("formatting should succeed");
  200    200   
                ::std::result::Result::Ok(())
  201    201   
            }
  202    202   
            #[allow(clippy::unnecessary_wraps)]
  203    203   
            fn update_http_builder(
  204    204   
                input: &crate::operation::put_access_grants_instance_resource_policy::PutAccessGrantsInstanceResourcePolicyInput,
  205         -
                builder: ::http::request::Builder,
  206         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         205  +
                builder: ::http_1x::request::Builder,
         206  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  207    207   
                let mut uri = ::std::string::String::new();
  208    208   
                uri_base(input, &mut uri)?;
  209    209   
                let builder =
  210    210   
                    crate::protocol_serde::shape_put_access_grants_instance_resource_policy::ser_put_access_grants_instance_resource_policy_headers(
  211    211   
                        input, builder,
  212    212   
                    )?;
  213    213   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  214    214   
            }
  215         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  216         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         215  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         216  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  217    217   
            builder
  218    218   
        };
  219    219   
        let body = ::aws_smithy_types::body::SdkBody::from(
  220    220   
            crate::protocol_serde::shape_put_access_grants_instance_resource_policy::ser_put_access_grants_instance_resource_policy_op_input(&input)?,
  221    221   
        );
  222    222   
        if let Some(content_length) = body.content_length() {
  223    223   
            let content_length = content_length.to_string();
  224         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         224  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  225    225   
        }
  226    226   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  227    227   
    }
  228    228   
}
  229    229   
#[derive(Debug)]
  230    230   
struct PutAccessGrantsInstanceResourcePolicyEndpointParamsInterceptor;
  231    231   
  232    232   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutAccessGrantsInstanceResourcePolicyEndpointParamsInterceptor {
  233    233   
    fn name(&self) -> &'static str {
  234    234   
        "PutAccessGrantsInstanceResourcePolicyEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_access_point_configuration_for_object_lambda.rs

@@ -183,183 +257,257 @@
  203    203   
                        "name",
  204    204   
                        "cannot be empty or unset",
  205    205   
                    ));
  206    206   
                }
  207    207   
                ::std::write!(output, "/v20180820/accesspointforobjectlambda/{Name}/configuration", Name = name).expect("formatting should succeed");
  208    208   
                ::std::result::Result::Ok(())
  209    209   
            }
  210    210   
            #[allow(clippy::unnecessary_wraps)]
  211    211   
            fn update_http_builder(
  212    212   
                input: &crate::operation::put_access_point_configuration_for_object_lambda::PutAccessPointConfigurationForObjectLambdaInput,
  213         -
                builder: ::http::request::Builder,
  214         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         213  +
                builder: ::http_1x::request::Builder,
         214  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  215    215   
                let mut uri = ::std::string::String::new();
  216    216   
                uri_base(input, &mut uri)?;
  217    217   
                let builder = crate::protocol_serde::shape_put_access_point_configuration_for_object_lambda::ser_put_access_point_configuration_for_object_lambda_headers(input, builder)?;
  218    218   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  219    219   
            }
  220         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  221         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         220  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         221  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  222    222   
            builder
  223    223   
        };
  224    224   
        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_put_access_point_configuration_for_object_lambda::ser_put_access_point_configuration_for_object_lambda_op_input(&input)?);
  225    225   
        if let Some(content_length) = body.content_length() {
  226    226   
            let content_length = content_length.to_string();
  227         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         227  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  228    228   
        }
  229    229   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  230    230   
    }
  231    231   
}
  232    232   
#[derive(Debug)]
  233    233   
struct PutAccessPointConfigurationForObjectLambdaEndpointParamsInterceptor;
  234    234   
  235    235   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutAccessPointConfigurationForObjectLambdaEndpointParamsInterceptor {
  236    236   
    fn name(&self) -> &'static str {
  237    237   
        "PutAccessPointConfigurationForObjectLambdaEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_access_point_policy.rs

@@ -176,176 +252,252 @@
  196    196   
                        "name",
  197    197   
                        "cannot be empty or unset",
  198    198   
                    ));
  199    199   
                }
  200    200   
                ::std::write!(output, "/v20180820/accesspoint/{Name}/policy", Name = name).expect("formatting should succeed");
  201    201   
                ::std::result::Result::Ok(())
  202    202   
            }
  203    203   
            #[allow(clippy::unnecessary_wraps)]
  204    204   
            fn update_http_builder(
  205    205   
                input: &crate::operation::put_access_point_policy::PutAccessPointPolicyInput,
  206         -
                builder: ::http::request::Builder,
  207         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         206  +
                builder: ::http_1x::request::Builder,
         207  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  208    208   
                let mut uri = ::std::string::String::new();
  209    209   
                uri_base(input, &mut uri)?;
  210    210   
                let builder = crate::protocol_serde::shape_put_access_point_policy::ser_put_access_point_policy_headers(input, builder)?;
  211    211   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  212    212   
            }
  213         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  214         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         213  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         214  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  215    215   
            builder
  216    216   
        };
  217    217   
        let body = ::aws_smithy_types::body::SdkBody::from(
  218    218   
            crate::protocol_serde::shape_put_access_point_policy::ser_put_access_point_policy_op_input(&input)?,
  219    219   
        );
  220    220   
        if let Some(content_length) = body.content_length() {
  221    221   
            let content_length = content_length.to_string();
  222         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         222  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  223    223   
        }
  224    224   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  225    225   
    }
  226    226   
}
  227    227   
#[derive(Debug)]
  228    228   
struct PutAccessPointPolicyEndpointParamsInterceptor;
  229    229   
  230    230   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutAccessPointPolicyEndpointParamsInterceptor {
  231    231   
    fn name(&self) -> &'static str {
  232    232   
        "PutAccessPointPolicyEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_access_point_policy_for_object_lambda.rs

@@ -186,186 +265,265 @@
  206    206   
                        "name",
  207    207   
                        "cannot be empty or unset",
  208    208   
                    ));
  209    209   
                }
  210    210   
                ::std::write!(output, "/v20180820/accesspointforobjectlambda/{Name}/policy", Name = name).expect("formatting should succeed");
  211    211   
                ::std::result::Result::Ok(())
  212    212   
            }
  213    213   
            #[allow(clippy::unnecessary_wraps)]
  214    214   
            fn update_http_builder(
  215    215   
                input: &crate::operation::put_access_point_policy_for_object_lambda::PutAccessPointPolicyForObjectLambdaInput,
  216         -
                builder: ::http::request::Builder,
  217         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         216  +
                builder: ::http_1x::request::Builder,
         217  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  218    218   
                let mut uri = ::std::string::String::new();
  219    219   
                uri_base(input, &mut uri)?;
  220    220   
                let builder =
  221    221   
                    crate::protocol_serde::shape_put_access_point_policy_for_object_lambda::ser_put_access_point_policy_for_object_lambda_headers(
  222    222   
                        input, builder,
  223    223   
                    )?;
  224    224   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  225    225   
            }
  226         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  227         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         226  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         227  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  228    228   
            builder
  229    229   
        };
  230    230   
        let body = ::aws_smithy_types::body::SdkBody::from(
  231    231   
            crate::protocol_serde::shape_put_access_point_policy_for_object_lambda::ser_put_access_point_policy_for_object_lambda_op_input(&input)?,
  232    232   
        );
  233    233   
        if let Some(content_length) = body.content_length() {
  234    234   
            let content_length = content_length.to_string();
  235         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         235  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  236    236   
        }
  237    237   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  238    238   
    }
  239    239   
}
  240    240   
#[derive(Debug)]
  241    241   
struct PutAccessPointPolicyForObjectLambdaEndpointParamsInterceptor;
  242    242   
  243    243   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutAccessPointPolicyForObjectLambdaEndpointParamsInterceptor {
  244    244   
    fn name(&self) -> &'static str {
  245    245   
        "PutAccessPointPolicyForObjectLambdaEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_access_point_scope.rs

@@ -176,176 +252,252 @@
  196    196   
                        "name",
  197    197   
                        "cannot be empty or unset",
  198    198   
                    ));
  199    199   
                }
  200    200   
                ::std::write!(output, "/v20180820/accesspoint/{Name}/scope", Name = name).expect("formatting should succeed");
  201    201   
                ::std::result::Result::Ok(())
  202    202   
            }
  203    203   
            #[allow(clippy::unnecessary_wraps)]
  204    204   
            fn update_http_builder(
  205    205   
                input: &crate::operation::put_access_point_scope::PutAccessPointScopeInput,
  206         -
                builder: ::http::request::Builder,
  207         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         206  +
                builder: ::http_1x::request::Builder,
         207  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  208    208   
                let mut uri = ::std::string::String::new();
  209    209   
                uri_base(input, &mut uri)?;
  210    210   
                let builder = crate::protocol_serde::shape_put_access_point_scope::ser_put_access_point_scope_headers(input, builder)?;
  211    211   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  212    212   
            }
  213         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  214         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         213  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         214  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  215    215   
            builder
  216    216   
        };
  217    217   
        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_put_access_point_scope::ser_put_access_point_scope_op_input(
  218    218   
            &input,
  219    219   
        )?);
  220    220   
        if let Some(content_length) = body.content_length() {
  221    221   
            let content_length = content_length.to_string();
  222         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         222  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  223    223   
        }
  224    224   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  225    225   
    }
  226    226   
}
  227    227   
#[derive(Debug)]
  228    228   
struct PutAccessPointScopeEndpointParamsInterceptor;
  229    229   
  230    230   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutAccessPointScopeEndpointParamsInterceptor {
  231    231   
    fn name(&self) -> &'static str {
  232    232   
        "PutAccessPointScopeEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_bucket_lifecycle_configuration.rs

@@ -184,184 +263,263 @@
  204    204   
                        "bucket",
  205    205   
                        "cannot be empty or unset",
  206    206   
                    ));
  207    207   
                }
  208    208   
                ::std::write!(output, "/v20180820/bucket/{Bucket}/lifecycleconfiguration", Bucket = bucket).expect("formatting should succeed");
  209    209   
                ::std::result::Result::Ok(())
  210    210   
            }
  211    211   
            #[allow(clippy::unnecessary_wraps)]
  212    212   
            fn update_http_builder(
  213    213   
                input: &crate::operation::put_bucket_lifecycle_configuration::PutBucketLifecycleConfigurationInput,
  214         -
                builder: ::http::request::Builder,
  215         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         214  +
                builder: ::http_1x::request::Builder,
         215  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  216    216   
                let mut uri = ::std::string::String::new();
  217    217   
                uri_base(input, &mut uri)?;
  218    218   
                let builder =
  219    219   
                    crate::protocol_serde::shape_put_bucket_lifecycle_configuration::ser_put_bucket_lifecycle_configuration_headers(input, builder)?;
  220    220   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  221    221   
            }
  222         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  223         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         222  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         223  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  224    224   
            builder
  225    225   
        };
  226    226   
        let body = ::aws_smithy_types::body::SdkBody::from(
  227    227   
            crate::protocol_serde::shape_put_bucket_lifecycle_configuration_input::ser_lifecycle_configuration_http_payload(
  228    228   
                &input.lifecycle_configuration,
  229    229   
            )?,
  230    230   
        );
  231    231   
        if let Some(content_length) = body.content_length() {
  232    232   
            let content_length = content_length.to_string();
  233         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         233  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  234    234   
        }
  235    235   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  236    236   
    }
  237    237   
}
  238    238   
#[derive(Debug)]
  239    239   
struct PutBucketLifecycleConfigurationEndpointParamsInterceptor;
  240    240   
  241    241   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutBucketLifecycleConfigurationEndpointParamsInterceptor {
  242    242   
    fn name(&self) -> &'static str {
  243    243   
        "PutBucketLifecycleConfigurationEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_bucket_policy.rs

@@ -176,176 +250,250 @@
  196    196   
                        "bucket",
  197    197   
                        "cannot be empty or unset",
  198    198   
                    ));
  199    199   
                }
  200    200   
                ::std::write!(output, "/v20180820/bucket/{Bucket}/policy", Bucket = bucket).expect("formatting should succeed");
  201    201   
                ::std::result::Result::Ok(())
  202    202   
            }
  203    203   
            #[allow(clippy::unnecessary_wraps)]
  204    204   
            fn update_http_builder(
  205    205   
                input: &crate::operation::put_bucket_policy::PutBucketPolicyInput,
  206         -
                builder: ::http::request::Builder,
  207         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         206  +
                builder: ::http_1x::request::Builder,
         207  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  208    208   
                let mut uri = ::std::string::String::new();
  209    209   
                uri_base(input, &mut uri)?;
  210    210   
                let builder = crate::protocol_serde::shape_put_bucket_policy::ser_put_bucket_policy_headers(input, builder)?;
  211    211   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  212    212   
            }
  213         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  214         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         213  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         214  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  215    215   
            builder
  216    216   
        };
  217    217   
        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_put_bucket_policy::ser_put_bucket_policy_op_input(&input)?);
  218    218   
        if let Some(content_length) = body.content_length() {
  219    219   
            let content_length = content_length.to_string();
  220         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         220  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  221    221   
        }
  222    222   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  223    223   
    }
  224    224   
}
  225    225   
#[derive(Debug)]
  226    226   
struct PutBucketPolicyEndpointParamsInterceptor;
  227    227   
  228    228   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutBucketPolicyEndpointParamsInterceptor {
  229    229   
    fn name(&self) -> &'static str {
  230    230   
        "PutBucketPolicyEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_bucket_replication.rs

@@ -176,176 +252,252 @@
  196    196   
                        "bucket",
  197    197   
                        "cannot be empty or unset",
  198    198   
                    ));
  199    199   
                }
  200    200   
                ::std::write!(output, "/v20180820/bucket/{Bucket}/replication", Bucket = bucket).expect("formatting should succeed");
  201    201   
                ::std::result::Result::Ok(())
  202    202   
            }
  203    203   
            #[allow(clippy::unnecessary_wraps)]
  204    204   
            fn update_http_builder(
  205    205   
                input: &crate::operation::put_bucket_replication::PutBucketReplicationInput,
  206         -
                builder: ::http::request::Builder,
  207         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         206  +
                builder: ::http_1x::request::Builder,
         207  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  208    208   
                let mut uri = ::std::string::String::new();
  209    209   
                uri_base(input, &mut uri)?;
  210    210   
                let builder = crate::protocol_serde::shape_put_bucket_replication::ser_put_bucket_replication_headers(input, builder)?;
  211    211   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  212    212   
            }
  213         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  214         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         213  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         214  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  215    215   
            builder
  216    216   
        };
  217    217   
        let body = ::aws_smithy_types::body::SdkBody::from(
  218    218   
            crate::protocol_serde::shape_put_bucket_replication_input::ser_replication_configuration_http_payload(&input.replication_configuration)?,
  219    219   
        );
  220    220   
        if let Some(content_length) = body.content_length() {
  221    221   
            let content_length = content_length.to_string();
  222         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         222  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  223    223   
        }
  224    224   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  225    225   
    }
  226    226   
}
  227    227   
#[derive(Debug)]
  228    228   
struct PutBucketReplicationEndpointParamsInterceptor;
  229    229   
  230    230   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutBucketReplicationEndpointParamsInterceptor {
  231    231   
    fn name(&self) -> &'static str {
  232    232   
        "PutBucketReplicationEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_bucket_tagging.rs

@@ -176,176 +252,252 @@
  196    196   
                        "bucket",
  197    197   
                        "cannot be empty or unset",
  198    198   
                    ));
  199    199   
                }
  200    200   
                ::std::write!(output, "/v20180820/bucket/{Bucket}/tagging", Bucket = bucket).expect("formatting should succeed");
  201    201   
                ::std::result::Result::Ok(())
  202    202   
            }
  203    203   
            #[allow(clippy::unnecessary_wraps)]
  204    204   
            fn update_http_builder(
  205    205   
                input: &crate::operation::put_bucket_tagging::PutBucketTaggingInput,
  206         -
                builder: ::http::request::Builder,
  207         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         206  +
                builder: ::http_1x::request::Builder,
         207  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  208    208   
                let mut uri = ::std::string::String::new();
  209    209   
                uri_base(input, &mut uri)?;
  210    210   
                let builder = crate::protocol_serde::shape_put_bucket_tagging::ser_put_bucket_tagging_headers(input, builder)?;
  211    211   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  212    212   
            }
  213         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  214         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         213  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         214  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  215    215   
            builder
  216    216   
        };
  217    217   
        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_put_bucket_tagging_input::ser_tagging_http_payload(
  218    218   
            &input.tagging,
  219    219   
        )?);
  220    220   
        if let Some(content_length) = body.content_length() {
  221    221   
            let content_length = content_length.to_string();
  222         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         222  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  223    223   
        }
  224    224   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  225    225   
    }
  226    226   
}
  227    227   
#[derive(Debug)]
  228    228   
struct PutBucketTaggingEndpointParamsInterceptor;
  229    229   
  230    230   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutBucketTaggingEndpointParamsInterceptor {
  231    231   
    fn name(&self) -> &'static str {
  232    232   
        "PutBucketTaggingEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_bucket_versioning.rs

@@ -176,176 +252,252 @@
  196    196   
                        "bucket",
  197    197   
                        "cannot be empty or unset",
  198    198   
                    ));
  199    199   
                }
  200    200   
                ::std::write!(output, "/v20180820/bucket/{Bucket}/versioning", Bucket = bucket).expect("formatting should succeed");
  201    201   
                ::std::result::Result::Ok(())
  202    202   
            }
  203    203   
            #[allow(clippy::unnecessary_wraps)]
  204    204   
            fn update_http_builder(
  205    205   
                input: &crate::operation::put_bucket_versioning::PutBucketVersioningInput,
  206         -
                builder: ::http::request::Builder,
  207         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         206  +
                builder: ::http_1x::request::Builder,
         207  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  208    208   
                let mut uri = ::std::string::String::new();
  209    209   
                uri_base(input, &mut uri)?;
  210    210   
                let builder = crate::protocol_serde::shape_put_bucket_versioning::ser_put_bucket_versioning_headers(input, builder)?;
  211    211   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  212    212   
            }
  213         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  214         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         213  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         214  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  215    215   
            builder
  216    216   
        };
  217    217   
        let body = ::aws_smithy_types::body::SdkBody::from(
  218    218   
            crate::protocol_serde::shape_put_bucket_versioning_input::ser_versioning_configuration_http_payload(&input.versioning_configuration)?,
  219    219   
        );
  220    220   
        if let Some(content_length) = body.content_length() {
  221    221   
            let content_length = content_length.to_string();
  222         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         222  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  223    223   
        }
  224    224   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  225    225   
    }
  226    226   
}
  227    227   
#[derive(Debug)]
  228    228   
struct PutBucketVersioningEndpointParamsInterceptor;
  229    229   
  230    230   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutBucketVersioningEndpointParamsInterceptor {
  231    231   
    fn name(&self) -> &'static str {
  232    232   
        "PutBucketVersioningEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_job_tagging.rs

@@ -176,176 +250,250 @@
  196    196   
                        "job_id",
  197    197   
                        "cannot be empty or unset",
  198    198   
                    ));
  199    199   
                }
  200    200   
                ::std::write!(output, "/v20180820/jobs/{JobId}/tagging", JobId = job_id).expect("formatting should succeed");
  201    201   
                ::std::result::Result::Ok(())
  202    202   
            }
  203    203   
            #[allow(clippy::unnecessary_wraps)]
  204    204   
            fn update_http_builder(
  205    205   
                input: &crate::operation::put_job_tagging::PutJobTaggingInput,
  206         -
                builder: ::http::request::Builder,
  207         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         206  +
                builder: ::http_1x::request::Builder,
         207  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  208    208   
                let mut uri = ::std::string::String::new();
  209    209   
                uri_base(input, &mut uri)?;
  210    210   
                let builder = crate::protocol_serde::shape_put_job_tagging::ser_put_job_tagging_headers(input, builder)?;
  211    211   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  212    212   
            }
  213         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  214         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         213  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         214  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  215    215   
            builder
  216    216   
        };
  217    217   
        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_put_job_tagging::ser_put_job_tagging_op_input(&input)?);
  218    218   
        if let Some(content_length) = body.content_length() {
  219    219   
            let content_length = content_length.to_string();
  220         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         220  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  221    221   
        }
  222    222   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  223    223   
    }
  224    224   
}
  225    225   
#[derive(Debug)]
  226    226   
struct PutJobTaggingEndpointParamsInterceptor;
  227    227   
  228    228   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutJobTaggingEndpointParamsInterceptor {
  229    229   
    fn name(&self) -> &'static str {
  230    230   
        "PutJobTaggingEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_multi_region_access_point_policy.rs

@@ -185,185 +263,263 @@
  205    205   
                _input: &crate::operation::put_multi_region_access_point_policy::PutMultiRegionAccessPointPolicyInput,
  206    206   
                output: &mut ::std::string::String,
  207    207   
            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
  208    208   
                use ::std::fmt::Write as _;
  209    209   
                ::std::write!(output, "/v20180820/async-requests/mrap/put-policy").expect("formatting should succeed");
  210    210   
                ::std::result::Result::Ok(())
  211    211   
            }
  212    212   
            #[allow(clippy::unnecessary_wraps)]
  213    213   
            fn update_http_builder(
  214    214   
                input: &crate::operation::put_multi_region_access_point_policy::PutMultiRegionAccessPointPolicyInput,
  215         -
                builder: ::http::request::Builder,
  216         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         215  +
                builder: ::http_1x::request::Builder,
         216  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  217    217   
                let mut uri = ::std::string::String::new();
  218    218   
                uri_base(input, &mut uri)?;
  219    219   
                let builder = crate::protocol_serde::shape_put_multi_region_access_point_policy::ser_put_multi_region_access_point_policy_headers(
  220    220   
                    input, builder,
  221    221   
                )?;
  222    222   
                ::std::result::Result::Ok(builder.method("POST").uri(uri))
  223    223   
            }
  224         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  225         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         224  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         225  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  226    226   
            builder
  227    227   
        };
  228    228   
        let body = ::aws_smithy_types::body::SdkBody::from(
  229    229   
            crate::protocol_serde::shape_put_multi_region_access_point_policy::ser_put_multi_region_access_point_policy_op_input(&input)?,
  230    230   
        );
  231    231   
        if let Some(content_length) = body.content_length() {
  232    232   
            let content_length = content_length.to_string();
  233         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         233  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  234    234   
        }
  235    235   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  236    236   
    }
  237    237   
}
  238    238   
#[derive(Debug)]
  239    239   
struct PutMultiRegionAccessPointPolicyEndpointParamsInterceptor;
  240    240   
  241    241   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutMultiRegionAccessPointPolicyEndpointParamsInterceptor {
  242    242   
    fn name(&self) -> &'static str {
  243    243   
        "PutMultiRegionAccessPointPolicyEndpointParamsInterceptor"

tmp-codegen-diff/aws-sdk/sdk/s3control/src/operation/put_public_access_block.rs

@@ -165,165 +243,243 @@
  185    185   
                _input: &crate::operation::put_public_access_block::PutPublicAccessBlockInput,
  186    186   
                output: &mut ::std::string::String,
  187    187   
            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
  188    188   
                use ::std::fmt::Write as _;
  189    189   
                ::std::write!(output, "/v20180820/configuration/publicAccessBlock").expect("formatting should succeed");
  190    190   
                ::std::result::Result::Ok(())
  191    191   
            }
  192    192   
            #[allow(clippy::unnecessary_wraps)]
  193    193   
            fn update_http_builder(
  194    194   
                input: &crate::operation::put_public_access_block::PutPublicAccessBlockInput,
  195         -
                builder: ::http::request::Builder,
  196         -
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
         195  +
                builder: ::http_1x::request::Builder,
         196  +
            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  197    197   
                let mut uri = ::std::string::String::new();
  198    198   
                uri_base(input, &mut uri)?;
  199    199   
                let builder = crate::protocol_serde::shape_put_public_access_block::ser_put_public_access_block_headers(input, builder)?;
  200    200   
                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
  201    201   
            }
  202         -
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  203         -
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/xml");
         202  +
            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
         203  +
            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
  204    204   
            builder
  205    205   
        };
  206    206   
        let body = ::aws_smithy_types::body::SdkBody::from(
  207    207   
            crate::protocol_serde::shape_put_public_access_block_input::ser_public_access_block_configuration_http_payload(
  208    208   
                &input.public_access_block_configuration,
  209    209   
            )?,
  210    210   
        );
  211    211   
        if let Some(content_length) = body.content_length() {
  212    212   
            let content_length = content_length.to_string();
  213         -
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
         213  +
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
  214    214   
        }
  215    215   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  216    216   
    }
  217    217   
}
  218    218   
#[derive(Debug)]
  219    219   
struct PutPublicAccessBlockEndpointParamsInterceptor;
  220    220   
  221    221   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutPublicAccessBlockEndpointParamsInterceptor {
  222    222   
    fn name(&self) -> &'static str {
  223    223   
        "PutPublicAccessBlockEndpointParamsInterceptor"