AWS SDK

AWS SDK

rev. eb19c4c7998eaae1210cb747286b497c3425236c

Files changed:

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_occ_conflict_exception.rs

@@ -0,1 +0,35 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_occ_conflict_exception_json_err(
           3  +
    value: &[u8],
           4  +
    mut builder: crate::types::error::builders::OccConflictExceptionBuilder,
           5  +
) -> ::std::result::Result<crate::types::error::builders::OccConflictExceptionBuilder, ::aws_smithy_json::deserialize::error::DeserializeError> {
           6  +
    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
           7  +
    let tokens = &mut tokens_owned;
           8  +
    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
           9  +
    loop {
          10  +
        match tokens.next().transpose()? {
          11  +
            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          12  +
            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          13  +
                "Message" => {
          14  +
                    builder = builder.set_message(
          15  +
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
          16  +
                            .map(|s| s.to_unescaped().map(|u| u.into_owned()))
          17  +
                            .transpose()?,
          18  +
                    );
          19  +
                }
          20  +
                _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          21  +
            },
          22  +
            other => {
          23  +
                return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          24  +
                    "expected object key or end object, found: {other:?}"
          25  +
                )))
          26  +
            }
          27  +
        }
          28  +
    }
          29  +
    if tokens.next().is_some() {
          30  +
        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          31  +
            "found more JSON tokens after completing parsing",
          32  +
        ));
          33  +
    }
          34  +
    Ok(builder)
          35  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_page.rs

@@ -0,1 +0,42 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_page<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<crate::types::Page>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut builder = crate::types::builders::PageBuilder::default();
          13  +
            loop {
          14  +
                match tokens.next().transpose()? {
          15  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          16  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          17  +
                        "Values" => {
          18  +
                            builder = builder.set_values(crate::protocol_serde::shape_value_holders::de_value_holders(tokens)?);
          19  +
                        }
          20  +
                        "NextPageToken" => {
          21  +
                            builder = builder.set_next_page_token(
          22  +
                                ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
          23  +
                                    .map(|s| s.to_unescaped().map(|u| u.into_owned()))
          24  +
                                    .transpose()?,
          25  +
                            );
          26  +
                        }
          27  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          28  +
                    },
          29  +
                    other => {
          30  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          31  +
                            "expected object key or end object, found: {other:?}"
          32  +
                        )))
          33  +
                    }
          34  +
                }
          35  +
            }
          36  +
            Ok(Some(builder.build()))
          37  +
        }
          38  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          39  +
            "expected start object or null",
          40  +
        )),
          41  +
    }
          42  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_rate_exceeded_exception.rs

@@ -0,1 +0,35 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_rate_exceeded_exception_json_err(
           3  +
    value: &[u8],
           4  +
    mut builder: crate::types::error::builders::RateExceededExceptionBuilder,
           5  +
) -> ::std::result::Result<crate::types::error::builders::RateExceededExceptionBuilder, ::aws_smithy_json::deserialize::error::DeserializeError> {
           6  +
    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
           7  +
    let tokens = &mut tokens_owned;
           8  +
    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
           9  +
    loop {
          10  +
        match tokens.next().transpose()? {
          11  +
            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          12  +
            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          13  +
                "Message" => {
          14  +
                    builder = builder.set_message(
          15  +
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
          16  +
                            .map(|s| s.to_unescaped().map(|u| u.into_owned()))
          17  +
                            .transpose()?,
          18  +
                    );
          19  +
                }
          20  +
                _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          21  +
            },
          22  +
            other => {
          23  +
                return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          24  +
                    "expected object key or end object, found: {other:?}"
          25  +
                )))
          26  +
            }
          27  +
        }
          28  +
    }
          29  +
    if tokens.next().is_some() {
          30  +
        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          31  +
            "found more JSON tokens after completing parsing",
          32  +
        ));
          33  +
    }
          34  +
    Ok(builder)
          35  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_send_command.rs

@@ -0,1 +0,196 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
#[allow(clippy::unnecessary_wraps)]
           3  +
pub fn de_send_command_http_error(
           4  +
    _response_status: u16,
           5  +
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
           6  +
    _response_body: &[u8],
           7  +
) -> std::result::Result<crate::operation::send_command::SendCommandOutput, crate::operation::send_command::SendCommandError> {
           8  +
    #[allow(unused_mut)]
           9  +
    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
          10  +
        .map_err(crate::operation::send_command::SendCommandError::unhandled)?;
          11  +
    generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
          12  +
    let generic = generic_builder.build();
          13  +
    let error_code = match generic.code() {
          14  +
        Some(code) => code,
          15  +
        None => return Err(crate::operation::send_command::SendCommandError::unhandled(generic)),
          16  +
    };
          17  +
          18  +
    let _error_message = generic.message().map(|msg| msg.to_owned());
          19  +
    Err(match error_code {
          20  +
        "BadRequestException" => crate::operation::send_command::SendCommandError::BadRequestException({
          21  +
            #[allow(unused_mut)]
          22  +
            let mut tmp = {
          23  +
                #[allow(unused_mut)]
          24  +
                let mut output = crate::types::error::builders::BadRequestExceptionBuilder::default();
          25  +
                output = crate::protocol_serde::shape_bad_request_exception::de_bad_request_exception_json_err(_response_body, output)
          26  +
                    .map_err(crate::operation::send_command::SendCommandError::unhandled)?;
          27  +
                let output = output.meta(generic);
          28  +
                output.build()
          29  +
            };
          30  +
            if tmp.message.is_none() {
          31  +
                tmp.message = _error_message;
          32  +
            }
          33  +
            tmp
          34  +
        }),
          35  +
        "CapacityExceededException" => crate::operation::send_command::SendCommandError::CapacityExceededException({
          36  +
            #[allow(unused_mut)]
          37  +
            let mut tmp = {
          38  +
                #[allow(unused_mut)]
          39  +
                let mut output = crate::types::error::builders::CapacityExceededExceptionBuilder::default();
          40  +
                output = crate::protocol_serde::shape_capacity_exceeded_exception::de_capacity_exceeded_exception_json_err(_response_body, output)
          41  +
                    .map_err(crate::operation::send_command::SendCommandError::unhandled)?;
          42  +
                let output = output.meta(generic);
          43  +
                output.build()
          44  +
            };
          45  +
            if tmp.message.is_none() {
          46  +
                tmp.message = _error_message;
          47  +
            }
          48  +
            tmp
          49  +
        }),
          50  +
        "InvalidSessionException" => crate::operation::send_command::SendCommandError::InvalidSessionException({
          51  +
            #[allow(unused_mut)]
          52  +
            let mut tmp = {
          53  +
                #[allow(unused_mut)]
          54  +
                let mut output = crate::types::error::builders::InvalidSessionExceptionBuilder::default();
          55  +
                output = crate::protocol_serde::shape_invalid_session_exception::de_invalid_session_exception_json_err(_response_body, output)
          56  +
                    .map_err(crate::operation::send_command::SendCommandError::unhandled)?;
          57  +
                let output = output.meta(generic);
          58  +
                output.build()
          59  +
            };
          60  +
            if tmp.message.is_none() {
          61  +
                tmp.message = _error_message;
          62  +
            }
          63  +
            tmp
          64  +
        }),
          65  +
        "LimitExceededException" => crate::operation::send_command::SendCommandError::LimitExceededException({
          66  +
            #[allow(unused_mut)]
          67  +
            let mut tmp = {
          68  +
                #[allow(unused_mut)]
          69  +
                let mut output = crate::types::error::builders::LimitExceededExceptionBuilder::default();
          70  +
                output = crate::protocol_serde::shape_limit_exceeded_exception::de_limit_exceeded_exception_json_err(_response_body, output)
          71  +
                    .map_err(crate::operation::send_command::SendCommandError::unhandled)?;
          72  +
                let output = output.meta(generic);
          73  +
                output.build()
          74  +
            };
          75  +
            if tmp.message.is_none() {
          76  +
                tmp.message = _error_message;
          77  +
            }
          78  +
            tmp
          79  +
        }),
          80  +
        "OccConflictException" => crate::operation::send_command::SendCommandError::OccConflictException({
          81  +
            #[allow(unused_mut)]
          82  +
            let mut tmp = {
          83  +
                #[allow(unused_mut)]
          84  +
                let mut output = crate::types::error::builders::OccConflictExceptionBuilder::default();
          85  +
                output = crate::protocol_serde::shape_occ_conflict_exception::de_occ_conflict_exception_json_err(_response_body, output)
          86  +
                    .map_err(crate::operation::send_command::SendCommandError::unhandled)?;
          87  +
                let output = output.meta(generic);
          88  +
                output.build()
          89  +
            };
          90  +
            if tmp.message.is_none() {
          91  +
                tmp.message = _error_message;
          92  +
            }
          93  +
            tmp
          94  +
        }),
          95  +
        "RateExceededException" => crate::operation::send_command::SendCommandError::RateExceededException({
          96  +
            #[allow(unused_mut)]
          97  +
            let mut tmp = {
          98  +
                #[allow(unused_mut)]
          99  +
                let mut output = crate::types::error::builders::RateExceededExceptionBuilder::default();
         100  +
                output = crate::protocol_serde::shape_rate_exceeded_exception::de_rate_exceeded_exception_json_err(_response_body, output)
         101  +
                    .map_err(crate::operation::send_command::SendCommandError::unhandled)?;
         102  +
                let output = output.meta(generic);
         103  +
                output.build()
         104  +
            };
         105  +
            if tmp.message.is_none() {
         106  +
                tmp.message = _error_message;
         107  +
            }
         108  +
            tmp
         109  +
        }),
         110  +
        _ => crate::operation::send_command::SendCommandError::generic(generic),
         111  +
    })
         112  +
}
         113  +
         114  +
#[allow(clippy::unnecessary_wraps)]
         115  +
pub fn de_send_command_http_response(
         116  +
    _response_status: u16,
         117  +
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
         118  +
    _response_body: &[u8],
         119  +
) -> std::result::Result<crate::operation::send_command::SendCommandOutput, crate::operation::send_command::SendCommandError> {
         120  +
    Ok({
         121  +
        #[allow(unused_mut)]
         122  +
        let mut output = crate::operation::send_command::builders::SendCommandOutputBuilder::default();
         123  +
        output = crate::protocol_serde::shape_send_command::de_send_command(_response_body, output)
         124  +
            .map_err(crate::operation::send_command::SendCommandError::unhandled)?;
         125  +
        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
         126  +
        output.build()
         127  +
    })
         128  +
}
         129  +
         130  +
pub fn ser_send_command_input(
         131  +
    input: &crate::operation::send_command::SendCommandInput,
         132  +
) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
         133  +
    let mut out = String::new();
         134  +
    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
         135  +
    crate::protocol_serde::shape_send_command_input::ser_send_command_input_input(&mut object, input)?;
         136  +
    object.finish();
         137  +
    Ok(::aws_smithy_types::body::SdkBody::from(out))
         138  +
}
         139  +
         140  +
pub(crate) fn de_send_command(
         141  +
    value: &[u8],
         142  +
    mut builder: crate::operation::send_command::builders::SendCommandOutputBuilder,
         143  +
) -> ::std::result::Result<crate::operation::send_command::builders::SendCommandOutputBuilder, ::aws_smithy_json::deserialize::error::DeserializeError>
         144  +
{
         145  +
    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
         146  +
    let tokens = &mut tokens_owned;
         147  +
    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
         148  +
    loop {
         149  +
        match tokens.next().transpose()? {
         150  +
            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
         151  +
            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
         152  +
                "StartSession" => {
         153  +
                    builder = builder.set_start_session(crate::protocol_serde::shape_start_session_result::de_start_session_result(tokens)?);
         154  +
                }
         155  +
                "StartTransaction" => {
         156  +
                    builder = builder.set_start_transaction(crate::protocol_serde::shape_start_transaction_result::de_start_transaction_result(
         157  +
                        tokens,
         158  +
                    )?);
         159  +
                }
         160  +
                "EndSession" => {
         161  +
                    builder = builder.set_end_session(crate::protocol_serde::shape_end_session_result::de_end_session_result(tokens)?);
         162  +
                }
         163  +
                "CommitTransaction" => {
         164  +
                    builder = builder.set_commit_transaction(crate::protocol_serde::shape_commit_transaction_result::de_commit_transaction_result(
         165  +
                        tokens,
         166  +
                    )?);
         167  +
                }
         168  +
                "AbortTransaction" => {
         169  +
                    builder = builder.set_abort_transaction(crate::protocol_serde::shape_abort_transaction_result::de_abort_transaction_result(
         170  +
                        tokens,
         171  +
                    )?);
         172  +
                }
         173  +
                "ExecuteStatement" => {
         174  +
                    builder = builder.set_execute_statement(crate::protocol_serde::shape_execute_statement_result::de_execute_statement_result(
         175  +
                        tokens,
         176  +
                    )?);
         177  +
                }
         178  +
                "FetchPage" => {
         179  +
                    builder = builder.set_fetch_page(crate::protocol_serde::shape_fetch_page_result::de_fetch_page_result(tokens)?);
         180  +
                }
         181  +
                _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
         182  +
            },
         183  +
            other => {
         184  +
                return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
         185  +
                    "expected object key or end object, found: {other:?}"
         186  +
                )))
         187  +
            }
         188  +
        }
         189  +
    }
         190  +
    if tokens.next().is_some() {
         191  +
        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
         192  +
            "found more JSON tokens after completing parsing",
         193  +
        ));
         194  +
    }
         195  +
    Ok(builder)
         196  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_send_command_input.rs

@@ -0,1 +0,52 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub fn ser_send_command_input_input(
           3  +
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
           4  +
    input: &crate::operation::send_command::SendCommandInput,
           5  +
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
           6  +
    if let Some(var_1) = &input.session_token {
           7  +
        object.key("SessionToken").string(var_1.as_str());
           8  +
    }
           9  +
    if let Some(var_2) = &input.start_session {
          10  +
        #[allow(unused_mut)]
          11  +
        let mut object_3 = object.key("StartSession").start_object();
          12  +
        crate::protocol_serde::shape_start_session_request::ser_start_session_request(&mut object_3, var_2)?;
          13  +
        object_3.finish();
          14  +
    }
          15  +
    if let Some(var_4) = &input.start_transaction {
          16  +
        #[allow(unused_mut)]
          17  +
        let mut object_5 = object.key("StartTransaction").start_object();
          18  +
        crate::protocol_serde::shape_start_transaction_request::ser_start_transaction_request(&mut object_5, var_4)?;
          19  +
        object_5.finish();
          20  +
    }
          21  +
    if let Some(var_6) = &input.end_session {
          22  +
        #[allow(unused_mut)]
          23  +
        let mut object_7 = object.key("EndSession").start_object();
          24  +
        crate::protocol_serde::shape_end_session_request::ser_end_session_request(&mut object_7, var_6)?;
          25  +
        object_7.finish();
          26  +
    }
          27  +
    if let Some(var_8) = &input.commit_transaction {
          28  +
        #[allow(unused_mut)]
          29  +
        let mut object_9 = object.key("CommitTransaction").start_object();
          30  +
        crate::protocol_serde::shape_commit_transaction_request::ser_commit_transaction_request(&mut object_9, var_8)?;
          31  +
        object_9.finish();
          32  +
    }
          33  +
    if let Some(var_10) = &input.abort_transaction {
          34  +
        #[allow(unused_mut)]
          35  +
        let mut object_11 = object.key("AbortTransaction").start_object();
          36  +
        crate::protocol_serde::shape_abort_transaction_request::ser_abort_transaction_request(&mut object_11, var_10)?;
          37  +
        object_11.finish();
          38  +
    }
          39  +
    if let Some(var_12) = &input.execute_statement {
          40  +
        #[allow(unused_mut)]
          41  +
        let mut object_13 = object.key("ExecuteStatement").start_object();
          42  +
        crate::protocol_serde::shape_execute_statement_request::ser_execute_statement_request(&mut object_13, var_12)?;
          43  +
        object_13.finish();
          44  +
    }
          45  +
    if let Some(var_14) = &input.fetch_page {
          46  +
        #[allow(unused_mut)]
          47  +
        let mut object_15 = object.key("FetchPage").start_object();
          48  +
        crate::protocol_serde::shape_fetch_page_request::ser_fetch_page_request(&mut object_15, var_14)?;
          49  +
        object_15.finish();
          50  +
    }
          51  +
    Ok(())
          52  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_start_session_request.rs

@@ -0,1 +0,10 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub fn ser_start_session_request(
           3  +
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
           4  +
    input: &crate::types::StartSessionRequest,
           5  +
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
           6  +
    {
           7  +
        object.key("LedgerName").string(input.ledger_name.as_str());
           8  +
    }
           9  +
    Ok(())
          10  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_start_session_result.rs

@@ -0,1 +0,42 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_start_session_result<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<crate::types::StartSessionResult>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut builder = crate::types::builders::StartSessionResultBuilder::default();
          13  +
            loop {
          14  +
                match tokens.next().transpose()? {
          15  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          16  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          17  +
                        "SessionToken" => {
          18  +
                            builder = builder.set_session_token(
          19  +
                                ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
          20  +
                                    .map(|s| s.to_unescaped().map(|u| u.into_owned()))
          21  +
                                    .transpose()?,
          22  +
                            );
          23  +
                        }
          24  +
                        "TimingInformation" => {
          25  +
                            builder = builder.set_timing_information(crate::protocol_serde::shape_timing_information::de_timing_information(tokens)?);
          26  +
                        }
          27  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          28  +
                    },
          29  +
                    other => {
          30  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          31  +
                            "expected object key or end object, found: {other:?}"
          32  +
                        )))
          33  +
                    }
          34  +
                }
          35  +
            }
          36  +
            Ok(Some(builder.build()))
          37  +
        }
          38  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          39  +
            "expected start object or null",
          40  +
        )),
          41  +
    }
          42  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_start_transaction_request.rs

@@ -0,1 +0,7 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub fn ser_start_transaction_request(
           3  +
    #[allow(unused_variables)] object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
           4  +
    #[allow(unused_variables)] input: &crate::types::StartTransactionRequest,
           5  +
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
           6  +
    Ok(())
           7  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_start_transaction_result.rs

@@ -0,1 +0,42 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_start_transaction_result<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<crate::types::StartTransactionResult>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut builder = crate::types::builders::StartTransactionResultBuilder::default();
          13  +
            loop {
          14  +
                match tokens.next().transpose()? {
          15  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          16  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          17  +
                        "TransactionId" => {
          18  +
                            builder = builder.set_transaction_id(
          19  +
                                ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
          20  +
                                    .map(|s| s.to_unescaped().map(|u| u.into_owned()))
          21  +
                                    .transpose()?,
          22  +
                            );
          23  +
                        }
          24  +
                        "TimingInformation" => {
          25  +
                            builder = builder.set_timing_information(crate::protocol_serde::shape_timing_information::de_timing_information(tokens)?);
          26  +
                        }
          27  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          28  +
                    },
          29  +
                    other => {
          30  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          31  +
                            "expected object key or end object, found: {other:?}"
          32  +
                        )))
          33  +
                    }
          34  +
                }
          35  +
            }
          36  +
            Ok(Some(builder.build()))
          37  +
        }
          38  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          39  +
            "expected start object or null",
          40  +
        )),
          41  +
    }
          42  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_timing_information.rs

@@ -0,1 +0,39 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_timing_information<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<crate::types::TimingInformation>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut builder = crate::types::builders::TimingInformationBuilder::default();
          13  +
            loop {
          14  +
                match tokens.next().transpose()? {
          15  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          16  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          17  +
                        "ProcessingTimeMilliseconds" => {
          18  +
                            builder = builder.set_processing_time_milliseconds(
          19  +
                                ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
          20  +
                                    .map(i64::try_from)
          21  +
                                    .transpose()?,
          22  +
                            );
          23  +
                        }
          24  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          25  +
                    },
          26  +
                    other => {
          27  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          28  +
                            "expected object key or end object, found: {other:?}"
          29  +
                        )))
          30  +
                    }
          31  +
                }
          32  +
            }
          33  +
            Ok(Some(builder.build()))
          34  +
        }
          35  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          36  +
            "expected start object or null",
          37  +
        )),
          38  +
    }
          39  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_value_holder.rs

@@ -0,1 +0,55 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub fn ser_value_holder(
           3  +
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
           4  +
    input: &crate::types::ValueHolder,
           5  +
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
           6  +
    if let Some(var_1) = &input.ion_binary {
           7  +
        object.key("IonBinary").string_unchecked(&::aws_smithy_types::base64::encode(var_1));
           8  +
    }
           9  +
    if let Some(var_2) = &input.ion_text {
          10  +
        object.key("IonText").string(var_2.as_str());
          11  +
    }
          12  +
    Ok(())
          13  +
}
          14  +
          15  +
pub(crate) fn de_value_holder<'a, I>(
          16  +
    tokens: &mut ::std::iter::Peekable<I>,
          17  +
) -> ::std::result::Result<Option<crate::types::ValueHolder>, ::aws_smithy_json::deserialize::error::DeserializeError>
          18  +
where
          19  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
          20  +
{
          21  +
    match tokens.next().transpose()? {
          22  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          23  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          24  +
            #[allow(unused_mut)]
          25  +
            let mut builder = crate::types::builders::ValueHolderBuilder::default();
          26  +
            loop {
          27  +
                match tokens.next().transpose()? {
          28  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          29  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          30  +
                        "IonBinary" => {
          31  +
                            builder = builder.set_ion_binary(::aws_smithy_json::deserialize::token::expect_blob_or_null(tokens.next())?);
          32  +
                        }
          33  +
                        "IonText" => {
          34  +
                            builder = builder.set_ion_text(
          35  +
                                ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
          36  +
                                    .map(|s| s.to_unescaped().map(|u| u.into_owned()))
          37  +
                                    .transpose()?,
          38  +
                            );
          39  +
                        }
          40  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          41  +
                    },
          42  +
                    other => {
          43  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          44  +
                            "expected object key or end object, found: {other:?}"
          45  +
                        )))
          46  +
                    }
          47  +
                }
          48  +
            }
          49  +
            Ok(Some(builder.build()))
          50  +
        }
          51  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          52  +
            "expected start object or null",
          53  +
        )),
          54  +
    }
          55  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/protocol_serde/shape_value_holders.rs

@@ -0,1 +0,32 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_value_holders<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<::std::vec::Vec<crate::types::ValueHolder>>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartArray { .. }) => {
          11  +
            let mut items = Vec::new();
          12  +
            loop {
          13  +
                match tokens.peek() {
          14  +
                    Some(Ok(::aws_smithy_json::deserialize::Token::EndArray { .. })) => {
          15  +
                        tokens.next().transpose().unwrap();
          16  +
                        break;
          17  +
                    }
          18  +
                    _ => {
          19  +
                        let value = crate::protocol_serde::shape_value_holder::de_value_holder(tokens)?;
          20  +
                        if let Some(value) = value {
          21  +
                            items.push(value);
          22  +
                        }
          23  +
                    }
          24  +
                }
          25  +
            }
          26  +
            Ok(Some(items))
          27  +
        }
          28  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          29  +
            "expected start array or null",
          30  +
        )),
          31  +
    }
          32  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/sdk_feature_tracker.rs

@@ -0,1 +0,198 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/*
           3  +
 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
           4  +
 * SPDX-License-Identifier: Apache-2.0
           5  +
 */
           6  +
           7  +
#[allow(dead_code)]
           8  +
pub(crate) mod rpc_v2_cbor {
           9  +
    use aws_smithy_runtime::client::sdk_feature::SmithySdkFeature;
          10  +
    use aws_smithy_runtime_api::box_error::BoxError;
          11  +
    use aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextMut;
          12  +
    use aws_smithy_runtime_api::client::interceptors::Intercept;
          13  +
    use aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
          14  +
    use aws_smithy_types::config_bag::ConfigBag;
          15  +
          16  +
    #[derive(Debug)]
          17  +
    pub(crate) struct RpcV2CborFeatureTrackerInterceptor;
          18  +
          19  +
    impl RpcV2CborFeatureTrackerInterceptor {
          20  +
        pub(crate) fn new() -> Self {
          21  +
            Self
          22  +
        }
          23  +
    }
          24  +
          25  +
    impl Intercept for RpcV2CborFeatureTrackerInterceptor {
          26  +
        fn name(&self) -> &'static str {
          27  +
            "RpcV2CborFeatureTrackerInterceptor"
          28  +
        }
          29  +
          30  +
        fn modify_before_serialization(
          31  +
            &self,
          32  +
            _context: &mut BeforeSerializationInterceptorContextMut<'_>,
          33  +
            _runtime_components: &RuntimeComponents,
          34  +
            cfg: &mut ConfigBag,
          35  +
        ) -> Result<(), BoxError> {
          36  +
            cfg.interceptor_state()
          37  +
                .store_append::<SmithySdkFeature>(SmithySdkFeature::ProtocolRpcV2Cbor);
          38  +
            Ok(())
          39  +
        }
          40  +
    }
          41  +
}
          42  +
          43  +
#[allow(dead_code)]
          44  +
pub(crate) mod paginator {
          45  +
    use aws_smithy_runtime::client::sdk_feature::SmithySdkFeature;
          46  +
    use aws_smithy_runtime_api::box_error::BoxError;
          47  +
    use aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextMut;
          48  +
    use aws_smithy_runtime_api::client::interceptors::{Intercept, SharedInterceptor};
          49  +
    use aws_smithy_runtime_api::client::runtime_components::{RuntimeComponents, RuntimeComponentsBuilder};
          50  +
    use aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
          51  +
    use aws_smithy_types::config_bag::ConfigBag;
          52  +
    use std::borrow::Cow;
          53  +
          54  +
    #[derive(Debug)]
          55  +
    struct PaginatorFeatureTrackerInterceptor;
          56  +
          57  +
    impl PaginatorFeatureTrackerInterceptor {
          58  +
        pub(crate) fn new() -> Self {
          59  +
            Self
          60  +
        }
          61  +
    }
          62  +
          63  +
    impl Intercept for PaginatorFeatureTrackerInterceptor {
          64  +
        fn name(&self) -> &'static str {
          65  +
            "PaginatorFeatureTrackerInterceptor"
          66  +
        }
          67  +
          68  +
        fn modify_before_serialization(
          69  +
            &self,
          70  +
            _context: &mut BeforeSerializationInterceptorContextMut<'_>,
          71  +
            _runtime_components: &RuntimeComponents,
          72  +
            cfg: &mut ConfigBag,
          73  +
        ) -> Result<(), BoxError> {
          74  +
            cfg.interceptor_state().store_append::<SmithySdkFeature>(SmithySdkFeature::Paginator);
          75  +
            Ok(())
          76  +
        }
          77  +
    }
          78  +
          79  +
    #[derive(Debug)]
          80  +
    pub(crate) struct PaginatorFeatureTrackerRuntimePlugin {
          81  +
        runtime_components: RuntimeComponentsBuilder,
          82  +
    }
          83  +
          84  +
    impl PaginatorFeatureTrackerRuntimePlugin {
          85  +
        pub(crate) fn new() -> Self {
          86  +
            Self {
          87  +
                runtime_components: RuntimeComponentsBuilder::new("PaginatorFeatureTrackerRuntimePlugin")
          88  +
                    .with_interceptor(SharedInterceptor::new(PaginatorFeatureTrackerInterceptor::new())),
          89  +
            }
          90  +
        }
          91  +
    }
          92  +
          93  +
    impl RuntimePlugin for PaginatorFeatureTrackerRuntimePlugin {
          94  +
        fn runtime_components(&self, _: &RuntimeComponentsBuilder) -> Cow<'_, RuntimeComponentsBuilder> {
          95  +
            Cow::Borrowed(&self.runtime_components)
          96  +
        }
          97  +
    }
          98  +
}
          99  +
         100  +
#[allow(dead_code)]
         101  +
pub(crate) mod waiter {
         102  +
    use aws_smithy_runtime::client::sdk_feature::SmithySdkFeature;
         103  +
    use aws_smithy_runtime_api::box_error::BoxError;
         104  +
    use aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextMut;
         105  +
    use aws_smithy_runtime_api::client::interceptors::{Intercept, SharedInterceptor};
         106  +
    use aws_smithy_runtime_api::client::runtime_components::{RuntimeComponents, RuntimeComponentsBuilder};
         107  +
    use aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         108  +
    use aws_smithy_types::config_bag::ConfigBag;
         109  +
    use std::borrow::Cow;
         110  +
         111  +
    #[derive(Debug)]
         112  +
    struct WaiterFeatureTrackerInterceptor;
         113  +
         114  +
    impl WaiterFeatureTrackerInterceptor {
         115  +
        pub(crate) fn new() -> Self {
         116  +
            Self
         117  +
        }
         118  +
    }
         119  +
         120  +
    impl Intercept for WaiterFeatureTrackerInterceptor {
         121  +
        fn name(&self) -> &'static str {
         122  +
            "WaiterFeatureTrackerInterceptor"
         123  +
        }
         124  +
         125  +
        fn modify_before_serialization(
         126  +
            &self,
         127  +
            _context: &mut BeforeSerializationInterceptorContextMut<'_>,
         128  +
            _runtime_components: &RuntimeComponents,
         129  +
            cfg: &mut ConfigBag,
         130  +
        ) -> Result<(), BoxError> {
         131  +
            cfg.interceptor_state().store_append::<SmithySdkFeature>(SmithySdkFeature::Waiter);
         132  +
            Ok(())
         133  +
        }
         134  +
    }
         135  +
         136  +
    #[derive(Debug)]
         137  +
    pub(crate) struct WaiterFeatureTrackerRuntimePlugin {
         138  +
        runtime_components: RuntimeComponentsBuilder,
         139  +
    }
         140  +
         141  +
    impl WaiterFeatureTrackerRuntimePlugin {
         142  +
        pub(crate) fn new() -> Self {
         143  +
            Self {
         144  +
                runtime_components: RuntimeComponentsBuilder::new("WaiterFeatureTrackerRuntimePlugin")
         145  +
                    .with_interceptor(SharedInterceptor::new(WaiterFeatureTrackerInterceptor::new())),
         146  +
            }
         147  +
        }
         148  +
    }
         149  +
         150  +
    impl RuntimePlugin for WaiterFeatureTrackerRuntimePlugin {
         151  +
        fn runtime_components(&self, _: &RuntimeComponentsBuilder) -> Cow<'_, RuntimeComponentsBuilder> {
         152  +
            Cow::Borrowed(&self.runtime_components)
         153  +
        }
         154  +
    }
         155  +
}
         156  +
         157  +
#[allow(dead_code)]
         158  +
pub(crate) mod retry_mode {
         159  +
    use aws_smithy_runtime::client::sdk_feature::SmithySdkFeature;
         160  +
    use aws_smithy_runtime_api::box_error::BoxError;
         161  +
    use aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef;
         162  +
    use aws_smithy_runtime_api::client::interceptors::Intercept;
         163  +
    use aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
         164  +
    use aws_smithy_types::config_bag::ConfigBag;
         165  +
    use aws_smithy_types::retry::{RetryConfig, RetryMode};
         166  +
         167  +
    #[derive(Debug)]
         168  +
    pub(crate) struct RetryModeFeatureTrackerInterceptor;
         169  +
         170  +
    impl RetryModeFeatureTrackerInterceptor {
         171  +
        pub(crate) fn new() -> Self {
         172  +
            Self
         173  +
        }
         174  +
    }
         175  +
         176  +
    impl Intercept for RetryModeFeatureTrackerInterceptor {
         177  +
        fn name(&self) -> &'static str {
         178  +
            "RetryModeFeatureTrackerInterceptor"
         179  +
        }
         180  +
         181  +
        fn read_before_serialization(
         182  +
            &self,
         183  +
            _context: &BeforeSerializationInterceptorContextRef<'_>,
         184  +
            _runtime_components: &RuntimeComponents,
         185  +
            cfg: &mut ConfigBag,
         186  +
        ) -> Result<(), BoxError> {
         187  +
            cfg.load::<RetryConfig>()
         188  +
                .map(|retry_config| match retry_config.mode() {
         189  +
                    RetryMode::Standard => SmithySdkFeature::RetryModeStandard,
         190  +
                    RetryMode::Adaptive => SmithySdkFeature::RetryModeAdaptive,
         191  +
                    _ => unreachable!("retry mode must be standard or adaptive"),
         192  +
                })
         193  +
                .map(|feature| cfg.interceptor_state().store_append::<SmithySdkFeature>(feature));
         194  +
         195  +
            Ok(())
         196  +
        }
         197  +
    }
         198  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/serialization_settings.rs

@@ -0,1 +0,84 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/*
           3  +
 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
           4  +
 * SPDX-License-Identifier: Apache-2.0
           5  +
 */
           6  +
           7  +
#![allow(dead_code)]
           8  +
           9  +
use aws_smithy_http::header::set_request_header_if_absent;
          10  +
use aws_smithy_types::config_bag::{Storable, StoreReplace};
          11  +
use http::header::{HeaderName, CONTENT_LENGTH, CONTENT_TYPE};
          12  +
          13  +
/// Configuration for how default protocol headers are serialized
          14  +
#[derive(Clone, Debug, Default)]
          15  +
pub(crate) struct HeaderSerializationSettings {
          16  +
    omit_default_content_length: bool,
          17  +
    omit_default_content_type: bool,
          18  +
}
          19  +
          20  +
impl HeaderSerializationSettings {
          21  +
    /// Creates new [`HeaderSerializationSettings`]
          22  +
    pub(crate) fn new() -> Self {
          23  +
        Default::default()
          24  +
    }
          25  +
          26  +
    /// Omit the default `Content-Length` header during serialization
          27  +
    pub(crate) fn omit_default_content_length(self) -> Self {
          28  +
        Self {
          29  +
            omit_default_content_length: true,
          30  +
            ..self
          31  +
        }
          32  +
    }
          33  +
          34  +
    /// Omit the default `Content-Type` header during serialization
          35  +
    pub(crate) fn omit_default_content_type(self) -> Self {
          36  +
        Self {
          37  +
            omit_default_content_type: true,
          38  +
            ..self
          39  +
        }
          40  +
    }
          41  +
          42  +
    /// Returns true if the given default header name should be serialized
          43  +
    fn include_header(&self, header: &HeaderName) -> bool {
          44  +
        (!self.omit_default_content_length || header != CONTENT_LENGTH) && (!self.omit_default_content_type || header != CONTENT_TYPE)
          45  +
    }
          46  +
          47  +
    /// Sets a default header on the given request builder if it should be serialized
          48  +
    pub(crate) fn set_default_header(&self, mut request: http::request::Builder, header_name: HeaderName, value: &str) -> http::request::Builder {
          49  +
        if self.include_header(&header_name) {
          50  +
            request = set_request_header_if_absent(request, header_name, value);
          51  +
        }
          52  +
        request
          53  +
    }
          54  +
}
          55  +
          56  +
impl Storable for HeaderSerializationSettings {
          57  +
    type Storer = StoreReplace<Self>;
          58  +
}
          59  +
          60  +
#[cfg(test)]
          61  +
mod tests {
          62  +
    use super::*;
          63  +
          64  +
    #[test]
          65  +
    fn test_include_header() {
          66  +
        let settings = HeaderSerializationSettings::default();
          67  +
        assert!(settings.include_header(&CONTENT_LENGTH));
          68  +
        assert!(settings.include_header(&CONTENT_TYPE));
          69  +
          70  +
        let settings = HeaderSerializationSettings::default().omit_default_content_length();
          71  +
        assert!(!settings.include_header(&CONTENT_LENGTH));
          72  +
        assert!(settings.include_header(&CONTENT_TYPE));
          73  +
          74  +
        let settings = HeaderSerializationSettings::default().omit_default_content_type();
          75  +
        assert!(settings.include_header(&CONTENT_LENGTH));
          76  +
        assert!(!settings.include_header(&CONTENT_TYPE));
          77  +
          78  +
        let settings = HeaderSerializationSettings::default()
          79  +
            .omit_default_content_type()
          80  +
            .omit_default_content_length();
          81  +
        assert!(!settings.include_header(&CONTENT_LENGTH));
          82  +
        assert!(!settings.include_header(&CONTENT_TYPE));
          83  +
    }
          84  +
}

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/types.rs

@@ -0,1 +0,78 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub use crate::types::_fetch_page_result::FetchPageResult;
           3  +
           4  +
pub use crate::types::_io_usage::IoUsage;
           5  +
           6  +
pub use crate::types::_timing_information::TimingInformation;
           7  +
           8  +
pub use crate::types::_page::Page;
           9  +
          10  +
pub use crate::types::_value_holder::ValueHolder;
          11  +
          12  +
pub use crate::types::_execute_statement_result::ExecuteStatementResult;
          13  +
          14  +
pub use crate::types::_abort_transaction_result::AbortTransactionResult;
          15  +
          16  +
pub use crate::types::_commit_transaction_result::CommitTransactionResult;
          17  +
          18  +
pub use crate::types::_end_session_result::EndSessionResult;
          19  +
          20  +
pub use crate::types::_start_transaction_result::StartTransactionResult;
          21  +
          22  +
pub use crate::types::_start_session_result::StartSessionResult;
          23  +
          24  +
pub use crate::types::_fetch_page_request::FetchPageRequest;
          25  +
          26  +
pub use crate::types::_execute_statement_request::ExecuteStatementRequest;
          27  +
          28  +
pub use crate::types::_abort_transaction_request::AbortTransactionRequest;
          29  +
          30  +
pub use crate::types::_commit_transaction_request::CommitTransactionRequest;
          31  +
          32  +
pub use crate::types::_end_session_request::EndSessionRequest;
          33  +
          34  +
pub use crate::types::_start_transaction_request::StartTransactionRequest;
          35  +
          36  +
pub use crate::types::_start_session_request::StartSessionRequest;
          37  +
          38  +
mod _abort_transaction_request;
          39  +
          40  +
mod _abort_transaction_result;
          41  +
          42  +
mod _commit_transaction_request;
          43  +
          44  +
mod _commit_transaction_result;
          45  +
          46  +
mod _end_session_request;
          47  +
          48  +
mod _end_session_result;
          49  +
          50  +
mod _execute_statement_request;
          51  +
          52  +
mod _execute_statement_result;
          53  +
          54  +
mod _fetch_page_request;
          55  +
          56  +
mod _fetch_page_result;
          57  +
          58  +
mod _io_usage;
          59  +
          60  +
mod _page;
          61  +
          62  +
mod _start_session_request;
          63  +
          64  +
mod _start_session_result;
          65  +
          66  +
mod _start_transaction_request;
          67  +
          68  +
mod _start_transaction_result;
          69  +
          70  +
mod _timing_information;
          71  +
          72  +
mod _value_holder;
          73  +
          74  +
/// Builders
          75  +
pub mod builders;
          76  +
          77  +
/// Error types that Amazon QLDB Session can respond with.
          78  +
pub mod error;

tmp-codegen-diff/aws-sdk/sdk/qldbsession/src/types/_abort_transaction_request.rs

@@ -0,1 +0,23 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
           3  +
/// <p>Contains the details of the transaction to abort.</p>
           4  +
#[non_exhaustive]
           5  +
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
           6  +
pub struct AbortTransactionRequest {}
           7  +
impl AbortTransactionRequest {
           8  +
    /// Creates a new builder-style object to manufacture [`AbortTransactionRequest`](crate::types::AbortTransactionRequest).
           9  +
    pub fn builder() -> crate::types::builders::AbortTransactionRequestBuilder {
          10  +
        crate::types::builders::AbortTransactionRequestBuilder::default()
          11  +
    }
          12  +
}
          13  +
          14  +
/// A builder for [`AbortTransactionRequest`](crate::types::AbortTransactionRequest).
          15  +
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
          16  +
#[non_exhaustive]
          17  +
pub struct AbortTransactionRequestBuilder {}
          18  +
impl AbortTransactionRequestBuilder {
          19  +
    /// Consumes the builder and constructs a [`AbortTransactionRequest`](crate::types::AbortTransactionRequest).
          20  +
    pub fn build(self) -> crate::types::AbortTransactionRequest {
          21  +
        crate::types::AbortTransactionRequest {}
          22  +
    }
          23  +
}