1 1 | // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
|
2 + | /* RustType.kt:516 */
|
2 3 | #[allow(clippy::unnecessary_wraps)]
|
4 + | /* ProtocolParserGenerator.kt:99 */
|
3 5 | pub fn de_batch_write_item_http_error(
|
4 6 | _response_status: u16,
|
5 7 | _response_headers: &::aws_smithy_runtime_api::http::Headers,
|
6 8 | _response_body: &[u8],
|
7 9 | ) -> std::result::Result<crate::operation::batch_write_item::BatchWriteItemOutput, crate::operation::batch_write_item::BatchWriteItemError> {
|
10 + | /* RustType.kt:516 */
|
8 11 | #[allow(unused_mut)]
|
12 + | /* ProtocolParserGenerator.kt:106 */
|
9 13 | let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
|
10 14 | .map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
15 + | /* ProtocolParserGenerator.kt:120 */
|
11 16 | let generic = generic_builder.build();
|
17 + | /* ProtocolParserGenerator.kt:122 */
|
12 18 | let error_code = match generic.code() {
|
13 19 | Some(code) => code,
|
14 20 | None => return Err(crate::operation::batch_write_item::BatchWriteItemError::unhandled(generic)),
|
15 21 | };
|
16 22 |
|
17 23 | let _error_message = generic.message().map(|msg| msg.to_owned());
|
24 + | /* ProtocolParserGenerator.kt:133 */
|
18 25 | Err(match error_code {
|
26 + | /* ProtocolParserGenerator.kt:139 */
|
19 27 | "InternalServerError" => crate::operation::batch_write_item::BatchWriteItemError::InternalServerError({
|
28 + | /* RustType.kt:516 */
|
20 29 | #[allow(unused_mut)]
|
21 - | let mut tmp = {
|
22 - | #[allow(unused_mut)]
|
23 - | let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
|
24 - | output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output)
|
25 - | .map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
26 - | let output = output.meta(generic);
|
27 - | output.build()
|
28 - | };
|
30 + | /* ProtocolParserGenerator.kt:145 */let mut tmp =
|
31 + | /* ProtocolParserGenerator.kt:146 */ {
|
32 + | /* RustType.kt:516 */#[allow(unused_mut)]
|
33 + | /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
|
34 + | /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output).map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
35 + | /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
|
36 + | /* ClientBuilderInstantiator.kt:56 */output.build()
|
37 + | /* ProtocolParserGenerator.kt:146 */}
|
38 + | /* ProtocolParserGenerator.kt:145 */;
|
39 + | /* ProtocolParserGenerator.kt:170 */
|
29 40 | if tmp.message.is_none() {
|
30 41 | tmp.message = _error_message;
|
31 42 | }
|
43 + | /* ProtocolParserGenerator.kt:179 */
|
32 44 | tmp
|
45 + | /* ProtocolParserGenerator.kt:139 */
|
33 46 | }),
|
47 + | /* ProtocolParserGenerator.kt:139 */
|
34 48 | "InvalidEndpointException" => crate::operation::batch_write_item::BatchWriteItemError::InvalidEndpointError({
|
49 + | /* RustType.kt:516 */
|
35 50 | #[allow(unused_mut)]
|
36 - | let mut tmp = {
|
37 - | #[allow(unused_mut)]
|
38 - | let mut output = crate::types::error::builders::InvalidEndpointErrorBuilder::default();
|
39 - | output = crate::protocol_serde::shape_invalid_endpoint_exception::de_invalid_endpoint_exception_json_err(_response_body, output)
|
40 - | .map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
41 - | let output = output.meta(generic);
|
42 - | output.build()
|
43 - | };
|
51 + | /* ProtocolParserGenerator.kt:145 */let mut tmp =
|
52 + | /* ProtocolParserGenerator.kt:146 */ {
|
53 + | /* RustType.kt:516 */#[allow(unused_mut)]
|
54 + | /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::InvalidEndpointErrorBuilder::default();
|
55 + | /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_invalid_endpoint_exception::de_invalid_endpoint_exception_json_err(_response_body, output).map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
56 + | /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
|
57 + | /* ClientBuilderInstantiator.kt:56 */output.build()
|
58 + | /* ProtocolParserGenerator.kt:146 */}
|
59 + | /* ProtocolParserGenerator.kt:145 */;
|
60 + | /* ProtocolParserGenerator.kt:170 */
|
44 61 | if tmp.message.is_none() {
|
45 62 | tmp.message = _error_message;
|
46 63 | }
|
64 + | /* ProtocolParserGenerator.kt:179 */
|
47 65 | tmp
|
66 + | /* ProtocolParserGenerator.kt:139 */
|
48 67 | }),
|
68 + | /* ProtocolParserGenerator.kt:139 */
|
49 69 | "ItemCollectionSizeLimitExceededException" => {
|
50 70 | crate::operation::batch_write_item::BatchWriteItemError::ItemCollectionSizeLimitExceededError({
|
71 + | /* RustType.kt:516 */
|
51 72 | #[allow(unused_mut)]
|
52 - | let mut tmp = {
|
53 - | #[allow(unused_mut)]
|
54 - | let mut output = crate::types::error::builders::ItemCollectionSizeLimitExceededErrorBuilder::default();
|
55 - | output = crate::protocol_serde::shape_item_collection_size_limit_exceeded_exception::de_item_collection_size_limit_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
56 - | let output = output.meta(generic);
|
57 - | output.build()
|
58 - | };
|
59 - | if tmp.message.is_none() {
|
60 - | tmp.message = _error_message;
|
61 - | }
|
62 - | tmp
|
63 - | })
|
64 - | }
|
65 - | "ProvisionedThroughputExceededException" => {
|
66 - | crate::operation::batch_write_item::BatchWriteItemError::ProvisionedThroughputExceededError({
|
67 - | #[allow(unused_mut)]
|
68 - | let mut tmp = {
|
69 - | #[allow(unused_mut)]
|
70 - | let mut output = crate::types::error::builders::ProvisionedThroughputExceededErrorBuilder::default();
|
71 - | output = crate::protocol_serde::shape_provisioned_throughput_exceeded_exception::de_provisioned_throughput_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
72 - | let output = output.meta(generic);
|
73 - | output.build()
|
74 - | };
|
73 + | /* ProtocolParserGenerator.kt:145 */let mut tmp =
|
74 + | /* ProtocolParserGenerator.kt:146 */ {
|
75 + | /* RustType.kt:516 */#[allow(unused_mut)]
|
76 + | /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ItemCollectionSizeLimitExceededErrorBuilder::default();
|
77 + | /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_item_collection_size_limit_exceeded_exception::de_item_collection_size_limit_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
78 + | /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
|
79 + | /* ClientBuilderInstantiator.kt:56 */output.build()
|
80 + | /* ProtocolParserGenerator.kt:146 */}
|
81 + | /* ProtocolParserGenerator.kt:145 */;
|
82 + | /* ProtocolParserGenerator.kt:170 */
|
75 83 | if tmp.message.is_none() {
|
76 84 | tmp.message = _error_message;
|
77 85 | }
|
86 + | /* ProtocolParserGenerator.kt:179 */
|
78 87 | tmp
|
88 + | /* ProtocolParserGenerator.kt:139 */
|
79 89 | })
|
80 90 | }
|
91 + | /* ProtocolParserGenerator.kt:139 */
|
92 + | "ProvisionedThroughputExceededException" => crate::operation::batch_write_item::BatchWriteItemError::ProvisionedThroughputExceededError({
|
93 + | /* RustType.kt:516 */
|
94 + | #[allow(unused_mut)]
|
95 + | /* ProtocolParserGenerator.kt:145 */let mut tmp =
|
96 + | /* ProtocolParserGenerator.kt:146 */ {
|
97 + | /* RustType.kt:516 */#[allow(unused_mut)]
|
98 + | /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ProvisionedThroughputExceededErrorBuilder::default();
|
99 + | /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_provisioned_throughput_exceeded_exception::de_provisioned_throughput_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
100 + | /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
|
101 + | /* ClientBuilderInstantiator.kt:56 */output.build()
|
102 + | /* ProtocolParserGenerator.kt:146 */}
|
103 + | /* ProtocolParserGenerator.kt:145 */;
|
104 + | /* ProtocolParserGenerator.kt:170 */
|
105 + | if tmp.message.is_none() {
|
106 + | tmp.message = _error_message;
|
107 + | }
|
108 + | /* ProtocolParserGenerator.kt:179 */
|
109 + | tmp
|
110 + | /* ProtocolParserGenerator.kt:139 */
|
111 + | }),
|
112 + | /* ProtocolParserGenerator.kt:139 */
|
81 113 | "RequestLimitExceeded" => crate::operation::batch_write_item::BatchWriteItemError::RequestLimitExceeded({
|
114 + | /* RustType.kt:516 */
|
82 115 | #[allow(unused_mut)]
|
83 - | let mut tmp = {
|
84 - | #[allow(unused_mut)]
|
85 - | let mut output = crate::types::error::builders::RequestLimitExceededBuilder::default();
|
86 - | output = crate::protocol_serde::shape_request_limit_exceeded::de_request_limit_exceeded_json_err(_response_body, output)
|
87 - | .map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
88 - | let output = output.meta(generic);
|
89 - | output.build()
|
90 - | };
|
116 + | /* ProtocolParserGenerator.kt:145 */let mut tmp =
|
117 + | /* ProtocolParserGenerator.kt:146 */ {
|
118 + | /* RustType.kt:516 */#[allow(unused_mut)]
|
119 + | /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::RequestLimitExceededBuilder::default();
|
120 + | /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_request_limit_exceeded::de_request_limit_exceeded_json_err(_response_body, output).map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
121 + | /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
|
122 + | /* ClientBuilderInstantiator.kt:56 */output.build()
|
123 + | /* ProtocolParserGenerator.kt:146 */}
|
124 + | /* ProtocolParserGenerator.kt:145 */;
|
125 + | /* ProtocolParserGenerator.kt:170 */
|
91 126 | if tmp.message.is_none() {
|
92 127 | tmp.message = _error_message;
|
93 128 | }
|
129 + | /* ProtocolParserGenerator.kt:179 */
|
94 130 | tmp
|
131 + | /* ProtocolParserGenerator.kt:139 */
|
95 132 | }),
|
133 + | /* ProtocolParserGenerator.kt:139 */
|
96 134 | "ResourceNotFoundException" => crate::operation::batch_write_item::BatchWriteItemError::ResourceNotFoundError({
|
135 + | /* RustType.kt:516 */
|
97 136 | #[allow(unused_mut)]
|
98 - | let mut tmp = {
|
99 - | #[allow(unused_mut)]
|
100 - | let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
|
101 - | output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
|
102 - | .map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
103 - | let output = output.meta(generic);
|
104 - | output.build()
|
105 - | };
|
137 + | /* ProtocolParserGenerator.kt:145 */let mut tmp =
|
138 + | /* ProtocolParserGenerator.kt:146 */ {
|
139 + | /* RustType.kt:516 */#[allow(unused_mut)]
|
140 + | /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
|
141 + | /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output).map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
142 + | /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
|
143 + | /* ClientBuilderInstantiator.kt:56 */output.build()
|
144 + | /* ProtocolParserGenerator.kt:146 */}
|
145 + | /* ProtocolParserGenerator.kt:145 */;
|
146 + | /* ProtocolParserGenerator.kt:170 */
|
106 147 | if tmp.message.is_none() {
|
107 148 | tmp.message = _error_message;
|
108 149 | }
|
150 + | /* ProtocolParserGenerator.kt:179 */
|
109 151 | tmp
|
152 + | /* ProtocolParserGenerator.kt:139 */
|
110 153 | }),
|
111 - | _ => crate::operation::batch_write_item::BatchWriteItemError::generic(generic),
|
154 + | /* ProtocolParserGenerator.kt:182 */
|
155 + | _ => crate::operation::batch_write_item::BatchWriteItemError::generic(generic), /* ProtocolParserGenerator.kt:133 */
|
112 156 | })
|
157 + | /* ProtocolParserGenerator.kt:99 */
|
113 158 | }
|
114 159 |
|
160 + | /* RustType.kt:516 */
|
115 161 | #[allow(clippy::unnecessary_wraps)]
|
162 + | /* ProtocolParserGenerator.kt:71 */
|
116 163 | pub fn de_batch_write_item_http_response(
|
117 164 | _response_status: u16,
|
118 165 | _response_headers: &::aws_smithy_runtime_api::http::Headers,
|
119 166 | _response_body: &[u8],
|
120 167 | ) -> std::result::Result<crate::operation::batch_write_item::BatchWriteItemOutput, crate::operation::batch_write_item::BatchWriteItemError> {
|
168 + | /* ProtocolParserGenerator.kt:77 */
|
121 169 | Ok({
|
170 + | /* RustType.kt:516 */
|
122 171 | #[allow(unused_mut)]
|
172 + | /* ProtocolParserGenerator.kt:240 */
|
123 173 | let mut output = crate::operation::batch_write_item::builders::BatchWriteItemOutputBuilder::default();
|
174 + | /* ProtocolParserGenerator.kt:247 */
|
124 175 | output = crate::protocol_serde::shape_batch_write_item::de_batch_write_item(_response_body, output)
|
125 176 | .map_err(crate::operation::batch_write_item::BatchWriteItemError::unhandled)?;
|
177 + | /* ClientBuilderInstantiator.kt:56 */
|
126 178 | output.build()
|
179 + | /* ProtocolParserGenerator.kt:77 */
|
127 180 | })
|
181 + | /* ProtocolParserGenerator.kt:71 */
|
128 182 | }
|
129 183 |
|
184 + | /* JsonSerializerGenerator.kt:287 */
|
130 185 | pub fn ser_batch_write_item_input(
|
131 186 | input: &crate::operation::batch_write_item::BatchWriteItemInput,
|
132 187 | ) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
|
188 + | /* JsonSerializerGenerator.kt:291 */
|
133 189 | let mut out = String::new();
|
190 + | /* JsonSerializerGenerator.kt:292 */
|
134 191 | let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
|
192 + | /* JsonSerializerGenerator.kt:375 */
|
135 193 | crate::protocol_serde::shape_batch_write_item_input::ser_batch_write_item_input_input(&mut object, input)?;
|
194 + | /* JsonSerializerGenerator.kt:295 */
|
136 195 | object.finish();
|
196 + | /* JsonSerializerGenerator.kt:296 */
|
137 197 | Ok(::aws_smithy_types::body::SdkBody::from(out))
|
198 + | /* JsonSerializerGenerator.kt:287 */
|
138 199 | }
|
139 200 |
|
201 + | /* JsonParserGenerator.kt:148 */
|
140 202 | pub(crate) fn de_batch_write_item(
|
141 203 | value: &[u8],
|
142 204 | mut builder: crate::operation::batch_write_item::builders::BatchWriteItemOutputBuilder,
|
143 205 | ) -> ::std::result::Result<
|
144 206 | crate::operation::batch_write_item::builders::BatchWriteItemOutputBuilder,
|
145 207 | ::aws_smithy_json::deserialize::error::DeserializeError,
|
146 208 | > {
|
209 + | /* JsonParserGenerator.kt:153 */
|
147 210 | let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
|
148 211 | let tokens = &mut tokens_owned;
|
149 212 | ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
|
213 + | /* JsonParserGenerator.kt:684 */
|
150 214 | loop {
|
215 + | /* JsonParserGenerator.kt:685 */
|
151 216 | match tokens.next().transpose()? {
|
152 - | Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
|
153 - | Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
|
154 - | "UnprocessedItems" => {
|
155 - | builder = builder
|
156 - | .set_unprocessed_items(crate::protocol_serde::shape_batch_write_item_request_map::de_batch_write_item_request_map(tokens)?);
|
157 - | }
|
158 - | "ItemCollectionMetrics" => {
|
159 - | builder = builder.set_item_collection_metrics(
|
160 - | crate::protocol_serde::shape_item_collection_metrics_per_table::de_item_collection_metrics_per_table(tokens)?,
|
161 - | );
|
162 - | }
|
163 - | "ConsumedCapacity" => {
|
164 - | builder = builder.set_consumed_capacity(crate::protocol_serde::shape_consumed_capacity_multiple::de_consumed_capacity_multiple(
|
165 - | tokens,
|
166 - | )?);
|
217 + | /* JsonParserGenerator.kt:686 */ Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
|
218 + | Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
|
219 + | /* JsonParserGenerator.kt:260 */
|
220 + | match key.to_unescaped()?.as_ref() {
|
221 + | /* JsonParserGenerator.kt:262 */
|
222 + | "UnprocessedItems" => {
|
223 + | /* JsonParserGenerator.kt:265 */
|
224 + | builder = builder.set_unprocessed_items(
|
225 + | /* JsonParserGenerator.kt:509 */crate::protocol_serde::shape_batch_write_item_request_map::de_batch_write_item_request_map(tokens)?
|
226 + | /* JsonParserGenerator.kt:265 */);
|
227 + | /* JsonParserGenerator.kt:262 */
|
228 + | }
|
229 + | /* JsonParserGenerator.kt:262 */
|
230 + | "ItemCollectionMetrics" => {
|
231 + | /* JsonParserGenerator.kt:265 */
|
232 + | builder = builder.set_item_collection_metrics(
|
233 + | /* JsonParserGenerator.kt:509 */crate::protocol_serde::shape_item_collection_metrics_per_table::de_item_collection_metrics_per_table(tokens)?
|
234 + | /* JsonParserGenerator.kt:265 */);
|
235 + | /* JsonParserGenerator.kt:262 */
|
236 + | }
|
237 + | /* JsonParserGenerator.kt:262 */
|
238 + | "ConsumedCapacity" => {
|
239 + | /* JsonParserGenerator.kt:265 */
|
240 + | builder = builder.set_consumed_capacity(
|
241 + | /* JsonParserGenerator.kt:451 */crate::protocol_serde::shape_consumed_capacity_multiple::de_consumed_capacity_multiple(tokens)?
|
242 + | /* JsonParserGenerator.kt:265 */);
|
243 + | /* JsonParserGenerator.kt:262 */
|
244 + | }
|
245 + | /* JsonParserGenerator.kt:290 */
|
246 + | _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:260 */
|
167 247 | }
|
168 - | _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
|
169 - | },
|
248 + | /* JsonParserGenerator.kt:686 */
|
249 + | }
|
250 + | /* JsonParserGenerator.kt:695 */
|
170 251 | other => {
|
171 252 | return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
|
172 253 | "expected object key or end object, found: {:?}",
|
173 254 | other
|
174 255 | )))
|
175 - | }
|
256 + | } /* JsonParserGenerator.kt:685 */
|
176 257 | }
|
258 + | /* JsonParserGenerator.kt:684 */
|
177 259 | }
|
260 + | /* JsonParserGenerator.kt:250 */
|
178 261 | if tokens.next().is_some() {
|
262 + | /* JsonParserGenerator.kt:251 */
|
179 263 | return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
|
180 264 | "found more JSON tokens after completing parsing",
|
181 265 | ));
|
266 + | /* JsonParserGenerator.kt:250 */
|
182 267 | }
|
268 + | /* JsonParserGenerator.kt:163 */
|
183 269 | Ok(builder)
|
270 + | /* JsonParserGenerator.kt:148 */
|
184 271 | }
|