aws_sdk_databasemigration/protocol_serde/
shape_start_replication_task_assessment_run.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2#[allow(clippy::unnecessary_wraps)]
3pub fn de_start_replication_task_assessment_run_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::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunOutput,
9    crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError,
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::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::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::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled(generic)),
19    };
20
21    let _error_message = generic.message().map(|msg| msg.to_owned());
22    Err(match error_code {
23        "AccessDeniedFault" => crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::AccessDeniedFault({
24            #[allow(unused_mut)]
25            let mut tmp = {
26                #[allow(unused_mut)]
27                let mut output = crate::types::error::builders::AccessDeniedFaultBuilder::default();
28                output = crate::protocol_serde::shape_access_denied_fault::de_access_denied_fault_json_err(_response_body, output)
29                    .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::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        "InvalidResourceStateFault" => {
39            crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::InvalidResourceStateFault({
40                #[allow(unused_mut)]
41                let mut tmp = {
42                    #[allow(unused_mut)]
43                    let mut output = crate::types::error::builders::InvalidResourceStateFaultBuilder::default();
44                    output =
45                        crate::protocol_serde::shape_invalid_resource_state_fault::de_invalid_resource_state_fault_json_err(_response_body, output)
46                            .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
47                    let output = output.meta(generic);
48                    output.build()
49                };
50                if tmp.message.is_none() {
51                    tmp.message = _error_message;
52                }
53                tmp
54            })
55        }
56        "KMSAccessDeniedFault" => {
57            crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::KmsAccessDeniedFault({
58                #[allow(unused_mut)]
59                let mut tmp = {
60                    #[allow(unused_mut)]
61                    let mut output = crate::types::error::builders::KmsAccessDeniedFaultBuilder::default();
62                    output = crate::protocol_serde::shape_kms_access_denied_fault::de_kms_access_denied_fault_json_err(_response_body, output)
63                        .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
64                    let output = output.meta(generic);
65                    output.build()
66                };
67                if tmp.message.is_none() {
68                    tmp.message = _error_message;
69                }
70                tmp
71            })
72        }
73        "KMSDisabledFault" => crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::KmsDisabledFault({
74            #[allow(unused_mut)]
75            let mut tmp = {
76                #[allow(unused_mut)]
77                let mut output = crate::types::error::builders::KmsDisabledFaultBuilder::default();
78                output = crate::protocol_serde::shape_kms_disabled_fault::de_kms_disabled_fault_json_err(_response_body, output)
79                    .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
80                let output = output.meta(generic);
81                output.build()
82            };
83            if tmp.message.is_none() {
84                tmp.message = _error_message;
85            }
86            tmp
87        }),
88        "KMSFault" => crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::KmsFault({
89            #[allow(unused_mut)]
90            let mut tmp = {
91                #[allow(unused_mut)]
92                let mut output = crate::types::error::builders::KmsFaultBuilder::default();
93                output = crate::protocol_serde::shape_kms_fault::de_kms_fault_json_err(_response_body, output)
94                    .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
95                let output = output.meta(generic);
96                output.build()
97            };
98            if tmp.message.is_none() {
99                tmp.message = _error_message;
100            }
101            tmp
102        }),
103        "KMSInvalidStateFault" => {
104            crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::KmsInvalidStateFault({
105                #[allow(unused_mut)]
106                let mut tmp = {
107                    #[allow(unused_mut)]
108                    let mut output = crate::types::error::builders::KmsInvalidStateFaultBuilder::default();
109                    output = crate::protocol_serde::shape_kms_invalid_state_fault::de_kms_invalid_state_fault_json_err(_response_body, output)
110                        .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
111                    let output = output.meta(generic);
112                    output.build()
113                };
114                if tmp.message.is_none() {
115                    tmp.message = _error_message;
116                }
117                tmp
118            })
119        }
120        "KMSKeyNotAccessibleFault" => {
121            crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::KmsKeyNotAccessibleFault({
122                #[allow(unused_mut)]
123                let mut tmp = {
124                    #[allow(unused_mut)]
125                    let mut output = crate::types::error::builders::KmsKeyNotAccessibleFaultBuilder::default();
126                    output =
127                        crate::protocol_serde::shape_kms_key_not_accessible_fault::de_kms_key_not_accessible_fault_json_err(_response_body, output)
128                            .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
129                    let output = output.meta(generic);
130                    output.build()
131                };
132                if tmp.message.is_none() {
133                    tmp.message = _error_message;
134                }
135                tmp
136            })
137        }
138        "KMSNotFoundFault" => crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::KmsNotFoundFault({
139            #[allow(unused_mut)]
140            let mut tmp = {
141                #[allow(unused_mut)]
142                let mut output = crate::types::error::builders::KmsNotFoundFaultBuilder::default();
143                output = crate::protocol_serde::shape_kms_not_found_fault::de_kms_not_found_fault_json_err(_response_body, output)
144                    .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
145                let output = output.meta(generic);
146                output.build()
147            };
148            if tmp.message.is_none() {
149                tmp.message = _error_message;
150            }
151            tmp
152        }),
153        "ResourceAlreadyExistsFault" => {
154            crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::ResourceAlreadyExistsFault({
155                #[allow(unused_mut)]
156                let mut tmp = {
157                    #[allow(unused_mut)]
158                    let mut output = crate::types::error::builders::ResourceAlreadyExistsFaultBuilder::default();
159                    output =
160                        crate::protocol_serde::shape_resource_already_exists_fault::de_resource_already_exists_fault_json_err(_response_body, output)
161                            .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
162                    let output = output.meta(generic);
163                    output.build()
164                };
165                if tmp.message.is_none() {
166                    tmp.message = _error_message;
167                }
168                tmp
169            })
170        }
171        "ResourceNotFoundFault" => {
172            crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::ResourceNotFoundFault({
173                #[allow(unused_mut)]
174                let mut tmp = {
175                    #[allow(unused_mut)]
176                    let mut output = crate::types::error::builders::ResourceNotFoundFaultBuilder::default();
177                    output = crate::protocol_serde::shape_resource_not_found_fault::de_resource_not_found_fault_json_err(_response_body, output)
178                        .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
179                    let output = output.meta(generic);
180                    output.build()
181                };
182                if tmp.message.is_none() {
183                    tmp.message = _error_message;
184                }
185                tmp
186            })
187        }
188        "S3AccessDeniedFault" => {
189            crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::S3AccessDeniedFault({
190                #[allow(unused_mut)]
191                let mut tmp = {
192                    #[allow(unused_mut)]
193                    let mut output = crate::types::error::builders::S3AccessDeniedFaultBuilder::default();
194                    output = crate::protocol_serde::shape_s3_access_denied_fault::de_s3_access_denied_fault_json_err(_response_body, output)
195                        .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
196                    let output = output.meta(generic);
197                    output.build()
198                };
199                if tmp.message.is_none() {
200                    tmp.message = _error_message;
201                }
202                tmp
203            })
204        }
205        "S3ResourceNotFoundFault" => {
206            crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::S3ResourceNotFoundFault({
207                #[allow(unused_mut)]
208                let mut tmp = {
209                    #[allow(unused_mut)]
210                    let mut output = crate::types::error::builders::S3ResourceNotFoundFaultBuilder::default();
211                    output =
212                        crate::protocol_serde::shape_s3_resource_not_found_fault::de_s3_resource_not_found_fault_json_err(_response_body, output)
213                            .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
214                    let output = output.meta(generic);
215                    output.build()
216                };
217                if tmp.message.is_none() {
218                    tmp.message = _error_message;
219                }
220                tmp
221            })
222        }
223        _ => crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::generic(generic),
224    })
225}
226
227#[allow(clippy::unnecessary_wraps)]
228pub fn de_start_replication_task_assessment_run_http_response(
229    _response_status: u16,
230    _response_headers: &::aws_smithy_runtime_api::http::Headers,
231    _response_body: &[u8],
232) -> std::result::Result<
233    crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunOutput,
234    crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError,
235> {
236    Ok({
237        #[allow(unused_mut)]
238        let mut output = crate::operation::start_replication_task_assessment_run::builders::StartReplicationTaskAssessmentRunOutputBuilder::default();
239        output = crate::protocol_serde::shape_start_replication_task_assessment_run::de_start_replication_task_assessment_run(_response_body, output)
240            .map_err(crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunError::unhandled)?;
241        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
242        output.build()
243    })
244}
245
246pub fn ser_start_replication_task_assessment_run_input(
247    input: &crate::operation::start_replication_task_assessment_run::StartReplicationTaskAssessmentRunInput,
248) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
249    let mut out = String::new();
250    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
251    crate::protocol_serde::shape_start_replication_task_assessment_run_input::ser_start_replication_task_assessment_run_input_input(
252        &mut object,
253        input,
254    )?;
255    object.finish();
256    Ok(::aws_smithy_types::body::SdkBody::from(out))
257}
258
259pub(crate) fn de_start_replication_task_assessment_run(
260    value: &[u8],
261    mut builder: crate::operation::start_replication_task_assessment_run::builders::StartReplicationTaskAssessmentRunOutputBuilder,
262) -> ::std::result::Result<
263    crate::operation::start_replication_task_assessment_run::builders::StartReplicationTaskAssessmentRunOutputBuilder,
264    ::aws_smithy_json::deserialize::error::DeserializeError,
265> {
266    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
267    let tokens = &mut tokens_owned;
268    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
269    loop {
270        match tokens.next().transpose()? {
271            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
272            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
273                "ReplicationTaskAssessmentRun" => {
274                    builder = builder.set_replication_task_assessment_run(
275                        crate::protocol_serde::shape_replication_task_assessment_run::de_replication_task_assessment_run(tokens)?,
276                    );
277                }
278                _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
279            },
280            other => {
281                return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
282                    "expected object key or end object, found: {:?}",
283                    other
284                )))
285            }
286        }
287    }
288    if tokens.next().is_some() {
289        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
290            "found more JSON tokens after completing parsing",
291        ));
292    }
293    Ok(builder)
294}
aws_sdk_databasemigration/protocol_serde/shape_start_replication_task_assessment_run.rs

aws_sdk_databasemigration/protocol_serde/
shape_start_replication_task_assessment_run.rs
