73 82 | runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
|
74 83 | }
|
75 84 | runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
|
76 85 | config_override,
|
77 86 | client_config.config.clone(),
|
78 87 | &client_config.runtime_components,
|
79 88 | ));
|
80 89 | }
|
81 90 | runtime_plugins
|
82 91 | }
|
92 + | /* OperationGenerator.kt:85 */
|
83 93 | }
|
94 + | /* OperationRuntimePluginGenerator.kt:55 */
|
84 95 | impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for PutItem {
|
85 96 | fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
|
86 97 | let mut cfg = ::aws_smithy_types::config_bag::Layer::new("PutItem");
|
87 98 |
|
88 99 | cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
|
89 100 | PutItemRequestSerializer,
|
90 101 | ));
|
91 102 | cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
|
92 103 | PutItemResponseDeserializer,
|
93 104 | ));
|
94 105 |
|
95 106 | cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
|
96 107 | ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
|
97 108 | ));
|
98 109 |
|
99 110 | cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new("PutItem", "DynamoDB"));
|
100 111 |
|
101 112 | ::std::option::Option::Some(cfg.freeze())
|
102 113 | }
|
103 114 |
|
104 115 | fn runtime_components(
|
105 116 | &self,
|
106 117 | _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
|
107 118 | ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
|
108 119 | #[allow(unused_mut)]
|
109 120 | let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("PutItem")
|
110 121 | .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
|
111 122 | .with_interceptor(PutItemEndpointParamsInterceptor)
|
112 123 | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
|
113 124 | crate::operation::put_item::PutItemError,
|
114 125 | >::new())
|
115 126 | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
|
116 127 | crate::operation::put_item::PutItemError,
|
117 128 | >::new());
|
118 129 |
|
119 130 | ::std::borrow::Cow::Owned(rcb)
|
120 131 | }
|
121 132 | }
|
122 133 |
|
134 + | /* ResponseDeserializerGenerator.kt:64 */
|
123 135 | #[derive(Debug)]
|
124 136 | struct PutItemResponseDeserializer;
|
125 137 | impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for PutItemResponseDeserializer {
|
126 138 | fn deserialize_nonstreaming(
|
127 139 | &self,
|
128 140 | response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
|
129 141 | ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
|
130 142 | let (success, status) = (response.status().is_success(), response.status().as_u16());
|
131 143 | let headers = response.headers();
|
132 144 | let body = response.body().bytes().expect("body loaded");
|
133 145 | #[allow(unused_mut)]
|
134 146 | let mut force_error = false;
|
135 147 |
|
136 148 | let parse_result = if !success && status != 200 || force_error {
|
137 149 | crate::protocol_serde::shape_put_item::de_put_item_http_error(status, headers, body)
|
138 150 | } else {
|
139 151 | crate::protocol_serde::shape_put_item::de_put_item_http_response(status, headers, body)
|
140 152 | };
|
141 153 | crate::protocol_serde::type_erase_result(parse_result)
|
142 154 | }
|
143 155 | }
|
156 + | /* RequestSerializerGenerator.kt:67 */
|
144 157 | #[derive(Debug)]
|
145 158 | struct PutItemRequestSerializer;
|
146 159 | impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for PutItemRequestSerializer {
|
147 160 | #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
|
148 161 | fn serialize_input(
|
149 162 | &self,
|
150 163 | input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
|
151 164 | _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
|
152 165 | ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
|
153 166 | let input = input.downcast::<crate::operation::put_item::PutItemInput>().expect("correct type");
|
154 167 | let _header_serialization_settings = _cfg
|
155 168 | .load::<crate::serialization_settings::HeaderSerializationSettings>()
|
156 169 | .cloned()
|
157 170 | .unwrap_or_default();
|
158 171 | let mut request_builder = {
|
159 172 | fn uri_base(
|
160 173 | _input: &crate::operation::put_item::PutItemInput,
|
161 174 | output: &mut ::std::string::String,
|
162 175 | ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
|
163 176 | use ::std::fmt::Write as _;
|
164 177 | ::std::write!(output, "/").expect("formatting should succeed");
|
165 178 | ::std::result::Result::Ok(())
|
166 179 | }
|
167 180 | #[allow(clippy::unnecessary_wraps)]
|
168 181 | fn update_http_builder(
|
169 182 | input: &crate::operation::put_item::PutItemInput,
|
170 183 | builder: ::http::request::Builder,
|
171 184 | ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
|
172 185 | let mut uri = ::std::string::String::new();
|
173 186 | uri_base(input, &mut uri)?;
|
174 187 | ::std::result::Result::Ok(builder.method("POST").uri(uri))
|
175 188 | }
|
176 189 | let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
|
177 190 | builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.0");
|
178 191 | builder = _header_serialization_settings.set_default_header(
|
179 192 | builder,
|
180 193 | ::http::header::HeaderName::from_static("x-amz-target"),
|
181 194 | "DynamoDB_20120810.PutItem",
|
182 195 | );
|
183 196 | builder
|
184 197 | };
|
185 198 | let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_put_item::ser_put_item_input(&input)?);
|
186 199 | if let Some(content_length) = body.content_length() {
|
187 200 | let content_length = content_length.to_string();
|
188 201 | request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
|
189 202 | }
|
190 203 | ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
|
191 204 | }
|
192 205 | }
|
206 + | /* EndpointParamsInterceptorGenerator.kt:86 */
|
193 207 | #[derive(Debug)]
|
194 208 | struct PutItemEndpointParamsInterceptor;
|
195 209 |
|
196 210 | impl ::aws_smithy_runtime_api::client::interceptors::Intercept for PutItemEndpointParamsInterceptor {
|
197 211 | fn name(&self) -> &'static str {
|
198 212 | "PutItemEndpointParamsInterceptor"
|
199 213 | }
|
200 214 |
|
201 215 | fn read_before_execution(
|
202 216 | &self,
|
203 217 | context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
|
204 218 | '_,
|
205 219 | ::aws_smithy_runtime_api::client::interceptors::context::Input,
|
206 220 | ::aws_smithy_runtime_api::client::interceptors::context::Output,
|
207 221 | ::aws_smithy_runtime_api::client::interceptors::context::Error,
|
208 222 | >,
|
209 223 | cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
|
210 224 | ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
|
211 225 | let _input = context
|
212 226 | .input()
|
213 227 | .downcast_ref::<PutItemInput>()
|
214 228 | .ok_or("failed to downcast to PutItemInput")?;
|
215 229 |
|
216 230 | let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
|
217 231 | ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
|
218 232 | })?;
|
219 233 | cfg.interceptor_state()
|
220 234 | .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
|
221 235 | ::std::result::Result::Ok(())
|
222 236 | }
|
223 237 | }
|
224 238 |
|
225 239 | // The get_* functions below are generated from JMESPath expressions in the
|
226 240 | // operationContextParams trait. They target the operation's input shape.
|
227 241 |
|
242 + | /* OperationErrorGenerator.kt:79 */
|
228 243 | /// Error type for the `PutItemError` operation.
|
244 + | /* RustType.kt:516 */
|
229 245 | #[non_exhaustive]
|
246 + | /* RustType.kt:516 */
|
230 247 | #[derive(::std::fmt::Debug)]
|
231 - | pub enum PutItemError {
|
232 - | /// <p>A condition specified in the operation could not be evaluated.</p>
|
248 + | pub /* OperationErrorGenerator.kt:81 */ enum PutItemError {
|
249 + | /// /* OperationErrorGenerator.kt:83 */<p>A condition specified in the operation could not be evaluated.</p>
|
250 + | /* OperationErrorGenerator.kt:86 */
|
233 251 | ConditionalCheckFailedError(crate::types::error::ConditionalCheckFailedError),
|
234 - | /// <p>An error occurred on the server side.</p>
|
252 + | /// /* OperationErrorGenerator.kt:83 */<p>An error occurred on the server side.</p>
|
253 + | /* OperationErrorGenerator.kt:86 */
|
235 254 | InternalServerError(crate::types::error::InternalServerError),
|
255 + | /* OperationErrorGenerator.kt:83 */
|
236 256 | #[allow(missing_docs)] // documentation missing in model
|
257 + | /* OperationErrorGenerator.kt:86 */
|
237 258 | InvalidEndpointError(crate::types::error::InvalidEndpointError),
|
238 - | /// <p>An item collection is too large. This exception is only returned for tables that have one or more local secondary indexes.</p>
|
259 + | /// /* OperationErrorGenerator.kt:83 */<p>An item collection is too large. This exception is only returned for tables that have one or more local secondary indexes.</p>
|
260 + | /* OperationErrorGenerator.kt:86 */
|
239 261 | ItemCollectionSizeLimitExceededError(crate::types::error::ItemCollectionSizeLimitExceededError),
|
240 - | /// <p>Your request rate is too high. The AWS SDKs for DynamoDB automatically retry requests that receive this exception. Your request is eventually successful, unless your retry queue is too large to finish. Reduce the frequency of requests and use exponential backoff. For more information, go to <a href="https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Programming.Errors.html#Programming.Errors.RetryAndBackoff">Error Retries and Exponential Backoff</a> in the <i>Amazon DynamoDB Developer Guide</i>.</p>
|
262 + | /// /* OperationErrorGenerator.kt:83 */<p>Your request rate is too high. The AWS SDKs for DynamoDB automatically retry requests that receive this exception. Your request is eventually successful, unless your retry queue is too large to finish. Reduce the frequency of requests and use exponential backoff. For more information, go to <a href="https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Programming.Errors.html#Programming.Errors.RetryAndBackoff">Error Retries and Exponential Backoff</a> in the <i>Amazon DynamoDB Developer Guide</i>.</p>
|
263 + | /* OperationErrorGenerator.kt:86 */
|
241 264 | ProvisionedThroughputExceededError(crate::types::error::ProvisionedThroughputExceededError),
|
242 - | /// <p>Throughput exceeds the current throughput quota for your account. Please contact AWS Support at <a href="https://aws.amazon.com/support">AWS Support</a> to request a quota increase.</p>
|
265 + | /// /* OperationErrorGenerator.kt:83 */<p>Throughput exceeds the current throughput quota for your account. Please contact AWS Support at <a href="https://aws.amazon.com/support">AWS Support</a> to request a quota increase.</p>
|
266 + | /* OperationErrorGenerator.kt:86 */
|
243 267 | RequestLimitExceeded(crate::types::error::RequestLimitExceeded),
|
244 - | /// <p>The operation tried to access a nonexistent table or index. The resource might not be specified correctly, or its status might not be <code>ACTIVE</code>.</p>
|
268 + | /// /* OperationErrorGenerator.kt:83 */<p>The operation tried to access a nonexistent table or index. The resource might not be specified correctly, or its status might not be <code>ACTIVE</code>.</p>
|
269 + | /* OperationErrorGenerator.kt:86 */
|
245 270 | ResourceNotFoundError(crate::types::error::ResourceNotFoundError),
|
246 - | /// <p>Operation was rejected because there is an ongoing transaction for the item.</p>
|
271 + | /// /* OperationErrorGenerator.kt:83 */<p>Operation was rejected because there is an ongoing transaction for the item.</p>
|
272 + | /* OperationErrorGenerator.kt:86 */
|
247 273 | TransactionConflictError(crate::types::error::TransactionConflictError),
|
274 + | /* OperationErrorGenerator.kt:88 */
|
248 275 | /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
|
249 276 | #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
|
250 277 | variable wildcard pattern and check `.code()`:
|
251 278 | \
|
252 279 | `err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
|
253 280 | \
|
254 281 | See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-PutItemError) for what information is available for the error.")]
|
255 282 | Unhandled(crate::error::sealed_unhandled::Unhandled),
|
283 + | /* OperationErrorGenerator.kt:81 */
|
256 284 | }
|
285 + | /* OperationErrorGenerator.kt:218 */
|
257 286 | impl PutItemError {
|
287 + | /* OperationErrorGenerator.kt:219 */
|
258 288 | /// Creates the `PutItemError::Unhandled` variant from any error type.
|
259 289 | pub fn unhandled(
|
260 290 | err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
|
261 291 | ) -> Self {
|
262 292 | Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
|
263 293 | source: err.into(),
|
264 294 | meta: ::std::default::Default::default(),
|
265 295 | })
|
266 296 | }
|
267 297 |
|
268 298 | /// Creates the `PutItemError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
|
269 299 | pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
|
270 300 | Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
|
271 301 | source: err.clone().into(),
|
272 302 | meta: err,
|
273 303 | })
|
274 304 | }
|
275 - | ///
|
305 + | /// /* OperationErrorGenerator.kt:236 */
|
276 306 | /// Returns error metadata, which includes the error code, message,
|
277 307 | /// request ID, and potentially additional information.
|
278 308 | ///
|
309 + | /* OperationErrorGenerator.kt:242 */
|
279 310 | pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
|
311 + | /* OperationErrorGenerator.kt:243 */
|
280 312 | match self {
|
313 + | /* OperationErrorGenerator.kt:246 */
|
281 314 | Self::ConditionalCheckFailedError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
315 + | /* OperationErrorGenerator.kt:246 */
|
282 316 | Self::InternalServerError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
317 + | /* OperationErrorGenerator.kt:246 */
|
283 318 | Self::InvalidEndpointError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
319 + | /* OperationErrorGenerator.kt:246 */
|
284 320 | Self::ItemCollectionSizeLimitExceededError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
321 + | /* OperationErrorGenerator.kt:246 */
|
285 322 | Self::ProvisionedThroughputExceededError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
323 + | /* OperationErrorGenerator.kt:246 */
|
286 324 | Self::RequestLimitExceeded(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
325 + | /* OperationErrorGenerator.kt:246 */
|
287 326 | Self::ResourceNotFoundError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
327 + | /* OperationErrorGenerator.kt:246 */
|
288 328 | Self::TransactionConflictError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
289 - | Self::Unhandled(e) => &e.meta,
|
329 + | /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
|
330 + | /* OperationErrorGenerator.kt:243 */
|
290 331 | }
|
332 + | /* OperationErrorGenerator.kt:242 */
|
291 333 | }
|
334 + | /* OperationErrorGenerator.kt:257 */
|
292 335 | /// Returns `true` if the error kind is `PutItemError::ConditionalCheckFailedError`.
|
336 + | /* OperationErrorGenerator.kt:258 */
|
293 337 | pub fn is_conditional_check_failed_error(&self) -> bool {
|
338 + | /* OperationErrorGenerator.kt:259 */
|
294 339 | matches!(self, Self::ConditionalCheckFailedError(_))
|
340 + | /* OperationErrorGenerator.kt:258 */
|
295 341 | }
|
342 + | /* OperationErrorGenerator.kt:257 */
|
296 343 | /// Returns `true` if the error kind is `PutItemError::InternalServerError`.
|
344 + | /* OperationErrorGenerator.kt:258 */
|
297 345 | pub fn is_internal_server_error(&self) -> bool {
|
346 + | /* OperationErrorGenerator.kt:259 */
|
298 347 | matches!(self, Self::InternalServerError(_))
|
348 + | /* OperationErrorGenerator.kt:258 */
|
299 349 | }
|
350 + | /* OperationErrorGenerator.kt:257 */
|
300 351 | /// Returns `true` if the error kind is `PutItemError::InvalidEndpointError`.
|
352 + | /* OperationErrorGenerator.kt:258 */
|
301 353 | pub fn is_invalid_endpoint_error(&self) -> bool {
|
354 + | /* OperationErrorGenerator.kt:259 */
|
302 355 | matches!(self, Self::InvalidEndpointError(_))
|
356 + | /* OperationErrorGenerator.kt:258 */
|
303 357 | }
|
358 + | /* OperationErrorGenerator.kt:257 */
|
304 359 | /// Returns `true` if the error kind is `PutItemError::ItemCollectionSizeLimitExceededError`.
|
360 + | /* OperationErrorGenerator.kt:258 */
|
305 361 | pub fn is_item_collection_size_limit_exceeded_error(&self) -> bool {
|
362 + | /* OperationErrorGenerator.kt:259 */
|
306 363 | matches!(self, Self::ItemCollectionSizeLimitExceededError(_))
|
364 + | /* OperationErrorGenerator.kt:258 */
|
307 365 | }
|
366 + | /* OperationErrorGenerator.kt:257 */
|
308 367 | /// Returns `true` if the error kind is `PutItemError::ProvisionedThroughputExceededError`.
|
368 + | /* OperationErrorGenerator.kt:258 */
|
309 369 | pub fn is_provisioned_throughput_exceeded_error(&self) -> bool {
|
370 + | /* OperationErrorGenerator.kt:259 */
|
310 371 | matches!(self, Self::ProvisionedThroughputExceededError(_))
|
372 + | /* OperationErrorGenerator.kt:258 */
|
311 373 | }
|
374 + | /* OperationErrorGenerator.kt:257 */
|
312 375 | /// Returns `true` if the error kind is `PutItemError::RequestLimitExceeded`.
|
376 + | /* OperationErrorGenerator.kt:258 */
|
313 377 | pub fn is_request_limit_exceeded(&self) -> bool {
|
378 + | /* OperationErrorGenerator.kt:259 */
|
314 379 | matches!(self, Self::RequestLimitExceeded(_))
|
380 + | /* OperationErrorGenerator.kt:258 */
|
315 381 | }
|
382 + | /* OperationErrorGenerator.kt:257 */
|
316 383 | /// Returns `true` if the error kind is `PutItemError::ResourceNotFoundError`.
|
384 + | /* OperationErrorGenerator.kt:258 */
|
317 385 | pub fn is_resource_not_found_error(&self) -> bool {
|
386 + | /* OperationErrorGenerator.kt:259 */
|
318 387 | matches!(self, Self::ResourceNotFoundError(_))
|
388 + | /* OperationErrorGenerator.kt:258 */
|
319 389 | }
|
390 + | /* OperationErrorGenerator.kt:257 */
|
320 391 | /// Returns `true` if the error kind is `PutItemError::TransactionConflictError`.
|
392 + | /* OperationErrorGenerator.kt:258 */
|
321 393 | pub fn is_transaction_conflict_error(&self) -> bool {
|
394 + | /* OperationErrorGenerator.kt:259 */
|
322 395 | matches!(self, Self::TransactionConflictError(_))
|
396 + | /* OperationErrorGenerator.kt:258 */
|
323 397 | }
|
398 + | /* OperationErrorGenerator.kt:218 */
|
324 399 | }
|
400 + | /* OperationErrorGenerator.kt:269 */
|
325 401 | impl ::std::error::Error for PutItemError {
|
402 + | /* OperationErrorGenerator.kt:270 */
|
326 403 | fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
|
404 + | /* OperationErrorGenerator.kt:318 */
|
327 405 | match self {
|
328 - | Self::ConditionalCheckFailedError(_inner) => ::std::option::Option::Some(_inner),
|
329 - | Self::InternalServerError(_inner) => ::std::option::Option::Some(_inner),
|
330 - | Self::InvalidEndpointError(_inner) => ::std::option::Option::Some(_inner),
|
331 - | Self::ItemCollectionSizeLimitExceededError(_inner) => ::std::option::Option::Some(_inner),
|
332 - | Self::ProvisionedThroughputExceededError(_inner) => ::std::option::Option::Some(_inner),
|
333 - | Self::RequestLimitExceeded(_inner) => ::std::option::Option::Some(_inner),
|
334 - | Self::ResourceNotFoundError(_inner) => ::std::option::Option::Some(_inner),
|
335 - | Self::TransactionConflictError(_inner) => ::std::option::Option::Some(_inner),
|
336 - | Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
|
406 + | /* OperationErrorGenerator.kt:321 */
|
407 + | Self::ConditionalCheckFailedError(_inner) =>
|
408 + | /* OperationErrorGenerator.kt:283 */
|
409 + | {
|
410 + | ::std::option::Option::Some(_inner)
|
411 + | }
|
412 + | ,
|
413 + | /* OperationErrorGenerator.kt:321 */
|
414 + | Self::InternalServerError(_inner) =>
|
415 + | /* OperationErrorGenerator.kt:283 */
|
416 + | {
|
417 + | ::std::option::Option::Some(_inner)
|
418 + | }
|
419 + | ,
|
420 + | /* OperationErrorGenerator.kt:321 */
|
421 + | Self::InvalidEndpointError(_inner) =>
|
422 + | /* OperationErrorGenerator.kt:283 */
|
423 + | {
|
424 + | ::std::option::Option::Some(_inner)
|
425 + | }
|
426 + | ,
|
427 + | /* OperationErrorGenerator.kt:321 */
|
428 + | Self::ItemCollectionSizeLimitExceededError(_inner) =>
|
429 + | /* OperationErrorGenerator.kt:283 */
|
430 + | {
|
431 + | ::std::option::Option::Some(_inner)
|
432 + | }
|
433 + | ,
|
434 + | /* OperationErrorGenerator.kt:321 */
|
435 + | Self::ProvisionedThroughputExceededError(_inner) =>
|
436 + | /* OperationErrorGenerator.kt:283 */
|
437 + | {
|
438 + | ::std::option::Option::Some(_inner)
|
439 + | }
|
440 + | ,
|
441 + | /* OperationErrorGenerator.kt:321 */
|
442 + | Self::RequestLimitExceeded(_inner) =>
|
443 + | /* OperationErrorGenerator.kt:283 */
|
444 + | {
|
445 + | ::std::option::Option::Some(_inner)
|
446 + | }
|
447 + | ,
|
448 + | /* OperationErrorGenerator.kt:321 */
|
449 + | Self::ResourceNotFoundError(_inner) =>
|
450 + | /* OperationErrorGenerator.kt:283 */
|
451 + | {
|
452 + | ::std::option::Option::Some(_inner)
|
453 + | }
|
454 + | ,
|
455 + | /* OperationErrorGenerator.kt:321 */
|
456 + | Self::TransactionConflictError(_inner) =>
|
457 + | /* OperationErrorGenerator.kt:283 */
|
458 + | {
|
459 + | ::std::option::Option::Some(_inner)
|
460 + | }
|
461 + | ,
|
462 + | /* OperationErrorGenerator.kt:326 */
|
463 + | Self::Unhandled(_inner) => {
|
464 + | /* OperationErrorGenerator.kt:279 */
|
465 + | ::std::option::Option::Some(&*_inner.source)
|
466 + | /* OperationErrorGenerator.kt:326 */
|
467 + | } /* OperationErrorGenerator.kt:318 */
|
337 468 | }
|
469 + | /* OperationErrorGenerator.kt:270 */
|
338 470 | }
|
471 + | /* OperationErrorGenerator.kt:269 */
|
339 472 | }
|
473 + | /* OperationErrorGenerator.kt:133 */
|
340 474 | impl ::std::fmt::Display for PutItemError {
|
475 + | /* OperationErrorGenerator.kt:134 */
|
341 476 | fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
|
477 + | /* OperationErrorGenerator.kt:318 */
|
342 478 | match self {
|
343 - | Self::ConditionalCheckFailedError(_inner) => _inner.fmt(f),
|
344 - | Self::InternalServerError(_inner) => _inner.fmt(f),
|
345 - | Self::InvalidEndpointError(_inner) => _inner.fmt(f),
|
346 - | Self::ItemCollectionSizeLimitExceededError(_inner) => _inner.fmt(f),
|
347 - | Self::ProvisionedThroughputExceededError(_inner) => _inner.fmt(f),
|
348 - | Self::RequestLimitExceeded(_inner) => _inner.fmt(f),
|
349 - | Self::ResourceNotFoundError(_inner) => _inner.fmt(f),
|
350 - | Self::TransactionConflictError(_inner) => _inner.fmt(f),
|
479 + | /* OperationErrorGenerator.kt:321 */
|
480 + | Self::ConditionalCheckFailedError(_inner) =>
|
481 + | /* OperationErrorGenerator.kt:151 */
|
482 + | {
|
483 + | _inner.fmt(f)
|
484 + | }
|
485 + | ,
|
486 + | /* OperationErrorGenerator.kt:321 */
|
487 + | Self::InternalServerError(_inner) =>
|
488 + | /* OperationErrorGenerator.kt:151 */
|
489 + | {
|
490 + | _inner.fmt(f)
|
491 + | }
|
492 + | ,
|
493 + | /* OperationErrorGenerator.kt:321 */
|
494 + | Self::InvalidEndpointError(_inner) =>
|
495 + | /* OperationErrorGenerator.kt:151 */
|
496 + | {
|
497 + | _inner.fmt(f)
|
498 + | }
|
499 + | ,
|
500 + | /* OperationErrorGenerator.kt:321 */
|
501 + | Self::ItemCollectionSizeLimitExceededError(_inner) =>
|
502 + | /* OperationErrorGenerator.kt:151 */
|
503 + | {
|
504 + | _inner.fmt(f)
|
505 + | }
|
506 + | ,
|
507 + | /* OperationErrorGenerator.kt:321 */
|
508 + | Self::ProvisionedThroughputExceededError(_inner) =>
|
509 + | /* OperationErrorGenerator.kt:151 */
|
510 + | {
|
511 + | _inner.fmt(f)
|
512 + | }
|
513 + | ,
|
514 + | /* OperationErrorGenerator.kt:321 */
|
515 + | Self::RequestLimitExceeded(_inner) =>
|
516 + | /* OperationErrorGenerator.kt:151 */
|
517 + | {
|
518 + | _inner.fmt(f)
|
519 + | }
|
520 + | ,
|
521 + | /* OperationErrorGenerator.kt:321 */
|
522 + | Self::ResourceNotFoundError(_inner) =>
|
523 + | /* OperationErrorGenerator.kt:151 */
|
524 + | {
|
525 + | _inner.fmt(f)
|
526 + | }
|
527 + | ,
|
528 + | /* OperationErrorGenerator.kt:321 */
|
529 + | Self::TransactionConflictError(_inner) =>
|
530 + | /* OperationErrorGenerator.kt:151 */
|
531 + | {
|
532 + | _inner.fmt(f)
|
533 + | }
|
534 + | ,
|
535 + | /* OperationErrorGenerator.kt:326 */
|
351 536 | Self::Unhandled(_inner) => {
|
537 + | /* OperationErrorGenerator.kt:139 */
|
352 538 | if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
|
353 539 | write!(f, "unhandled error ({code})")
|
354 540 | } else {
|
355 541 | f.write_str("unhandled error")
|
356 542 | }
|
543 + | /* OperationErrorGenerator.kt:326 */
|
544 + | } /* OperationErrorGenerator.kt:318 */
|
357 545 | }
|
546 + | /* OperationErrorGenerator.kt:134 */
|
358 547 | }
|
359 - | }
|
548 + | /* OperationErrorGenerator.kt:133 */
|
360 549 | }
|
550 + | /* OperationErrorGenerator.kt:182 */
|
361 551 | impl ::aws_smithy_types::retry::ProvideErrorKind for PutItemError {
|
552 + | /* OperationErrorGenerator.kt:186 */
|
362 553 | fn code(&self) -> ::std::option::Option<&str> {
|
554 + | /* OperationErrorGenerator.kt:187 */
|
363 555 | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
|
556 + | /* OperationErrorGenerator.kt:186 */
|
364 557 | }
|
558 + | /* OperationErrorGenerator.kt:190 */
|
365 559 | fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
|
560 + | /* OperationErrorGenerator.kt:197 */
|
366 561 | ::std::option::Option::None
|
562 + | /* OperationErrorGenerator.kt:190 */
|
367 563 | }
|
564 + | /* OperationErrorGenerator.kt:182 */
|
368 565 | }
|
566 + | /* OperationErrorGenerator.kt:163 */
|
369 567 | impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for PutItemError {
|
568 + | /* OperationErrorGenerator.kt:164 */
|
370 569 | fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
|
570 + | /* OperationErrorGenerator.kt:318 */
|
371 571 | match self {
|
372 - | Self::ConditionalCheckFailedError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
373 - | Self::InternalServerError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
374 - | Self::InvalidEndpointError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
375 - | Self::ItemCollectionSizeLimitExceededError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
376 - | Self::ProvisionedThroughputExceededError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
377 - | Self::RequestLimitExceeded(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
378 - | Self::ResourceNotFoundError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
379 - | Self::TransactionConflictError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
380 - | Self::Unhandled(_inner) => &_inner.meta,
|
572 + | /* OperationErrorGenerator.kt:321 */
|
573 + | Self::ConditionalCheckFailedError(_inner) =>
|
574 + | /* OperationErrorGenerator.kt:169 */
|
575 + | {
|
576 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
577 + | }
|
578 + | ,
|
579 + | /* OperationErrorGenerator.kt:321 */
|
580 + | Self::InternalServerError(_inner) =>
|
581 + | /* OperationErrorGenerator.kt:169 */
|
582 + | {
|
583 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
584 + | }
|
585 + | ,
|
586 + | /* OperationErrorGenerator.kt:321 */
|
587 + | Self::InvalidEndpointError(_inner) =>
|
588 + | /* OperationErrorGenerator.kt:169 */
|
589 + | {
|
590 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
591 + | }
|
592 + | ,
|
593 + | /* OperationErrorGenerator.kt:321 */
|
594 + | Self::ItemCollectionSizeLimitExceededError(_inner) =>
|
595 + | /* OperationErrorGenerator.kt:169 */
|
596 + | {
|
597 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
598 + | }
|
599 + | ,
|
600 + | /* OperationErrorGenerator.kt:321 */
|
601 + | Self::ProvisionedThroughputExceededError(_inner) =>
|
602 + | /* OperationErrorGenerator.kt:169 */
|
603 + | {
|
604 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
605 + | }
|
606 + | ,
|
607 + | /* OperationErrorGenerator.kt:321 */
|
608 + | Self::RequestLimitExceeded(_inner) =>
|
609 + | /* OperationErrorGenerator.kt:169 */
|
610 + | {
|
611 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
612 + | }
|
613 + | ,
|
614 + | /* OperationErrorGenerator.kt:321 */
|
615 + | Self::ResourceNotFoundError(_inner) =>
|
616 + | /* OperationErrorGenerator.kt:169 */
|
617 + | {
|
618 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
619 + | }
|
620 + | ,
|
621 + | /* OperationErrorGenerator.kt:321 */
|
622 + | Self::TransactionConflictError(_inner) =>
|
623 + | /* OperationErrorGenerator.kt:169 */
|
624 + | {
|
625 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
626 + | }
|
627 + | ,
|
628 + | /* OperationErrorGenerator.kt:326 */
|
629 + | Self::Unhandled(_inner) => {
|
630 + | /* OperationErrorGenerator.kt:168 */
|
631 + | &_inner.meta
|
632 + | /* OperationErrorGenerator.kt:326 */
|
633 + | } /* OperationErrorGenerator.kt:318 */
|
381 634 | }
|
635 + | /* OperationErrorGenerator.kt:164 */
|
382 636 | }
|
637 + | /* OperationErrorGenerator.kt:163 */
|
383 638 | }
|
639 + | /* OperationErrorGenerator.kt:109 */
|
384 640 | impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for PutItemError {
|
641 + | /* OperationErrorGenerator.kt:110 */
|
385 642 | fn create_unhandled_error(
|
386 643 | source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
|
387 644 | meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
|
388 645 | ) -> Self {
|
646 + | /* OperationErrorGenerator.kt:121 */
|
389 647 | Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
|
390 648 | source,
|
391 649 | meta: meta.unwrap_or_default(),
|
392 650 | })
|
651 + | /* OperationErrorGenerator.kt:110 */
|
393 652 | }
|
653 + | /* OperationErrorGenerator.kt:109 */
|
394 654 | }
|
395 655 |
|
656 + | /* CodegenDelegator.kt:255 */
|
396 657 | pub use crate::operation::put_item::_put_item_output::PutItemOutput;
|
397 658 |
|
659 + | /* CodegenDelegator.kt:255 */
|
398 660 | pub use crate::operation::put_item::_put_item_input::PutItemInput;
|
399 661 |
|
662 + | /* RustModule.kt:172 */
|
400 663 | mod _put_item_input;
|
401 664 |
|
665 + | /* RustModule.kt:172 */
|
402 666 | mod _put_item_output;
|
403 667 |
|
404 - | /// Builders
|
668 + | /// /* CodegenDelegator.kt:51 */Builders
|
405 669 | pub mod builders;
|