AWS SDK

AWS SDK

rev. 96f5a1b4ad139d2f1ad1e8e40f300e1cd1ff574c (ignoring whitespace)

Files changed:

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

@@ -1,0 +10,0 @@
    1         -
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
pub fn ser_get_integration_input_input(
    3         -
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
    4         -
    input: &crate::operation::get_integration::GetIntegrationInput,
    5         -
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
    6         -
    if let Some(var_1) = &input.integration_name {
    7         -
        object.key("integrationName").string(var_1.as_str());
    8         -
    }
    9         -
    Ok(())
   10         -
}

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

@@ -1,0 +205,0 @@
    1         -
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
#[allow(clippy::unnecessary_wraps)]
    3         -
pub fn de_get_log_anomaly_detector_http_error(
    4         -
    _response_status: u16,
    5         -
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
    6         -
    _response_body: &[u8],
    7         -
) -> std::result::Result<
    8         -
    crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorOutput,
    9         -
    crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError,
   10         -
> {
   11         -
    #[allow(unused_mut)]
   12         -
    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
   13         -
        .map_err(crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::unhandled)?;
   14         -
    generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
   15         -
    let generic = generic_builder.build();
   16         -
    let error_code = match generic.code() {
   17         -
        Some(code) => code,
   18         -
        None => return Err(crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::unhandled(generic)),
   19         -
    };
   20         -
   21         -
    let _error_message = generic.message().map(|msg| msg.to_owned());
   22         -
    Err(match error_code {
   23         -
        "InvalidParameterException" => crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::InvalidParameterException({
   24         -
            #[allow(unused_mut)]
   25         -
            let mut tmp = {
   26         -
                #[allow(unused_mut)]
   27         -
                let mut output = crate::types::error::builders::InvalidParameterExceptionBuilder::default();
   28         -
                output = crate::protocol_serde::shape_invalid_parameter_exception::de_invalid_parameter_exception_json_err(_response_body, output)
   29         -
                    .map_err(crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::unhandled)?;
   30         -
                let output = output.meta(generic);
   31         -
                output.build()
   32         -
            };
   33         -
            if tmp.message.is_none() {
   34         -
                tmp.message = _error_message;
   35         -
            }
   36         -
            tmp
   37         -
        }),
   38         -
        "OperationAbortedException" => crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::OperationAbortedException({
   39         -
            #[allow(unused_mut)]
   40         -
            let mut tmp = {
   41         -
                #[allow(unused_mut)]
   42         -
                let mut output = crate::types::error::builders::OperationAbortedExceptionBuilder::default();
   43         -
                output = crate::protocol_serde::shape_operation_aborted_exception::de_operation_aborted_exception_json_err(_response_body, output)
   44         -
                    .map_err(crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::unhandled)?;
   45         -
                let output = output.meta(generic);
   46         -
                output.build()
   47         -
            };
   48         -
            if tmp.message.is_none() {
   49         -
                tmp.message = _error_message;
   50         -
            }
   51         -
            tmp
   52         -
        }),
   53         -
        "ResourceNotFoundException" => crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::ResourceNotFoundException({
   54         -
            #[allow(unused_mut)]
   55         -
            let mut tmp = {
   56         -
                #[allow(unused_mut)]
   57         -
                let mut output = crate::types::error::builders::ResourceNotFoundExceptionBuilder::default();
   58         -
                output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
   59         -
                    .map_err(crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::unhandled)?;
   60         -
                let output = output.meta(generic);
   61         -
                output.build()
   62         -
            };
   63         -
            if tmp.message.is_none() {
   64         -
                tmp.message = _error_message;
   65         -
            }
   66         -
            tmp
   67         -
        }),
   68         -
        "ServiceUnavailableException" => crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::ServiceUnavailableException({
   69         -
            #[allow(unused_mut)]
   70         -
            let mut tmp = {
   71         -
                #[allow(unused_mut)]
   72         -
                let mut output = crate::types::error::builders::ServiceUnavailableExceptionBuilder::default();
   73         -
                output =
   74         -
                    crate::protocol_serde::shape_service_unavailable_exception::de_service_unavailable_exception_json_err(_response_body, output)
   75         -
                        .map_err(crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::unhandled)?;
   76         -
                let output = output.meta(generic);
   77         -
                output.build()
   78         -
            };
   79         -
            if tmp.message.is_none() {
   80         -
                tmp.message = _error_message;
   81         -
            }
   82         -
            tmp
   83         -
        }),
   84         -
        _ => crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::generic(generic),
   85         -
    })
   86         -
}
   87         -
   88         -
#[allow(clippy::unnecessary_wraps)]
   89         -
pub fn de_get_log_anomaly_detector_http_response(
   90         -
    _response_status: u16,
   91         -
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
   92         -
    _response_body: &[u8],
   93         -
) -> std::result::Result<
   94         -
    crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorOutput,
   95         -
    crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError,
   96         -
> {
   97         -
    Ok({
   98         -
        #[allow(unused_mut)]
   99         -
        let mut output = crate::operation::get_log_anomaly_detector::builders::GetLogAnomalyDetectorOutputBuilder::default();
  100         -
        output = crate::protocol_serde::shape_get_log_anomaly_detector::de_get_log_anomaly_detector(_response_body, output)
  101         -
            .map_err(crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorError::unhandled)?;
  102         -
        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
  103         -
        output.build()
  104         -
    })
  105         -
}
  106         -
  107         -
pub fn ser_get_log_anomaly_detector_input(
  108         -
    input: &crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorInput,
  109         -
) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
  110         -
    let mut out = String::new();
  111         -
    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
  112         -
    crate::protocol_serde::shape_get_log_anomaly_detector_input::ser_get_log_anomaly_detector_input_input(&mut object, input)?;
  113         -
    object.finish();
  114         -
    Ok(::aws_smithy_types::body::SdkBody::from(out))
  115         -
}
  116         -
  117         -
pub(crate) fn de_get_log_anomaly_detector(
  118         -
    _value: &[u8],
  119         -
    mut builder: crate::operation::get_log_anomaly_detector::builders::GetLogAnomalyDetectorOutputBuilder,
  120         -
) -> ::std::result::Result<
  121         -
    crate::operation::get_log_anomaly_detector::builders::GetLogAnomalyDetectorOutputBuilder,
  122         -
    ::aws_smithy_json::deserialize::error::DeserializeError,
  123         -
> {
  124         -
    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(_value)).peekable();
  125         -
    let tokens = &mut tokens_owned;
  126         -
    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
  127         -
    loop {
  128         -
        match tokens.next().transpose()? {
  129         -
            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
  130         -
            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
  131         -
                "detectorName" => {
  132         -
                    builder = builder.set_detector_name(
  133         -
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
  134         -
                            .map(|s| s.to_unescaped().map(|u| u.into_owned()))
  135         -
                            .transpose()?,
  136         -
                    );
  137         -
                }
  138         -
                "logGroupArnList" => {
  139         -
                    builder = builder.set_log_group_arn_list(crate::protocol_serde::shape_log_group_arn_list::de_log_group_arn_list(tokens, _value)?);
  140         -
                }
  141         -
                "evaluationFrequency" => {
  142         -
                    builder = builder.set_evaluation_frequency(
  143         -
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
  144         -
                            .map(|s| s.to_unescaped().map(|u| crate::types::EvaluationFrequency::from(u.as_ref())))
  145         -
                            .transpose()?,
  146         -
                    );
  147         -
                }
  148         -
                "filterPattern" => {
  149         -
                    builder = builder.set_filter_pattern(
  150         -
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
  151         -
                            .map(|s| s.to_unescaped().map(|u| u.into_owned()))
  152         -
                            .transpose()?,
  153         -
                    );
  154         -
                }
  155         -
                "anomalyDetectorStatus" => {
  156         -
                    builder = builder.set_anomaly_detector_status(
  157         -
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
  158         -
                            .map(|s| s.to_unescaped().map(|u| crate::types::AnomalyDetectorStatus::from(u.as_ref())))
  159         -
                            .transpose()?,
  160         -
                    );
  161         -
                }
  162         -
                "kmsKeyId" => {
  163         -
                    builder = builder.set_kms_key_id(
  164         -
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
  165         -
                            .map(|s| s.to_unescaped().map(|u| u.into_owned()))
  166         -
                            .transpose()?,
  167         -
                    );
  168         -
                }
  169         -
                "creationTimeStamp" => {
  170         -
                    builder = builder.set_creation_time_stamp(
  171         -
                        ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
  172         -
                            .map(i64::try_from)
  173         -
                            .transpose()?,
  174         -
                    );
  175         -
                }
  176         -
                "lastModifiedTimeStamp" => {
  177         -
                    builder = builder.set_last_modified_time_stamp(
  178         -
                        ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
  179         -
                            .map(i64::try_from)
  180         -
                            .transpose()?,
  181         -
                    );
  182         -
                }
  183         -
                "anomalyVisibilityTime" => {
  184         -
                    builder = builder.set_anomaly_visibility_time(
  185         -
                        ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
  186         -
                            .map(i64::try_from)
  187         -
                            .transpose()?,
  188         -
                    );
  189         -
                }
  190         -
                _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
  191         -
            },
  192         -
            other => {
  193         -
                return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
  194         -
                    "expected object key or end object, found: {other:?}"
  195         -
                )))
  196         -
            }
  197         -
        }
  198         -
    }
  199         -
    if tokens.next().is_some() {
  200         -
        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
  201         -
            "found more JSON tokens after completing parsing",
  202         -
        ));
  203         -
    }
  204         -
    Ok(builder)
  205         -
}

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

@@ -1,0 +10,0 @@
    1         -
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
pub fn ser_get_log_anomaly_detector_input_input(
    3         -
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
    4         -
    input: &crate::operation::get_log_anomaly_detector::GetLogAnomalyDetectorInput,
    5         -
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
    6         -
    if let Some(var_1) = &input.anomaly_detector_arn {
    7         -
        object.key("anomalyDetectorArn").string(var_1.as_str());
    8         -
    }
    9         -
    Ok(())
   10         -
}

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

@@ -1,0 +142,0 @@
    1         -
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
#[allow(clippy::unnecessary_wraps)]
    3         -
pub fn de_get_log_events_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::get_log_events::GetLogEventsOutput, crate::operation::get_log_events::GetLogEventsError> {
    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::get_log_events::GetLogEventsError::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::get_log_events::GetLogEventsError::unhandled(generic)),
   16         -
    };
   17         -
   18         -
    let _error_message = generic.message().map(|msg| msg.to_owned());
   19         -
    Err(match error_code {
   20         -
        "InvalidParameterException" => crate::operation::get_log_events::GetLogEventsError::InvalidParameterException({
   21         -
            #[allow(unused_mut)]
   22         -
            let mut tmp = {
   23         -
                #[allow(unused_mut)]
   24         -
                let mut output = crate::types::error::builders::InvalidParameterExceptionBuilder::default();
   25         -
                output = crate::protocol_serde::shape_invalid_parameter_exception::de_invalid_parameter_exception_json_err(_response_body, output)
   26         -
                    .map_err(crate::operation::get_log_events::GetLogEventsError::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         -
        "ResourceNotFoundException" => crate::operation::get_log_events::GetLogEventsError::ResourceNotFoundException({
   36         -
            #[allow(unused_mut)]
   37         -
            let mut tmp = {
   38         -
                #[allow(unused_mut)]
   39         -
                let mut output = crate::types::error::builders::ResourceNotFoundExceptionBuilder::default();
   40         -
                output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
   41         -
                    .map_err(crate::operation::get_log_events::GetLogEventsError::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         -
        "ServiceUnavailableException" => crate::operation::get_log_events::GetLogEventsError::ServiceUnavailableException({
   51         -
            #[allow(unused_mut)]
   52         -
            let mut tmp = {
   53         -
                #[allow(unused_mut)]
   54         -
                let mut output = crate::types::error::builders::ServiceUnavailableExceptionBuilder::default();
   55         -
                output =
   56         -
                    crate::protocol_serde::shape_service_unavailable_exception::de_service_unavailable_exception_json_err(_response_body, output)
   57         -
                        .map_err(crate::operation::get_log_events::GetLogEventsError::unhandled)?;
   58         -
                let output = output.meta(generic);
   59         -
                output.build()
   60         -
            };
   61         -
            if tmp.message.is_none() {
   62         -
                tmp.message = _error_message;
   63         -
            }
   64         -
            tmp
   65         -
        }),
   66         -
        _ => crate::operation::get_log_events::GetLogEventsError::generic(generic),
   67         -
    })
   68         -
}
   69         -
   70         -
#[allow(clippy::unnecessary_wraps)]
   71         -
pub fn de_get_log_events_http_response(
   72         -
    _response_status: u16,
   73         -
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
   74         -
    _response_body: &[u8],
   75         -
) -> std::result::Result<crate::operation::get_log_events::GetLogEventsOutput, crate::operation::get_log_events::GetLogEventsError> {
   76         -
    Ok({
   77         -
        #[allow(unused_mut)]
   78         -
        let mut output = crate::operation::get_log_events::builders::GetLogEventsOutputBuilder::default();
   79         -
        output = crate::protocol_serde::shape_get_log_events::de_get_log_events(_response_body, output)
   80         -
            .map_err(crate::operation::get_log_events::GetLogEventsError::unhandled)?;
   81         -
        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
   82         -
        output.build()
   83         -
    })
   84         -
}
   85         -
   86         -
pub fn ser_get_log_events_input(
   87         -
    input: &crate::operation::get_log_events::GetLogEventsInput,
   88         -
) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
   89         -
    let mut out = String::new();
   90         -
    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
   91         -
    crate::protocol_serde::shape_get_log_events_input::ser_get_log_events_input_input(&mut object, input)?;
   92         -
    object.finish();
   93         -
    Ok(::aws_smithy_types::body::SdkBody::from(out))
   94         -
}
   95         -
   96         -
pub(crate) fn de_get_log_events(
   97         -
    _value: &[u8],
   98         -
    mut builder: crate::operation::get_log_events::builders::GetLogEventsOutputBuilder,
   99         -
) -> ::std::result::Result<
  100         -
    crate::operation::get_log_events::builders::GetLogEventsOutputBuilder,
  101         -
    ::aws_smithy_json::deserialize::error::DeserializeError,
  102         -
> {
  103         -
    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(_value)).peekable();
  104         -
    let tokens = &mut tokens_owned;
  105         -
    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
  106         -
    loop {
  107         -
        match tokens.next().transpose()? {
  108         -
            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
  109         -
            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
  110         -
                "events" => {
  111         -
                    builder = builder.set_events(crate::protocol_serde::shape_output_log_events::de_output_log_events(tokens, _value)?);
  112         -
                }
  113         -
                "nextForwardToken" => {
  114         -
                    builder = builder.set_next_forward_token(
  115         -
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
  116         -
                            .map(|s| s.to_unescaped().map(|u| u.into_owned()))
  117         -
                            .transpose()?,
  118         -
                    );
  119         -
                }
  120         -
                "nextBackwardToken" => {
  121         -
                    builder = builder.set_next_backward_token(
  122         -
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
  123         -
                            .map(|s| s.to_unescaped().map(|u| u.into_owned()))
  124         -
                            .transpose()?,
  125         -
                    );
  126         -
                }
  127         -
                _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
  128         -
            },
  129         -
            other => {
  130         -
                return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
  131         -
                    "expected object key or end object, found: {other:?}"
  132         -
                )))
  133         -
            }
  134         -
        }
  135         -
    }
  136         -
    if tokens.next().is_some() {
  137         -
        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
  138         -
            "found more JSON tokens after completing parsing",
  139         -
        ));
  140         -
    }
  141         -
    Ok(builder)
  142         -
}

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

@@ -1,0 +43,0 @@
    1         -
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
pub fn ser_get_log_events_input_input(
    3         -
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
    4         -
    input: &crate::operation::get_log_events::GetLogEventsInput,
    5         -
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
    6         -
    if let Some(var_1) = &input.log_group_name {
    7         -
        object.key("logGroupName").string(var_1.as_str());
    8         -
    }
    9         -
    if let Some(var_2) = &input.log_group_identifier {
   10         -
        object.key("logGroupIdentifier").string(var_2.as_str());
   11         -
    }
   12         -
    if let Some(var_3) = &input.log_stream_name {
   13         -
        object.key("logStreamName").string(var_3.as_str());
   14         -
    }
   15         -
    if let Some(var_4) = &input.start_time {
   16         -
        object.key("startTime").number(
   17         -
            #[allow(clippy::useless_conversion)]
   18         -
            ::aws_smithy_types::Number::NegInt((*var_4).into()),
   19         -
        );
   20         -
    }
   21         -
    if let Some(var_5) = &input.end_time {
   22         -
        object.key("endTime").number(
   23         -
            #[allow(clippy::useless_conversion)]
   24         -
            ::aws_smithy_types::Number::NegInt((*var_5).into()),
   25         -
        );
   26         -
    }
   27         -
    if let Some(var_6) = &input.next_token {
   28         -
        object.key("nextToken").string(var_6.as_str());
   29         -
    }
   30         -
    if let Some(var_7) = &input.limit {
   31         -
        object.key("limit").number(
   32         -
            #[allow(clippy::useless_conversion)]
   33         -
            ::aws_smithy_types::Number::NegInt((*var_7).into()),
   34         -
        );
   35         -
    }
   36         -
    if let Some(var_8) = &input.start_from_head {
   37         -
        object.key("startFromHead").boolean(*var_8);
   38         -
    }
   39         -
    if let Some(var_9) = &input.unmask {
   40         -
        object.key("unmask").boolean(*var_9);
   41         -
    }
   42         -
    Ok(())
   43         -
}

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

@@ -1,0 +151,0 @@
    1         -
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
#[allow(clippy::unnecessary_wraps)]
    3         -
pub fn de_get_log_group_fields_http_error(
    4         -
    _response_status: u16,
    5         -
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
    6         -
    _response_body: &[u8],
    7         -
) -> std::result::Result<
    8         -
    crate::operation::get_log_group_fields::GetLogGroupFieldsOutput,
    9         -
    crate::operation::get_log_group_fields::GetLogGroupFieldsError,
   10         -
> {
   11         -
    #[allow(unused_mut)]
   12         -
    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
   13         -
        .map_err(crate::operation::get_log_group_fields::GetLogGroupFieldsError::unhandled)?;
   14         -
    generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
   15         -
    let generic = generic_builder.build();
   16         -
    let error_code = match generic.code() {
   17         -
        Some(code) => code,
   18         -
        None => return Err(crate::operation::get_log_group_fields::GetLogGroupFieldsError::unhandled(generic)),
   19         -
    };
   20         -
   21         -
    let _error_message = generic.message().map(|msg| msg.to_owned());
   22         -
    Err(match error_code {
   23         -
        "InvalidParameterException" => crate::operation::get_log_group_fields::GetLogGroupFieldsError::InvalidParameterException({
   24         -
            #[allow(unused_mut)]
   25         -
            let mut tmp = {
   26         -
                #[allow(unused_mut)]
   27         -
                let mut output = crate::types::error::builders::InvalidParameterExceptionBuilder::default();
   28         -
                output = crate::protocol_serde::shape_invalid_parameter_exception::de_invalid_parameter_exception_json_err(_response_body, output)
   29         -
                    .map_err(crate::operation::get_log_group_fields::GetLogGroupFieldsError::unhandled)?;
   30         -
                let output = output.meta(generic);
   31         -
                output.build()
   32         -
            };
   33         -
            if tmp.message.is_none() {
   34         -
                tmp.message = _error_message;
   35         -
            }
   36         -
            tmp
   37         -
        }),
   38         -
        "LimitExceededException" => crate::operation::get_log_group_fields::GetLogGroupFieldsError::LimitExceededException({
   39         -
            #[allow(unused_mut)]
   40         -
            let mut tmp = {
   41         -
                #[allow(unused_mut)]
   42         -
                let mut output = crate::types::error::builders::LimitExceededExceptionBuilder::default();
   43         -
                output = crate::protocol_serde::shape_limit_exceeded_exception::de_limit_exceeded_exception_json_err(_response_body, output)
   44         -
                    .map_err(crate::operation::get_log_group_fields::GetLogGroupFieldsError::unhandled)?;
   45         -
                let output = output.meta(generic);
   46         -
                output.build()
   47         -
            };
   48         -
            if tmp.message.is_none() {
   49         -
                tmp.message = _error_message;
   50         -
            }
   51         -
            tmp
   52         -
        }),
   53         -
        "ResourceNotFoundException" => crate::operation::get_log_group_fields::GetLogGroupFieldsError::ResourceNotFoundException({
   54         -
            #[allow(unused_mut)]
   55         -
            let mut tmp = {
   56         -
                #[allow(unused_mut)]
   57         -
                let mut output = crate::types::error::builders::ResourceNotFoundExceptionBuilder::default();
   58         -
                output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
   59         -
                    .map_err(crate::operation::get_log_group_fields::GetLogGroupFieldsError::unhandled)?;
   60         -
                let output = output.meta(generic);
   61         -
                output.build()
   62         -
            };
   63         -
            if tmp.message.is_none() {
   64         -
                tmp.message = _error_message;
   65         -
            }
   66         -
            tmp
   67         -
        }),
   68         -
        "ServiceUnavailableException" => crate::operation::get_log_group_fields::GetLogGroupFieldsError::ServiceUnavailableException({
   69         -
            #[allow(unused_mut)]
   70         -
            let mut tmp = {
   71         -
                #[allow(unused_mut)]
   72         -
                let mut output = crate::types::error::builders::ServiceUnavailableExceptionBuilder::default();
   73         -
                output =
   74         -
                    crate::protocol_serde::shape_service_unavailable_exception::de_service_unavailable_exception_json_err(_response_body, output)
   75         -
                        .map_err(crate::operation::get_log_group_fields::GetLogGroupFieldsError::unhandled)?;
   76         -
                let output = output.meta(generic);
   77         -
                output.build()
   78         -
            };
   79         -
            if tmp.message.is_none() {
   80         -
                tmp.message = _error_message;
   81         -
            }
   82         -
            tmp
   83         -
        }),
   84         -
        _ => crate::operation::get_log_group_fields::GetLogGroupFieldsError::generic(generic),
   85         -
    })
   86         -
}
   87         -
   88         -
#[allow(clippy::unnecessary_wraps)]
   89         -
pub fn de_get_log_group_fields_http_response(
   90         -
    _response_status: u16,
   91         -
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
   92         -
    _response_body: &[u8],
   93         -
) -> std::result::Result<
   94         -
    crate::operation::get_log_group_fields::GetLogGroupFieldsOutput,
   95         -
    crate::operation::get_log_group_fields::GetLogGroupFieldsError,
   96         -
> {
   97         -
    Ok({
   98         -
        #[allow(unused_mut)]
   99         -
        let mut output = crate::operation::get_log_group_fields::builders::GetLogGroupFieldsOutputBuilder::default();
  100         -
        output = crate::protocol_serde::shape_get_log_group_fields::de_get_log_group_fields(_response_body, output)
  101         -
            .map_err(crate::operation::get_log_group_fields::GetLogGroupFieldsError::unhandled)?;
  102         -
        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
  103         -
        output.build()
  104         -
    })
  105         -
}
  106         -
  107         -
pub fn ser_get_log_group_fields_input(
  108         -
    input: &crate::operation::get_log_group_fields::GetLogGroupFieldsInput,
  109         -
) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
  110         -
    let mut out = String::new();
  111         -
    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
  112         -
    crate::protocol_serde::shape_get_log_group_fields_input::ser_get_log_group_fields_input_input(&mut object, input)?;
  113         -
    object.finish();
  114         -
    Ok(::aws_smithy_types::body::SdkBody::from(out))
  115         -
}
  116         -
  117         -
pub(crate) fn de_get_log_group_fields(
  118         -
    _value: &[u8],
  119         -
    mut builder: crate::operation::get_log_group_fields::builders::GetLogGroupFieldsOutputBuilder,
  120         -
) -> ::std::result::Result<
  121         -
    crate::operation::get_log_group_fields::builders::GetLogGroupFieldsOutputBuilder,
  122         -
    ::aws_smithy_json::deserialize::error::DeserializeError,
  123         -
> {
  124         -
    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(_value)).peekable();
  125         -
    let tokens = &mut tokens_owned;
  126         -
    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
  127         -
    loop {
  128         -
        match tokens.next().transpose()? {
  129         -
            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
  130         -
            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
  131         -
                "logGroupFields" => {
  132         -
                    builder = builder.set_log_group_fields(crate::protocol_serde::shape_log_group_field_list::de_log_group_field_list(
  133         -
                        tokens, _value,
  134         -
                    )?);
  135         -
                }
  136         -
                _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
  137         -
            },
  138         -
            other => {
  139         -
                return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
  140         -
                    "expected object key or end object, found: {other:?}"
  141         -
                )))
  142         -
            }
  143         -
        }
  144         -
    }
  145         -
    if tokens.next().is_some() {
  146         -
        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
  147         -
            "found more JSON tokens after completing parsing",
  148         -
        ));
  149         -
    }
  150         -
    Ok(builder)
  151         -
}

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

@@ -1,0 +19,0 @@
    1         -
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
pub fn ser_get_log_group_fields_input_input(
    3         -
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
    4         -
    input: &crate::operation::get_log_group_fields::GetLogGroupFieldsInput,
    5         -
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
    6         -
    if let Some(var_1) = &input.log_group_name {
    7         -
        object.key("logGroupName").string(var_1.as_str());
    8         -
    }
    9         -
    if let Some(var_2) = &input.time {
   10         -
        object.key("time").number(
   11         -
            #[allow(clippy::useless_conversion)]
   12         -
            ::aws_smithy_types::Number::NegInt((*var_2).into()),
   13         -
        );
   14         -
    }
   15         -
    if let Some(var_3) = &input.log_group_identifier {
   16         -
        object.key("logGroupIdentifier").string(var_3.as_str());
   17         -
    }
   18         -
    Ok(())
   19         -
}

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

@@ -1,1 +143,0 @@
   12     12   
    Ok({
   13     13   
        #[allow(unused_mut)]
   14     14   
        let mut output = crate::operation::get_log_object::builders::GetLogObjectOutputBuilder::default();
   15     15   
        output = output.set_field_stream(Some(crate::protocol_serde::shape_get_log_object_output::de_field_stream_payload(
   16     16   
            _response_body,
   17     17   
        )?));
   18     18   
        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
   19     19   
        output.build().map_err(crate::operation::get_log_object::GetLogObjectError::unhandled)?
   20     20   
    })
   21     21   
}
   22         -
   23         -
#[allow(clippy::unnecessary_wraps)]
   24         -
pub fn de_get_log_object_http_error(
   25         -
    _response_status: u16,
   26         -
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
   27         -
    _response_body: &[u8],
   28         -
) -> std::result::Result<crate::operation::get_log_object::GetLogObjectOutput, crate::operation::get_log_object::GetLogObjectError> {
   29         -
    #[allow(unused_mut)]
   30         -
    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
   31         -
        .map_err(crate::operation::get_log_object::GetLogObjectError::unhandled)?;
   32         -
    generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
   33         -
    let generic = generic_builder.build();
   34         -
    let error_code = match generic.code() {
   35         -
        Some(code) => code,
   36         -
        None => return Err(crate::operation::get_log_object::GetLogObjectError::unhandled(generic)),
   37         -
    };
   38         -
   39         -
    let _error_message = generic.message().map(|msg| msg.to_owned());
   40         -
    Err(match error_code {
   41         -
        "AccessDeniedException" => crate::operation::get_log_object::GetLogObjectError::AccessDeniedException({
   42         -
            #[allow(unused_mut)]
   43         -
            let mut tmp = {
   44         -
                #[allow(unused_mut)]
   45         -
                let mut output = crate::types::error::builders::AccessDeniedExceptionBuilder::default();
   46         -
                output = crate::protocol_serde::shape_access_denied_exception::de_access_denied_exception_json_err(_response_body, output)
   47         -
                    .map_err(crate::operation::get_log_object::GetLogObjectError::unhandled)?;
   48         -
                let output = output.meta(generic);
   49         -
                output.build()
   50         -
            };
   51         -
            if tmp.message.is_none() {
   52         -
                tmp.message = _error_message;
   53         -
            }
   54         -
            tmp
   55         -
        }),
   56         -
        "InvalidOperationException" => crate::operation::get_log_object::GetLogObjectError::InvalidOperationException({
   57         -
            #[allow(unused_mut)]
   58         -
            let mut tmp = {
   59         -
                #[allow(unused_mut)]
   60         -
                let mut output = crate::types::error::builders::InvalidOperationExceptionBuilder::default();
   61         -
                output = crate::protocol_serde::shape_invalid_operation_exception::de_invalid_operation_exception_json_err(_response_body, output)
   62         -
                    .map_err(crate::operation::get_log_object::GetLogObjectError::unhandled)?;
   63         -
                let output = output.meta(generic);
   64         -
                output.build()
   65         -
            };
   66         -
            if tmp.message.is_none() {
   67         -
                tmp.message = _error_message;
   68         -
            }
   69         -
            tmp
   70         -
        }),
   71         -
        "InvalidParameterException" => crate::operation::get_log_object::GetLogObjectError::InvalidParameterException({
   72         -
            #[allow(unused_mut)]
   73         -
            let mut tmp = {
   74         -
                #[allow(unused_mut)]
   75         -
                let mut output = crate::types::error::builders::InvalidParameterExceptionBuilder::default();
   76         -
                output = crate::protocol_serde::shape_invalid_parameter_exception::de_invalid_parameter_exception_json_err(_response_body, output)
   77         -
                    .map_err(crate::operation::get_log_object::GetLogObjectError::unhandled)?;
   78         -
                let output = output.meta(generic);
   79         -
                output.build()
   80         -
            };
   81         -
            if tmp.message.is_none() {
   82         -
                tmp.message = _error_message;
   83         -
            }
   84         -
            tmp
   85         -
        }),
   86         -
        "LimitExceededException" => crate::operation::get_log_object::GetLogObjectError::LimitExceededException({
   87         -
            #[allow(unused_mut)]
   88         -
            let mut tmp = {
   89         -
                #[allow(unused_mut)]
   90         -
                let mut output = crate::types::error::builders::LimitExceededExceptionBuilder::default();
   91         -
                output = crate::protocol_serde::shape_limit_exceeded_exception::de_limit_exceeded_exception_json_err(_response_body, output)
   92         -
                    .map_err(crate::operation::get_log_object::GetLogObjectError::unhandled)?;
   93         -
                let output = output.meta(generic);
   94         -
                output.build()
   95         -
            };
   96         -
            if tmp.message.is_none() {
   97         -
                tmp.message = _error_message;
   98         -
            }
   99         -
            tmp
  100         -
        }),
  101         -
        "ResourceNotFoundException" => crate::operation::get_log_object::GetLogObjectError::ResourceNotFoundException({
  102         -
            #[allow(unused_mut)]
  103         -
            let mut tmp = {
  104         -
                #[allow(unused_mut)]
  105         -
                let mut output = crate::types::error::builders::ResourceNotFoundExceptionBuilder::default();
  106         -
                output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
  107         -
                    .map_err(crate::operation::get_log_object::GetLogObjectError::unhandled)?;
  108         -
                let output = output.meta(generic);
  109         -
                output.build()
  110         -
            };
  111         -
            if tmp.message.is_none() {
  112         -
                tmp.message = _error_message;
  113         -
            }
  114         -
            tmp
  115         -
        }),
  116         -
        "InternalStreamingException" => crate::operation::get_log_object::GetLogObjectError::InternalStreamingException({
  117         -
            #[allow(unused_mut)]
  118         -
            let mut tmp = {
  119         -
                #[allow(unused_mut)]
  120         -
                let mut output = crate::types::error::builders::InternalStreamingExceptionBuilder::default();
  121         -
                output = crate::protocol_serde::shape_internal_streaming_exception::de_internal_streaming_exception_json_err(_response_body, output)
  122         -
                    .map_err(crate::operation::get_log_object::GetLogObjectError::unhandled)?;
  123         -
                let output = output.meta(generic);
  124         -
                output.build()
  125         -
            };
  126         -
            if tmp.message.is_none() {
  127         -
                tmp.message = _error_message;
  128         -
            }
  129         -
            tmp
  130         -
        }),
  131         -
        _ => crate::operation::get_log_object::GetLogObjectError::generic(generic),
  132         -
    })
  133         -
}
  134         -
  135         -
pub fn ser_get_log_object_input(
  136         -
    input: &crate::operation::get_log_object::GetLogObjectInput,
  137         -
) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
  138         -
    let mut out = String::new();
  139         -
    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
  140         -
    crate::protocol_serde::shape_get_log_object_input::ser_get_log_object_input_input(&mut object, input)?;
  141         -
    object.finish();
  142         -
    Ok(::aws_smithy_types::body::SdkBody::from(out))
  143         -
}

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

@@ -1,0 +13,0 @@
    1         -
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
pub fn ser_get_log_object_input_input(
    3         -
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
    4         -
    input: &crate::operation::get_log_object::GetLogObjectInput,
    5         -
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
    6         -
    if let Some(var_1) = &input.unmask {
    7         -
        object.key("unmask").boolean(*var_1);
    8         -
    }
    9         -
    if let Some(var_2) = &input.log_object_pointer {
   10         -
        object.key("logObjectPointer").string(var_2.as_str());
   11         -
    }
   12         -
    Ok(())
   13         -
}

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

@@ -1,0 +143,0 @@
    1         -
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
#[allow(clippy::unnecessary_wraps)]
    3         -
pub fn de_get_log_record_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::get_log_record::GetLogRecordOutput, crate::operation::get_log_record::GetLogRecordError> {
    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::get_log_record::GetLogRecordError::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::get_log_record::GetLogRecordError::unhandled(generic)),
   16         -
    };
   17         -
   18         -
    let _error_message = generic.message().map(|msg| msg.to_owned());
   19         -
    Err(match error_code {
   20         -
        "InvalidParameterException" => crate::operation::get_log_record::GetLogRecordError::InvalidParameterException({
   21         -
            #[allow(unused_mut)]
   22         -
            let mut tmp = {
   23         -
                #[allow(unused_mut)]
   24         -
                let mut output = crate::types::error::builders::InvalidParameterExceptionBuilder::default();
   25         -
                output = crate::protocol_serde::shape_invalid_parameter_exception::de_invalid_parameter_exception_json_err(_response_body, output)
   26         -
                    .map_err(crate::operation::get_log_record::GetLogRecordError::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         -
        "LimitExceededException" => crate::operation::get_log_record::GetLogRecordError::LimitExceededException({
   36         -
            #[allow(unused_mut)]
   37         -
            let mut tmp = {
   38         -
                #[allow(unused_mut)]
   39         -
                let mut output = crate::types::error::builders::LimitExceededExceptionBuilder::default();
   40         -
                output = crate::protocol_serde::shape_limit_exceeded_exception::de_limit_exceeded_exception_json_err(_response_body, output)
   41         -
                    .map_err(crate::operation::get_log_record::GetLogRecordError::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         -
        "ResourceNotFoundException" => crate::operation::get_log_record::GetLogRecordError::ResourceNotFoundException({
   51         -
            #[allow(unused_mut)]
   52         -
            let mut tmp = {
   53         -
                #[allow(unused_mut)]
   54         -
                let mut output = crate::types::error::builders::ResourceNotFoundExceptionBuilder::default();
   55         -
                output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
   56         -
                    .map_err(crate::operation::get_log_record::GetLogRecordError::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         -
        "ServiceUnavailableException" => crate::operation::get_log_record::GetLogRecordError::ServiceUnavailableException({
   66         -
            #[allow(unused_mut)]
   67         -
            let mut tmp = {
   68         -
                #[allow(unused_mut)]
   69         -
                let mut output = crate::types::error::builders::ServiceUnavailableExceptionBuilder::default();
   70         -
                output =
   71         -
                    crate::protocol_serde::shape_service_unavailable_exception::de_service_unavailable_exception_json_err(_response_body, output)
   72         -
                        .map_err(crate::operation::get_log_record::GetLogRecordError::unhandled)?;
   73         -
                let output = output.meta(generic);
   74         -
                output.build()
   75         -
            };
   76         -
            if tmp.message.is_none() {
   77         -
                tmp.message = _error_message;
   78         -
            }
   79         -
            tmp
   80         -
        }),
   81         -
        _ => crate::operation::get_log_record::GetLogRecordError::generic(generic),
   82         -
    })
   83         -
}
   84         -
   85         -
#[allow(clippy::unnecessary_wraps)]
   86         -
pub fn de_get_log_record_http_response(
   87         -
    _response_status: u16,
   88         -
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
   89         -
    _response_body: &[u8],
   90         -
) -> std::result::Result<crate::operation::get_log_record::GetLogRecordOutput, crate::operation::get_log_record::GetLogRecordError> {
   91         -
    Ok({
   92         -
        #[allow(unused_mut)]
   93         -
        let mut output = crate::operation::get_log_record::builders::GetLogRecordOutputBuilder::default();
   94         -
        output = crate::protocol_serde::shape_get_log_record::de_get_log_record(_response_body, output)
   95         -
            .map_err(crate::operation::get_log_record::GetLogRecordError::unhandled)?;
   96         -
        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
   97         -
        output.build()
   98         -
    })
   99         -
}
  100         -
  101         -
pub fn ser_get_log_record_input(
  102         -
    input: &crate::operation::get_log_record::GetLogRecordInput,
  103         -
) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
  104         -
    let mut out = String::new();
  105         -
    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
  106         -
    crate::protocol_serde::shape_get_log_record_input::ser_get_log_record_input_input(&mut object, input)?;
  107         -
    object.finish();
  108         -
    Ok(::aws_smithy_types::body::SdkBody::from(out))
  109         -
}
  110         -
  111         -
pub(crate) fn de_get_log_record(
  112         -
    _value: &[u8],
  113         -
    mut builder: crate::operation::get_log_record::builders::GetLogRecordOutputBuilder,
  114         -
) -> ::std::result::Result<
  115         -
    crate::operation::get_log_record::builders::GetLogRecordOutputBuilder,
  116         -
    ::aws_smithy_json::deserialize::error::DeserializeError,
  117         -
> {
  118         -
    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(_value)).peekable();
  119         -
    let tokens = &mut tokens_owned;
  120         -
    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
  121         -
    loop {
  122         -
        match tokens.next().transpose()? {
  123         -
            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
  124         -
            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
  125         -
                "logRecord" => {
  126         -
                    builder = builder.set_log_record(crate::protocol_serde::shape_log_record::de_log_record(tokens, _value)?);
  127         -
                }
  128         -
                _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
  129         -
            },
  130         -
            other => {
  131         -
                return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
  132         -
                    "expected object key or end object, found: {other:?}"
  133         -
                )))
  134         -
            }
  135         -
        }
  136         -
    }
  137         -
    if tokens.next().is_some() {
  138         -
        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
  139         -
            "found more JSON tokens after completing parsing",
  140         -
        ));
  141         -
    }
  142         -
    Ok(builder)
  143         -
}

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

@@ -1,0 +13,0 @@
    1         -
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
pub fn ser_get_log_record_input_input(
    3         -
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
    4         -
    input: &crate::operation::get_log_record::GetLogRecordInput,
    5         -
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
    6         -
    if let Some(var_1) = &input.log_record_pointer {
    7         -
        object.key("logRecordPointer").string(var_1.as_str());
    8         -
    }
    9         -
    if let Some(var_2) = &input.unmask {
   10         -
        object.key("unmask").boolean(*var_2);
   11         -
    }
   12         -
    Ok(())
   13         -
}

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

@@ -1,0 +152,0 @@
    1         -
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
#[allow(clippy::unnecessary_wraps)]
    3         -
pub fn de_get_query_results_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::get_query_results::GetQueryResultsOutput, crate::operation::get_query_results::GetQueryResultsError> {
    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::get_query_results::GetQueryResultsError::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::get_query_results::GetQueryResultsError::unhandled(generic)),
   16         -
    };
   17         -
   18         -
    let _error_message = generic.message().map(|msg| msg.to_owned());
   19         -
    Err(match error_code {
   20         -
        "InvalidParameterException" => crate::operation::get_query_results::GetQueryResultsError::InvalidParameterException({
   21         -
            #[allow(unused_mut)]
   22         -
            let mut tmp = {
   23         -
                #[allow(unused_mut)]
   24         -
                let mut output = crate::types::error::builders::InvalidParameterExceptionBuilder::default();
   25         -
                output = crate::protocol_serde::shape_invalid_parameter_exception::de_invalid_parameter_exception_json_err(_response_body, output)
   26         -
                    .map_err(crate::operation::get_query_results::GetQueryResultsError::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         -
        "ResourceNotFoundException" => crate::operation::get_query_results::GetQueryResultsError::ResourceNotFoundException({
   36         -
            #[allow(unused_mut)]
   37         -
            let mut tmp = {
   38         -
                #[allow(unused_mut)]
   39         -
                let mut output = crate::types::error::builders::ResourceNotFoundExceptionBuilder::default();
   40         -
                output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
   41         -
                    .map_err(crate::operation::get_query_results::GetQueryResultsError::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         -
        "ServiceUnavailableException" => crate::operation::get_query_results::GetQueryResultsError::ServiceUnavailableException({
   51         -
            #[allow(unused_mut)]
   52         -
            let mut tmp = {
   53         -
                #[allow(unused_mut)]
   54         -
                let mut output = crate::types::error::builders::ServiceUnavailableExceptionBuilder::default();
   55         -
                output =
   56         -
                    crate::protocol_serde::shape_service_unavailable_exception::de_service_unavailable_exception_json_err(_response_body, output)
   57         -
                        .map_err(crate::operation::get_query_results::GetQueryResultsError::unhandled)?;
   58         -
                let output = output.meta(generic);
   59         -
                output.build()
   60         -
            };
   61         -
            if tmp.message.is_none() {
   62         -
                tmp.message = _error_message;
   63         -
            }
   64         -
            tmp
   65         -
        }),
   66         -
        _ => crate::operation::get_query_results::GetQueryResultsError::generic(generic),
   67         -
    })
   68         -
}
   69         -
   70         -
#[allow(clippy::unnecessary_wraps)]
   71         -
pub fn de_get_query_results_http_response(
   72         -
    _response_status: u16,
   73         -
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
   74         -
    _response_body: &[u8],
   75         -
) -> std::result::Result<crate::operation::get_query_results::GetQueryResultsOutput, crate::operation::get_query_results::GetQueryResultsError> {
   76         -
    Ok({
   77         -
        #[allow(unused_mut)]
   78         -
        let mut output = crate::operation::get_query_results::builders::GetQueryResultsOutputBuilder::default();
   79         -
        output = crate::protocol_serde::shape_get_query_results::de_get_query_results(_response_body, output)
   80         -
            .map_err(crate::operation::get_query_results::GetQueryResultsError::unhandled)?;
   81         -
        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
   82         -
        output.build()
   83         -
    })
   84         -
}
   85         -
   86         -
pub fn ser_get_query_results_input(
   87         -
    input: &crate::operation::get_query_results::GetQueryResultsInput,
   88         -
) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
   89         -
    let mut out = String::new();
   90         -
    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
   91         -
    crate::protocol_serde::shape_get_query_results_input::ser_get_query_results_input_input(&mut object, input)?;
   92         -
    object.finish();
   93         -
    Ok(::aws_smithy_types::body::SdkBody::from(out))
   94         -
}
   95         -
   96         -
pub(crate) fn de_get_query_results(
   97         -
    _value: &[u8],
   98         -
    mut builder: crate::operation::get_query_results::builders::GetQueryResultsOutputBuilder,
   99         -
) -> ::std::result::Result<
  100         -
    crate::operation::get_query_results::builders::GetQueryResultsOutputBuilder,
  101         -
    ::aws_smithy_json::deserialize::error::DeserializeError,
  102         -
> {
  103         -
    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(_value)).peekable();
  104         -
    let tokens = &mut tokens_owned;
  105         -
    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
  106         -
    loop {
  107         -
        match tokens.next().transpose()? {
  108         -
            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
  109         -
            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
  110         -
                "queryLanguage" => {
  111         -
                    builder = builder.set_query_language(
  112         -
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
  113         -
                            .map(|s| s.to_unescaped().map(|u| crate::types::QueryLanguage::from(u.as_ref())))
  114         -
                            .transpose()?,
  115         -
                    );
  116         -
                }
  117         -
                "results" => {
  118         -
                    builder = builder.set_results(crate::protocol_serde::shape_query_results::de_query_results(tokens, _value)?);
  119         -
                }
  120         -
                "statistics" => {
  121         -
                    builder = builder.set_statistics(crate::protocol_serde::shape_query_statistics::de_query_statistics(tokens, _value)?);
  122         -
                }
  123         -
                "status" => {
  124         -
                    builder = builder.set_status(
  125         -
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
  126         -
                            .map(|s| s.to_unescaped().map(|u| crate::types::QueryStatus::from(u.as_ref())))
  127         -
                            .transpose()?,
  128         -
                    );
  129         -
                }
  130         -
                "encryptionKey" => {
  131         -
                    builder = builder.set_encryption_key(
  132         -
                        ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
  133         -
                            .map(|s| s.to_unescaped().map(|u| u.into_owned()))
  134         -
                            .transpose()?,
  135         -
                    );
  136         -
                }
  137         -
                _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
  138         -
            },
  139         -
            other => {
  140         -
                return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
  141         -
                    "expected object key or end object, found: {other:?}"
  142         -
                )))
  143         -
            }
  144         -
        }
  145         -
    }
  146         -
    if tokens.next().is_some() {
  147         -
        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
  148         -
            "found more JSON tokens after completing parsing",
  149         -
        ));
  150         -
    }
  151         -
    Ok(builder)
  152         -
}