aws_sdk_lambda/protocol_serde/
shape_put_provisioned_concurrency_config.rs1#[allow(clippy::unnecessary_wraps)]
3pub fn de_put_provisioned_concurrency_config_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::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigOutput,
9 crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError,
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::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::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::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::unhandled(generic)),
19 };
20
21 let _error_message = generic.message().map(|msg| msg.to_owned());
22 Err(match error_code {
23 "InvalidParameterValueException" => {
24 crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::InvalidParameterValueException({
25 #[allow(unused_mut)]
26 let mut tmp = {
27 #[allow(unused_mut)]
28 let mut output = crate::types::error::builders::InvalidParameterValueExceptionBuilder::default();
29 output = crate::protocol_serde::shape_invalid_parameter_value_exception::de_invalid_parameter_value_exception_json_err(
30 _response_body,
31 output,
32 )
33 .map_err(crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::unhandled)?;
34 let output = output.meta(generic);
35 output.build()
36 };
37 if tmp.message.is_none() {
38 tmp.message = _error_message;
39 }
40 tmp
41 })
42 }
43 "ResourceConflictException" => {
44 crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::ResourceConflictException({
45 #[allow(unused_mut)]
46 let mut tmp = {
47 #[allow(unused_mut)]
48 let mut output = crate::types::error::builders::ResourceConflictExceptionBuilder::default();
49 output =
50 crate::protocol_serde::shape_resource_conflict_exception::de_resource_conflict_exception_json_err(_response_body, output)
51 .map_err(crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::unhandled)?;
52 let output = output.meta(generic);
53 output.build()
54 };
55 if tmp.message.is_none() {
56 tmp.message = _error_message;
57 }
58 tmp
59 })
60 }
61 "ResourceNotFoundException" => {
62 crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::ResourceNotFoundException({
63 #[allow(unused_mut)]
64 let mut tmp = {
65 #[allow(unused_mut)]
66 let mut output = crate::types::error::builders::ResourceNotFoundExceptionBuilder::default();
67 output =
68 crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
69 .map_err(crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::unhandled)?;
70 let output = output.meta(generic);
71 output.build()
72 };
73 if tmp.message.is_none() {
74 tmp.message = _error_message;
75 }
76 tmp
77 })
78 }
79 "ServiceException" => crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::ServiceException({
80 #[allow(unused_mut)]
81 let mut tmp = {
82 #[allow(unused_mut)]
83 let mut output = crate::types::error::builders::ServiceExceptionBuilder::default();
84 output = crate::protocol_serde::shape_service_exception::de_service_exception_json_err(_response_body, output)
85 .map_err(crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::unhandled)?;
86 let output = output.meta(generic);
87 output.build()
88 };
89 if tmp.message.is_none() {
90 tmp.message = _error_message;
91 }
92 tmp
93 }),
94 "TooManyRequestsException" => {
95 crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::TooManyRequestsException({
96 #[allow(unused_mut)]
97 let mut tmp = {
98 #[allow(unused_mut)]
99 let mut output = crate::types::error::builders::TooManyRequestsExceptionBuilder::default();
100 output =
101 crate::protocol_serde::shape_too_many_requests_exception::de_too_many_requests_exception_json_err(_response_body, output)
102 .map_err(crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::unhandled)?;
103 output = output.set_retry_after_seconds(
104 crate::protocol_serde::shape_too_many_requests_exception::de_retry_after_seconds_header(_response_headers).map_err(|_| {
105 crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::unhandled(
106 "Failed to parse retryAfterSeconds from header `Retry-After",
107 )
108 })?,
109 );
110 let output = output.meta(generic);
111 output.build()
112 };
113 if tmp.message.is_none() {
114 tmp.message = _error_message;
115 }
116 tmp
117 })
118 }
119 _ => crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::generic(generic),
120 })
121}
122
123#[allow(clippy::unnecessary_wraps)]
124pub fn de_put_provisioned_concurrency_config_http_response(
125 _response_status: u16,
126 _response_headers: &::aws_smithy_runtime_api::http::Headers,
127 _response_body: &[u8],
128) -> std::result::Result<
129 crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigOutput,
130 crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError,
131> {
132 Ok({
133 #[allow(unused_mut)]
134 let mut output = crate::operation::put_provisioned_concurrency_config::builders::PutProvisionedConcurrencyConfigOutputBuilder::default();
135 output = crate::protocol_serde::shape_put_provisioned_concurrency_config::de_put_provisioned_concurrency_config(_response_body, output)
136 .map_err(crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigError::unhandled)?;
137 output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
138 output.build()
139 })
140}
141
142pub fn ser_put_provisioned_concurrency_config_input(
143 input: &crate::operation::put_provisioned_concurrency_config::PutProvisionedConcurrencyConfigInput,
144) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
145 let mut out = String::new();
146 let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
147 crate::protocol_serde::shape_put_provisioned_concurrency_config_input::ser_put_provisioned_concurrency_config_input_input(&mut object, input)?;
148 object.finish();
149 Ok(::aws_smithy_types::body::SdkBody::from(out))
150}
151
152pub(crate) fn de_put_provisioned_concurrency_config(
153 value: &[u8],
154 mut builder: crate::operation::put_provisioned_concurrency_config::builders::PutProvisionedConcurrencyConfigOutputBuilder,
155) -> ::std::result::Result<
156 crate::operation::put_provisioned_concurrency_config::builders::PutProvisionedConcurrencyConfigOutputBuilder,
157 ::aws_smithy_json::deserialize::error::DeserializeError,
158> {
159 let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
160 let tokens = &mut tokens_owned;
161 ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
162 loop {
163 match tokens.next().transpose()? {
164 Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
165 Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
166 "AllocatedProvisionedConcurrentExecutions" => {
167 builder = builder.set_allocated_provisioned_concurrent_executions(
168 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
169 .map(i32::try_from)
170 .transpose()?,
171 );
172 }
173 "AvailableProvisionedConcurrentExecutions" => {
174 builder = builder.set_available_provisioned_concurrent_executions(
175 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
176 .map(i32::try_from)
177 .transpose()?,
178 );
179 }
180 "LastModified" => {
181 builder = builder.set_last_modified(
182 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
183 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
184 .transpose()?,
185 );
186 }
187 "RequestedProvisionedConcurrentExecutions" => {
188 builder = builder.set_requested_provisioned_concurrent_executions(
189 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
190 .map(i32::try_from)
191 .transpose()?,
192 );
193 }
194 "Status" => {
195 builder = builder.set_status(
196 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
197 .map(|s| s.to_unescaped().map(|u| crate::types::ProvisionedConcurrencyStatusEnum::from(u.as_ref())))
198 .transpose()?,
199 );
200 }
201 "StatusReason" => {
202 builder = builder.set_status_reason(
203 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
204 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
205 .transpose()?,
206 );
207 }
208 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
209 },
210 other => {
211 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
212 "expected object key or end object, found: {:?}",
213 other
214 )))
215 }
216 }
217 }
218 if tokens.next().is_some() {
219 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
220 "found more JSON tokens after completing parsing",
221 ));
222 }
223 Ok(builder)
224}