aws_sdk_imagebuilder/protocol_serde/
shape_create_image_pipeline.rs1#[allow(clippy::unnecessary_wraps)]
3pub fn de_create_image_pipeline_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::create_image_pipeline::CreateImagePipelineOutput,
9 crate::operation::create_image_pipeline::CreateImagePipelineError,
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::create_image_pipeline::CreateImagePipelineError::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::create_image_pipeline::CreateImagePipelineError::unhandled(generic)),
19 };
20
21 let _error_message = generic.message().map(|msg| msg.to_owned());
22 Err(match error_code {
23 "CallRateLimitExceededException" => crate::operation::create_image_pipeline::CreateImagePipelineError::CallRateLimitExceededException({
24 #[allow(unused_mut)]
25 let mut tmp = {
26 #[allow(unused_mut)]
27 let mut output = crate::types::error::builders::CallRateLimitExceededExceptionBuilder::default();
28 output = crate::protocol_serde::shape_call_rate_limit_exceeded_exception::de_call_rate_limit_exceeded_exception_json_err(
29 _response_body,
30 output,
31 )
32 .map_err(crate::operation::create_image_pipeline::CreateImagePipelineError::unhandled)?;
33 let output = output.meta(generic);
34 output.build()
35 };
36 if tmp.message.is_none() {
37 tmp.message = _error_message;
38 }
39 tmp
40 }),
41 "ClientException" => crate::operation::create_image_pipeline::CreateImagePipelineError::ClientException({
42 #[allow(unused_mut)]
43 let mut tmp = {
44 #[allow(unused_mut)]
45 let mut output = crate::types::error::builders::ClientExceptionBuilder::default();
46 output = crate::protocol_serde::shape_client_exception::de_client_exception_json_err(_response_body, output)
47 .map_err(crate::operation::create_image_pipeline::CreateImagePipelineError::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 "ForbiddenException" => crate::operation::create_image_pipeline::CreateImagePipelineError::ForbiddenException({
57 #[allow(unused_mut)]
58 let mut tmp = {
59 #[allow(unused_mut)]
60 let mut output = crate::types::error::builders::ForbiddenExceptionBuilder::default();
61 output = crate::protocol_serde::shape_forbidden_exception::de_forbidden_exception_json_err(_response_body, output)
62 .map_err(crate::operation::create_image_pipeline::CreateImagePipelineError::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 "IdempotentParameterMismatchException" => {
72 crate::operation::create_image_pipeline::CreateImagePipelineError::IdempotentParameterMismatchException({
73 #[allow(unused_mut)]
74 let mut tmp = {
75 #[allow(unused_mut)]
76 let mut output = crate::types::error::builders::IdempotentParameterMismatchExceptionBuilder::default();
77 output =
78 crate::protocol_serde::shape_idempotent_parameter_mismatch_exception::de_idempotent_parameter_mismatch_exception_json_err(
79 _response_body,
80 output,
81 )
82 .map_err(crate::operation::create_image_pipeline::CreateImagePipelineError::unhandled)?;
83 let output = output.meta(generic);
84 output.build()
85 };
86 if tmp.message.is_none() {
87 tmp.message = _error_message;
88 }
89 tmp
90 })
91 }
92 "InvalidRequestException" => crate::operation::create_image_pipeline::CreateImagePipelineError::InvalidRequestException({
93 #[allow(unused_mut)]
94 let mut tmp = {
95 #[allow(unused_mut)]
96 let mut output = crate::types::error::builders::InvalidRequestExceptionBuilder::default();
97 output = crate::protocol_serde::shape_invalid_request_exception::de_invalid_request_exception_json_err(_response_body, output)
98 .map_err(crate::operation::create_image_pipeline::CreateImagePipelineError::unhandled)?;
99 let output = output.meta(generic);
100 output.build()
101 };
102 if tmp.message.is_none() {
103 tmp.message = _error_message;
104 }
105 tmp
106 }),
107 "ResourceAlreadyExistsException" => crate::operation::create_image_pipeline::CreateImagePipelineError::ResourceAlreadyExistsException({
108 #[allow(unused_mut)]
109 let mut tmp = {
110 #[allow(unused_mut)]
111 let mut output = crate::types::error::builders::ResourceAlreadyExistsExceptionBuilder::default();
112 output = crate::protocol_serde::shape_resource_already_exists_exception::de_resource_already_exists_exception_json_err(
113 _response_body,
114 output,
115 )
116 .map_err(crate::operation::create_image_pipeline::CreateImagePipelineError::unhandled)?;
117 let output = output.meta(generic);
118 output.build()
119 };
120 if tmp.message.is_none() {
121 tmp.message = _error_message;
122 }
123 tmp
124 }),
125 "ResourceInUseException" => crate::operation::create_image_pipeline::CreateImagePipelineError::ResourceInUseException({
126 #[allow(unused_mut)]
127 let mut tmp = {
128 #[allow(unused_mut)]
129 let mut output = crate::types::error::builders::ResourceInUseExceptionBuilder::default();
130 output = crate::protocol_serde::shape_resource_in_use_exception::de_resource_in_use_exception_json_err(_response_body, output)
131 .map_err(crate::operation::create_image_pipeline::CreateImagePipelineError::unhandled)?;
132 let output = output.meta(generic);
133 output.build()
134 };
135 if tmp.message.is_none() {
136 tmp.message = _error_message;
137 }
138 tmp
139 }),
140 "ServiceException" => crate::operation::create_image_pipeline::CreateImagePipelineError::ServiceException({
141 #[allow(unused_mut)]
142 let mut tmp = {
143 #[allow(unused_mut)]
144 let mut output = crate::types::error::builders::ServiceExceptionBuilder::default();
145 output = crate::protocol_serde::shape_service_exception::de_service_exception_json_err(_response_body, output)
146 .map_err(crate::operation::create_image_pipeline::CreateImagePipelineError::unhandled)?;
147 let output = output.meta(generic);
148 output.build()
149 };
150 if tmp.message.is_none() {
151 tmp.message = _error_message;
152 }
153 tmp
154 }),
155 "ServiceQuotaExceededException" => crate::operation::create_image_pipeline::CreateImagePipelineError::ServiceQuotaExceededException({
156 #[allow(unused_mut)]
157 let mut tmp = {
158 #[allow(unused_mut)]
159 let mut output = crate::types::error::builders::ServiceQuotaExceededExceptionBuilder::default();
160 output = crate::protocol_serde::shape_service_quota_exceeded_exception::de_service_quota_exceeded_exception_json_err(
161 _response_body,
162 output,
163 )
164 .map_err(crate::operation::create_image_pipeline::CreateImagePipelineError::unhandled)?;
165 let output = output.meta(generic);
166 output.build()
167 };
168 if tmp.message.is_none() {
169 tmp.message = _error_message;
170 }
171 tmp
172 }),
173 "ServiceUnavailableException" => crate::operation::create_image_pipeline::CreateImagePipelineError::ServiceUnavailableException({
174 #[allow(unused_mut)]
175 let mut tmp = {
176 #[allow(unused_mut)]
177 let mut output = crate::types::error::builders::ServiceUnavailableExceptionBuilder::default();
178 output =
179 crate::protocol_serde::shape_service_unavailable_exception::de_service_unavailable_exception_json_err(_response_body, output)
180 .map_err(crate::operation::create_image_pipeline::CreateImagePipelineError::unhandled)?;
181 let output = output.meta(generic);
182 output.build()
183 };
184 if tmp.message.is_none() {
185 tmp.message = _error_message;
186 }
187 tmp
188 }),
189 _ => crate::operation::create_image_pipeline::CreateImagePipelineError::generic(generic),
190 })
191}
192
193#[allow(clippy::unnecessary_wraps)]
194pub fn de_create_image_pipeline_http_response(
195 _response_status: u16,
196 _response_headers: &::aws_smithy_runtime_api::http::Headers,
197 _response_body: &[u8],
198) -> std::result::Result<
199 crate::operation::create_image_pipeline::CreateImagePipelineOutput,
200 crate::operation::create_image_pipeline::CreateImagePipelineError,
201> {
202 Ok({
203 #[allow(unused_mut)]
204 let mut output = crate::operation::create_image_pipeline::builders::CreateImagePipelineOutputBuilder::default();
205 output = crate::protocol_serde::shape_create_image_pipeline::de_create_image_pipeline(_response_body, output)
206 .map_err(crate::operation::create_image_pipeline::CreateImagePipelineError::unhandled)?;
207 output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
208 output.build()
209 })
210}
211
212pub fn ser_create_image_pipeline_input(
213 input: &crate::operation::create_image_pipeline::CreateImagePipelineInput,
214) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
215 let mut out = String::new();
216 let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
217 crate::protocol_serde::shape_create_image_pipeline_input::ser_create_image_pipeline_input_input(&mut object, input)?;
218 object.finish();
219 Ok(::aws_smithy_types::body::SdkBody::from(out))
220}
221
222pub(crate) fn de_create_image_pipeline(
223 value: &[u8],
224 mut builder: crate::operation::create_image_pipeline::builders::CreateImagePipelineOutputBuilder,
225) -> ::std::result::Result<
226 crate::operation::create_image_pipeline::builders::CreateImagePipelineOutputBuilder,
227 ::aws_smithy_json::deserialize::error::DeserializeError,
228> {
229 let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
230 let tokens = &mut tokens_owned;
231 ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
232 loop {
233 match tokens.next().transpose()? {
234 Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
235 Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
236 "clientToken" => {
237 builder = builder.set_client_token(
238 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
239 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
240 .transpose()?,
241 );
242 }
243 "imagePipelineArn" => {
244 builder = builder.set_image_pipeline_arn(
245 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
246 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
247 .transpose()?,
248 );
249 }
250 "requestId" => {
251 builder = builder.set_request_id(
252 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
253 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
254 .transpose()?,
255 );
256 }
257 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
258 },
259 other => {
260 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
261 "expected object key or end object, found: {:?}",
262 other
263 )))
264 }
265 }
266 }
267 if tokens.next().is_some() {
268 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
269 "found more JSON tokens after completing parsing",
270 ));
271 }
272 Ok(builder)
273}