86 95 | runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
|
87 96 | }
|
88 97 | runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
|
89 98 | config_override,
|
90 99 | client_config.config.clone(),
|
91 100 | &client_config.runtime_components,
|
92 101 | ));
|
93 102 | }
|
94 103 | runtime_plugins
|
95 104 | }
|
105 + | /* OperationGenerator.kt:85 */
|
96 106 | }
|
107 + | /* OperationRuntimePluginGenerator.kt:55 */
|
97 108 | impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for TransactWriteItems {
|
98 109 | fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
|
99 110 | let mut cfg = ::aws_smithy_types::config_bag::Layer::new("TransactWriteItems");
|
100 111 |
|
101 112 | cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
|
102 113 | TransactWriteItemsRequestSerializer,
|
103 114 | ));
|
104 115 | cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
|
105 116 | TransactWriteItemsResponseDeserializer,
|
106 117 | ));
|
107 118 |
|
108 119 | cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
|
109 120 | ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
|
110 121 | ));
|
111 122 |
|
112 123 | cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
|
113 124 | "TransactWriteItems",
|
114 125 | "DynamoDB",
|
115 126 | ));
|
116 127 |
|
117 128 | ::std::option::Option::Some(cfg.freeze())
|
118 129 | }
|
119 130 |
|
120 131 | fn runtime_components(
|
121 132 | &self,
|
122 133 | _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
|
123 134 | ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
|
124 135 | #[allow(unused_mut)]
|
125 136 | let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("TransactWriteItems")
|
126 137 | .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
|
127 138 | .with_interceptor(TransactWriteItemsEndpointParamsInterceptor)
|
128 139 | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
|
129 140 | crate::operation::transact_write_items::TransactWriteItemsError,
|
130 141 | >::new())
|
131 142 | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
|
132 143 | crate::operation::transact_write_items::TransactWriteItemsError,
|
133 144 | >::new());
|
134 145 |
|
135 146 | ::std::borrow::Cow::Owned(rcb)
|
136 147 | }
|
137 148 | }
|
138 149 |
|
150 + | /* ResponseDeserializerGenerator.kt:64 */
|
139 151 | #[derive(Debug)]
|
140 152 | struct TransactWriteItemsResponseDeserializer;
|
141 153 | impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for TransactWriteItemsResponseDeserializer {
|
142 154 | fn deserialize_nonstreaming(
|
143 155 | &self,
|
144 156 | response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
|
145 157 | ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
|
146 158 | let (success, status) = (response.status().is_success(), response.status().as_u16());
|
147 159 | let headers = response.headers();
|
148 160 | let body = response.body().bytes().expect("body loaded");
|
149 161 | #[allow(unused_mut)]
|
150 162 | let mut force_error = false;
|
151 163 |
|
152 164 | let parse_result = if !success && status != 200 || force_error {
|
153 165 | crate::protocol_serde::shape_transact_write_items::de_transact_write_items_http_error(status, headers, body)
|
154 166 | } else {
|
155 167 | crate::protocol_serde::shape_transact_write_items::de_transact_write_items_http_response(status, headers, body)
|
156 168 | };
|
157 169 | crate::protocol_serde::type_erase_result(parse_result)
|
158 170 | }
|
159 171 | }
|
172 + | /* RequestSerializerGenerator.kt:67 */
|
160 173 | #[derive(Debug)]
|
161 174 | struct TransactWriteItemsRequestSerializer;
|
162 175 | impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for TransactWriteItemsRequestSerializer {
|
163 176 | #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
|
164 177 | fn serialize_input(
|
165 178 | &self,
|
166 179 | input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
|
167 180 | _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
|
168 181 | ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
|
169 182 | let input = input
|
170 183 | .downcast::<crate::operation::transact_write_items::TransactWriteItemsInput>()
|
171 184 | .expect("correct type");
|
172 185 | let _header_serialization_settings = _cfg
|
173 186 | .load::<crate::serialization_settings::HeaderSerializationSettings>()
|
174 187 | .cloned()
|
175 188 | .unwrap_or_default();
|
176 189 | let mut request_builder = {
|
177 190 | fn uri_base(
|
178 191 | _input: &crate::operation::transact_write_items::TransactWriteItemsInput,
|
179 192 | output: &mut ::std::string::String,
|
180 193 | ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
|
181 194 | use ::std::fmt::Write as _;
|
182 195 | ::std::write!(output, "/").expect("formatting should succeed");
|
183 196 | ::std::result::Result::Ok(())
|
184 197 | }
|
185 198 | #[allow(clippy::unnecessary_wraps)]
|
186 199 | fn update_http_builder(
|
187 200 | input: &crate::operation::transact_write_items::TransactWriteItemsInput,
|
188 201 | builder: ::http::request::Builder,
|
189 202 | ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
|
190 203 | let mut uri = ::std::string::String::new();
|
191 204 | uri_base(input, &mut uri)?;
|
192 205 | ::std::result::Result::Ok(builder.method("POST").uri(uri))
|
193 206 | }
|
194 207 | let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
|
195 208 | builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.0");
|
196 209 | builder = _header_serialization_settings.set_default_header(
|
197 210 | builder,
|
198 211 | ::http::header::HeaderName::from_static("x-amz-target"),
|
199 212 | "DynamoDB_20120810.TransactWriteItems",
|
200 213 | );
|
201 214 | builder
|
202 215 | };
|
203 216 | let body =
|
204 217 | ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_transact_write_items::ser_transact_write_items_input(&input)?);
|
205 218 | if let Some(content_length) = body.content_length() {
|
206 219 | let content_length = content_length.to_string();
|
207 220 | request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
|
208 221 | }
|
209 222 | ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
|
210 223 | }
|
211 224 | }
|
225 + | /* EndpointParamsInterceptorGenerator.kt:86 */
|
212 226 | #[derive(Debug)]
|
213 227 | struct TransactWriteItemsEndpointParamsInterceptor;
|
214 228 |
|
215 229 | impl ::aws_smithy_runtime_api::client::interceptors::Intercept for TransactWriteItemsEndpointParamsInterceptor {
|
216 230 | fn name(&self) -> &'static str {
|
217 231 | "TransactWriteItemsEndpointParamsInterceptor"
|
218 232 | }
|
219 233 |
|
220 234 | fn read_before_execution(
|
221 235 | &self,
|
222 236 | context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
|
223 237 | '_,
|
224 238 | ::aws_smithy_runtime_api::client::interceptors::context::Input,
|
225 239 | ::aws_smithy_runtime_api::client::interceptors::context::Output,
|
226 240 | ::aws_smithy_runtime_api::client::interceptors::context::Error,
|
227 241 | >,
|
228 242 | cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
|
229 243 | ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
|
230 244 | let _input = context
|
231 245 | .input()
|
232 246 | .downcast_ref::<TransactWriteItemsInput>()
|
233 247 | .ok_or("failed to downcast to TransactWriteItemsInput")?;
|
234 248 |
|
235 249 | let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
|
236 250 | ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
|
237 251 | })?;
|
238 252 | cfg.interceptor_state()
|
239 253 | .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
|
240 254 | ::std::result::Result::Ok(())
|
241 255 | }
|
242 256 | }
|
243 257 |
|
244 258 | // The get_* functions below are generated from JMESPath expressions in the
|
245 259 | // operationContextParams trait. They target the operation's input shape.
|
246 260 |
|
261 + | /* OperationErrorGenerator.kt:79 */
|
247 262 | /// Error type for the `TransactWriteItemsError` operation.
|
263 + | /* RustType.kt:516 */
|
248 264 | #[non_exhaustive]
|
265 + | /* RustType.kt:516 */
|
249 266 | #[derive(::std::fmt::Debug)]
|
250 - | pub enum TransactWriteItemsError {
|
251 - | /// <p>DynamoDB rejected the request because you retried a request with a different payload but with an idempotent token that was already used.</p>
|
267 + | pub /* OperationErrorGenerator.kt:81 */ enum TransactWriteItemsError {
|
268 + | /// /* OperationErrorGenerator.kt:83 */<p>DynamoDB rejected the request because you retried a request with a different payload but with an idempotent token that was already used.</p>
|
269 + | /* OperationErrorGenerator.kt:86 */
|
252 270 | IdempotentParameterMismatchError(crate::types::error::IdempotentParameterMismatchError),
|
253 - | /// <p>An error occurred on the server side.</p>
|
271 + | /// /* OperationErrorGenerator.kt:83 */<p>An error occurred on the server side.</p>
|
272 + | /* OperationErrorGenerator.kt:86 */
|
254 273 | InternalServerError(crate::types::error::InternalServerError),
|
274 + | /* OperationErrorGenerator.kt:83 */
|
255 275 | #[allow(missing_docs)] // documentation missing in model
|
276 + | /* OperationErrorGenerator.kt:86 */
|
256 277 | InvalidEndpointError(crate::types::error::InvalidEndpointError),
|
257 - | /// <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>
|
278 + | /// /* 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>
|
279 + | /* OperationErrorGenerator.kt:86 */
|
258 280 | ProvisionedThroughputExceededError(crate::types::error::ProvisionedThroughputExceededError),
|
259 - | /// <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>
|
281 + | /// /* 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>
|
282 + | /* OperationErrorGenerator.kt:86 */
|
260 283 | RequestLimitExceeded(crate::types::error::RequestLimitExceeded),
|
261 - | /// <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>
|
284 + | /// /* 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>
|
285 + | /* OperationErrorGenerator.kt:86 */
|
262 286 | ResourceNotFoundError(crate::types::error::ResourceNotFoundError),
|
263 - | /// <p>The entire transaction request was canceled.</p>
|
287 + | /// /* OperationErrorGenerator.kt:83 */<p>The entire transaction request was canceled.</p>
|
264 288 | /// <p>DynamoDB cancels a <code>TransactWriteItems</code> request under the following circumstances:</p>
|
265 289 | /// <ul>
|
266 290 | /// <li>
|
267 291 | /// <p>A condition in one of the condition expressions is not met.</p></li>
|
268 292 | /// <li>
|
269 293 | /// <p>A table in the <code>TransactWriteItems</code> request is in a different account or region.</p></li>
|
270 294 | /// <li>
|
271 295 | /// <p>More than one action in the <code>TransactWriteItems</code> operation targets the same item.</p></li>
|
272 296 | /// <li>
|
273 297 | /// <p>There is insufficient provisioned capacity for the transaction to be completed.</p></li>
|
383 407 | /// <p>Type mismatch for attribute to update.</p></li>
|
384 408 | /// <li>
|
385 409 | /// <p>Nesting Levels have exceeded supported limits.</p></li>
|
386 410 | /// <li>
|
387 411 | /// <p>The document path provided in the update expression is invalid for update.</p></li>
|
388 412 | /// <li>
|
389 413 | /// <p>The provided expression refers to an attribute that does not exist in the item.</p></li>
|
390 414 | /// </ul></li>
|
391 415 | /// </ul></li>
|
392 416 | /// </ul>
|
417 + | /* OperationErrorGenerator.kt:86 */
|
393 418 | TransactionCanceledError(crate::types::error::TransactionCanceledError),
|
394 - | /// <p>The transaction with the given request token is already in progress.</p>
|
419 + | /// /* OperationErrorGenerator.kt:83 */<p>The transaction with the given request token is already in progress.</p>
|
420 + | /* OperationErrorGenerator.kt:86 */
|
395 421 | TransactionInProgressError(crate::types::error::TransactionInProgressError),
|
422 + | /* OperationErrorGenerator.kt:88 */
|
396 423 | /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
|
397 424 | #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
|
398 425 | variable wildcard pattern and check `.code()`:
|
399 426 | \
|
400 427 | `err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
|
401 428 | \
|
402 429 | See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-TransactWriteItemsError) for what information is available for the error.")]
|
403 430 | Unhandled(crate::error::sealed_unhandled::Unhandled),
|
431 + | /* OperationErrorGenerator.kt:81 */
|
404 432 | }
|
433 + | /* OperationErrorGenerator.kt:218 */
|
405 434 | impl TransactWriteItemsError {
|
435 + | /* OperationErrorGenerator.kt:219 */
|
406 436 | /// Creates the `TransactWriteItemsError::Unhandled` variant from any error type.
|
407 437 | pub fn unhandled(
|
408 438 | err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
|
409 439 | ) -> Self {
|
410 440 | Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
|
411 441 | source: err.into(),
|
412 442 | meta: ::std::default::Default::default(),
|
413 443 | })
|
414 444 | }
|
415 445 |
|
416 446 | /// Creates the `TransactWriteItemsError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
|
417 447 | pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
|
418 448 | Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
|
419 449 | source: err.clone().into(),
|
420 450 | meta: err,
|
421 451 | })
|
422 452 | }
|
423 - | ///
|
453 + | /// /* OperationErrorGenerator.kt:236 */
|
424 454 | /// Returns error metadata, which includes the error code, message,
|
425 455 | /// request ID, and potentially additional information.
|
426 456 | ///
|
457 + | /* OperationErrorGenerator.kt:242 */
|
427 458 | pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
|
459 + | /* OperationErrorGenerator.kt:243 */
|
428 460 | match self {
|
461 + | /* OperationErrorGenerator.kt:246 */
|
429 462 | Self::IdempotentParameterMismatchError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
463 + | /* OperationErrorGenerator.kt:246 */
|
430 464 | Self::InternalServerError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
465 + | /* OperationErrorGenerator.kt:246 */
|
431 466 | Self::InvalidEndpointError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
467 + | /* OperationErrorGenerator.kt:246 */
|
432 468 | Self::ProvisionedThroughputExceededError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
469 + | /* OperationErrorGenerator.kt:246 */
|
433 470 | Self::RequestLimitExceeded(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
471 + | /* OperationErrorGenerator.kt:246 */
|
434 472 | Self::ResourceNotFoundError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
473 + | /* OperationErrorGenerator.kt:246 */
|
435 474 | Self::TransactionCanceledError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
475 + | /* OperationErrorGenerator.kt:246 */
|
436 476 | Self::TransactionInProgressError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
|
437 - | Self::Unhandled(e) => &e.meta,
|
477 + | /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
|
478 + | /* OperationErrorGenerator.kt:243 */
|
438 479 | }
|
480 + | /* OperationErrorGenerator.kt:242 */
|
439 481 | }
|
482 + | /* OperationErrorGenerator.kt:257 */
|
440 483 | /// Returns `true` if the error kind is `TransactWriteItemsError::IdempotentParameterMismatchError`.
|
484 + | /* OperationErrorGenerator.kt:258 */
|
441 485 | pub fn is_idempotent_parameter_mismatch_error(&self) -> bool {
|
486 + | /* OperationErrorGenerator.kt:259 */
|
442 487 | matches!(self, Self::IdempotentParameterMismatchError(_))
|
488 + | /* OperationErrorGenerator.kt:258 */
|
443 489 | }
|
490 + | /* OperationErrorGenerator.kt:257 */
|
444 491 | /// Returns `true` if the error kind is `TransactWriteItemsError::InternalServerError`.
|
492 + | /* OperationErrorGenerator.kt:258 */
|
445 493 | pub fn is_internal_server_error(&self) -> bool {
|
494 + | /* OperationErrorGenerator.kt:259 */
|
446 495 | matches!(self, Self::InternalServerError(_))
|
496 + | /* OperationErrorGenerator.kt:258 */
|
447 497 | }
|
498 + | /* OperationErrorGenerator.kt:257 */
|
448 499 | /// Returns `true` if the error kind is `TransactWriteItemsError::InvalidEndpointError`.
|
500 + | /* OperationErrorGenerator.kt:258 */
|
449 501 | pub fn is_invalid_endpoint_error(&self) -> bool {
|
502 + | /* OperationErrorGenerator.kt:259 */
|
450 503 | matches!(self, Self::InvalidEndpointError(_))
|
504 + | /* OperationErrorGenerator.kt:258 */
|
451 505 | }
|
506 + | /* OperationErrorGenerator.kt:257 */
|
452 507 | /// Returns `true` if the error kind is `TransactWriteItemsError::ProvisionedThroughputExceededError`.
|
508 + | /* OperationErrorGenerator.kt:258 */
|
453 509 | pub fn is_provisioned_throughput_exceeded_error(&self) -> bool {
|
510 + | /* OperationErrorGenerator.kt:259 */
|
454 511 | matches!(self, Self::ProvisionedThroughputExceededError(_))
|
512 + | /* OperationErrorGenerator.kt:258 */
|
455 513 | }
|
514 + | /* OperationErrorGenerator.kt:257 */
|
456 515 | /// Returns `true` if the error kind is `TransactWriteItemsError::RequestLimitExceeded`.
|
516 + | /* OperationErrorGenerator.kt:258 */
|
457 517 | pub fn is_request_limit_exceeded(&self) -> bool {
|
518 + | /* OperationErrorGenerator.kt:259 */
|
458 519 | matches!(self, Self::RequestLimitExceeded(_))
|
520 + | /* OperationErrorGenerator.kt:258 */
|
459 521 | }
|
522 + | /* OperationErrorGenerator.kt:257 */
|
460 523 | /// Returns `true` if the error kind is `TransactWriteItemsError::ResourceNotFoundError`.
|
524 + | /* OperationErrorGenerator.kt:258 */
|
461 525 | pub fn is_resource_not_found_error(&self) -> bool {
|
526 + | /* OperationErrorGenerator.kt:259 */
|
462 527 | matches!(self, Self::ResourceNotFoundError(_))
|
528 + | /* OperationErrorGenerator.kt:258 */
|
463 529 | }
|
530 + | /* OperationErrorGenerator.kt:257 */
|
464 531 | /// Returns `true` if the error kind is `TransactWriteItemsError::TransactionCanceledError`.
|
532 + | /* OperationErrorGenerator.kt:258 */
|
465 533 | pub fn is_transaction_canceled_error(&self) -> bool {
|
534 + | /* OperationErrorGenerator.kt:259 */
|
466 535 | matches!(self, Self::TransactionCanceledError(_))
|
536 + | /* OperationErrorGenerator.kt:258 */
|
467 537 | }
|
538 + | /* OperationErrorGenerator.kt:257 */
|
468 539 | /// Returns `true` if the error kind is `TransactWriteItemsError::TransactionInProgressError`.
|
540 + | /* OperationErrorGenerator.kt:258 */
|
469 541 | pub fn is_transaction_in_progress_error(&self) -> bool {
|
542 + | /* OperationErrorGenerator.kt:259 */
|
470 543 | matches!(self, Self::TransactionInProgressError(_))
|
544 + | /* OperationErrorGenerator.kt:258 */
|
471 545 | }
|
546 + | /* OperationErrorGenerator.kt:218 */
|
472 547 | }
|
548 + | /* OperationErrorGenerator.kt:269 */
|
473 549 | impl ::std::error::Error for TransactWriteItemsError {
|
550 + | /* OperationErrorGenerator.kt:270 */
|
474 551 | fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
|
552 + | /* OperationErrorGenerator.kt:318 */
|
475 553 | match self {
|
476 - | Self::IdempotentParameterMismatchError(_inner) => ::std::option::Option::Some(_inner),
|
477 - | Self::InternalServerError(_inner) => ::std::option::Option::Some(_inner),
|
478 - | Self::InvalidEndpointError(_inner) => ::std::option::Option::Some(_inner),
|
479 - | Self::ProvisionedThroughputExceededError(_inner) => ::std::option::Option::Some(_inner),
|
480 - | Self::RequestLimitExceeded(_inner) => ::std::option::Option::Some(_inner),
|
481 - | Self::ResourceNotFoundError(_inner) => ::std::option::Option::Some(_inner),
|
482 - | Self::TransactionCanceledError(_inner) => ::std::option::Option::Some(_inner),
|
483 - | Self::TransactionInProgressError(_inner) => ::std::option::Option::Some(_inner),
|
484 - | Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
|
554 + | /* OperationErrorGenerator.kt:321 */
|
555 + | Self::IdempotentParameterMismatchError(_inner) =>
|
556 + | /* OperationErrorGenerator.kt:283 */
|
557 + | {
|
558 + | ::std::option::Option::Some(_inner)
|
559 + | }
|
560 + | ,
|
561 + | /* OperationErrorGenerator.kt:321 */
|
562 + | Self::InternalServerError(_inner) =>
|
563 + | /* OperationErrorGenerator.kt:283 */
|
564 + | {
|
565 + | ::std::option::Option::Some(_inner)
|
566 + | }
|
567 + | ,
|
568 + | /* OperationErrorGenerator.kt:321 */
|
569 + | Self::InvalidEndpointError(_inner) =>
|
570 + | /* OperationErrorGenerator.kt:283 */
|
571 + | {
|
572 + | ::std::option::Option::Some(_inner)
|
573 + | }
|
574 + | ,
|
575 + | /* OperationErrorGenerator.kt:321 */
|
576 + | Self::ProvisionedThroughputExceededError(_inner) =>
|
577 + | /* OperationErrorGenerator.kt:283 */
|
578 + | {
|
579 + | ::std::option::Option::Some(_inner)
|
580 + | }
|
581 + | ,
|
582 + | /* OperationErrorGenerator.kt:321 */
|
583 + | Self::RequestLimitExceeded(_inner) =>
|
584 + | /* OperationErrorGenerator.kt:283 */
|
585 + | {
|
586 + | ::std::option::Option::Some(_inner)
|
587 + | }
|
588 + | ,
|
589 + | /* OperationErrorGenerator.kt:321 */
|
590 + | Self::ResourceNotFoundError(_inner) =>
|
591 + | /* OperationErrorGenerator.kt:283 */
|
592 + | {
|
593 + | ::std::option::Option::Some(_inner)
|
594 + | }
|
595 + | ,
|
596 + | /* OperationErrorGenerator.kt:321 */
|
597 + | Self::TransactionCanceledError(_inner) =>
|
598 + | /* OperationErrorGenerator.kt:283 */
|
599 + | {
|
600 + | ::std::option::Option::Some(_inner)
|
601 + | }
|
602 + | ,
|
603 + | /* OperationErrorGenerator.kt:321 */
|
604 + | Self::TransactionInProgressError(_inner) =>
|
605 + | /* OperationErrorGenerator.kt:283 */
|
606 + | {
|
607 + | ::std::option::Option::Some(_inner)
|
608 + | }
|
609 + | ,
|
610 + | /* OperationErrorGenerator.kt:326 */
|
611 + | Self::Unhandled(_inner) => {
|
612 + | /* OperationErrorGenerator.kt:279 */
|
613 + | ::std::option::Option::Some(&*_inner.source)
|
614 + | /* OperationErrorGenerator.kt:326 */
|
615 + | } /* OperationErrorGenerator.kt:318 */
|
485 616 | }
|
617 + | /* OperationErrorGenerator.kt:270 */
|
486 618 | }
|
619 + | /* OperationErrorGenerator.kt:269 */
|
487 620 | }
|
621 + | /* OperationErrorGenerator.kt:133 */
|
488 622 | impl ::std::fmt::Display for TransactWriteItemsError {
|
623 + | /* OperationErrorGenerator.kt:134 */
|
489 624 | fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
|
625 + | /* OperationErrorGenerator.kt:318 */
|
490 626 | match self {
|
491 - | Self::IdempotentParameterMismatchError(_inner) => _inner.fmt(f),
|
492 - | Self::InternalServerError(_inner) => _inner.fmt(f),
|
493 - | Self::InvalidEndpointError(_inner) => _inner.fmt(f),
|
494 - | Self::ProvisionedThroughputExceededError(_inner) => _inner.fmt(f),
|
495 - | Self::RequestLimitExceeded(_inner) => _inner.fmt(f),
|
496 - | Self::ResourceNotFoundError(_inner) => _inner.fmt(f),
|
497 - | Self::TransactionCanceledError(_inner) => _inner.fmt(f),
|
498 - | Self::TransactionInProgressError(_inner) => _inner.fmt(f),
|
627 + | /* OperationErrorGenerator.kt:321 */
|
628 + | Self::IdempotentParameterMismatchError(_inner) =>
|
629 + | /* OperationErrorGenerator.kt:151 */
|
630 + | {
|
631 + | _inner.fmt(f)
|
632 + | }
|
633 + | ,
|
634 + | /* OperationErrorGenerator.kt:321 */
|
635 + | Self::InternalServerError(_inner) =>
|
636 + | /* OperationErrorGenerator.kt:151 */
|
637 + | {
|
638 + | _inner.fmt(f)
|
639 + | }
|
640 + | ,
|
641 + | /* OperationErrorGenerator.kt:321 */
|
642 + | Self::InvalidEndpointError(_inner) =>
|
643 + | /* OperationErrorGenerator.kt:151 */
|
644 + | {
|
645 + | _inner.fmt(f)
|
646 + | }
|
647 + | ,
|
648 + | /* OperationErrorGenerator.kt:321 */
|
649 + | Self::ProvisionedThroughputExceededError(_inner) =>
|
650 + | /* OperationErrorGenerator.kt:151 */
|
651 + | {
|
652 + | _inner.fmt(f)
|
653 + | }
|
654 + | ,
|
655 + | /* OperationErrorGenerator.kt:321 */
|
656 + | Self::RequestLimitExceeded(_inner) =>
|
657 + | /* OperationErrorGenerator.kt:151 */
|
658 + | {
|
659 + | _inner.fmt(f)
|
660 + | }
|
661 + | ,
|
662 + | /* OperationErrorGenerator.kt:321 */
|
663 + | Self::ResourceNotFoundError(_inner) =>
|
664 + | /* OperationErrorGenerator.kt:151 */
|
665 + | {
|
666 + | _inner.fmt(f)
|
667 + | }
|
668 + | ,
|
669 + | /* OperationErrorGenerator.kt:321 */
|
670 + | Self::TransactionCanceledError(_inner) =>
|
671 + | /* OperationErrorGenerator.kt:151 */
|
672 + | {
|
673 + | _inner.fmt(f)
|
674 + | }
|
675 + | ,
|
676 + | /* OperationErrorGenerator.kt:321 */
|
677 + | Self::TransactionInProgressError(_inner) =>
|
678 + | /* OperationErrorGenerator.kt:151 */
|
679 + | {
|
680 + | _inner.fmt(f)
|
681 + | }
|
682 + | ,
|
683 + | /* OperationErrorGenerator.kt:326 */
|
499 684 | Self::Unhandled(_inner) => {
|
685 + | /* OperationErrorGenerator.kt:139 */
|
500 686 | if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
|
501 687 | write!(f, "unhandled error ({code})")
|
502 688 | } else {
|
503 689 | f.write_str("unhandled error")
|
504 690 | }
|
691 + | /* OperationErrorGenerator.kt:326 */
|
692 + | } /* OperationErrorGenerator.kt:318 */
|
505 693 | }
|
694 + | /* OperationErrorGenerator.kt:134 */
|
506 695 | }
|
507 - | }
|
696 + | /* OperationErrorGenerator.kt:133 */
|
508 697 | }
|
698 + | /* OperationErrorGenerator.kt:182 */
|
509 699 | impl ::aws_smithy_types::retry::ProvideErrorKind for TransactWriteItemsError {
|
700 + | /* OperationErrorGenerator.kt:186 */
|
510 701 | fn code(&self) -> ::std::option::Option<&str> {
|
702 + | /* OperationErrorGenerator.kt:187 */
|
511 703 | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
|
704 + | /* OperationErrorGenerator.kt:186 */
|
512 705 | }
|
706 + | /* OperationErrorGenerator.kt:190 */
|
513 707 | fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
|
708 + | /* OperationErrorGenerator.kt:197 */
|
514 709 | ::std::option::Option::None
|
710 + | /* OperationErrorGenerator.kt:190 */
|
515 711 | }
|
712 + | /* OperationErrorGenerator.kt:182 */
|
516 713 | }
|
714 + | /* OperationErrorGenerator.kt:163 */
|
517 715 | impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for TransactWriteItemsError {
|
716 + | /* OperationErrorGenerator.kt:164 */
|
518 717 | fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
|
718 + | /* OperationErrorGenerator.kt:318 */
|
519 719 | match self {
|
520 - | Self::IdempotentParameterMismatchError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
521 - | Self::InternalServerError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
522 - | Self::InvalidEndpointError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
523 - | Self::ProvisionedThroughputExceededError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
524 - | Self::RequestLimitExceeded(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
525 - | Self::ResourceNotFoundError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
526 - | Self::TransactionCanceledError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
527 - | Self::TransactionInProgressError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
|
528 - | Self::Unhandled(_inner) => &_inner.meta,
|
720 + | /* OperationErrorGenerator.kt:321 */
|
721 + | Self::IdempotentParameterMismatchError(_inner) =>
|
722 + | /* OperationErrorGenerator.kt:169 */
|
723 + | {
|
724 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
725 + | }
|
726 + | ,
|
727 + | /* OperationErrorGenerator.kt:321 */
|
728 + | Self::InternalServerError(_inner) =>
|
729 + | /* OperationErrorGenerator.kt:169 */
|
730 + | {
|
731 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
732 + | }
|
733 + | ,
|
734 + | /* OperationErrorGenerator.kt:321 */
|
735 + | Self::InvalidEndpointError(_inner) =>
|
736 + | /* OperationErrorGenerator.kt:169 */
|
737 + | {
|
738 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
739 + | }
|
740 + | ,
|
741 + | /* OperationErrorGenerator.kt:321 */
|
742 + | Self::ProvisionedThroughputExceededError(_inner) =>
|
743 + | /* OperationErrorGenerator.kt:169 */
|
744 + | {
|
745 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
746 + | }
|
747 + | ,
|
748 + | /* OperationErrorGenerator.kt:321 */
|
749 + | Self::RequestLimitExceeded(_inner) =>
|
750 + | /* OperationErrorGenerator.kt:169 */
|
751 + | {
|
752 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
753 + | }
|
754 + | ,
|
755 + | /* OperationErrorGenerator.kt:321 */
|
756 + | Self::ResourceNotFoundError(_inner) =>
|
757 + | /* OperationErrorGenerator.kt:169 */
|
758 + | {
|
759 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
760 + | }
|
761 + | ,
|
762 + | /* OperationErrorGenerator.kt:321 */
|
763 + | Self::TransactionCanceledError(_inner) =>
|
764 + | /* OperationErrorGenerator.kt:169 */
|
765 + | {
|
766 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
767 + | }
|
768 + | ,
|
769 + | /* OperationErrorGenerator.kt:321 */
|
770 + | Self::TransactionInProgressError(_inner) =>
|
771 + | /* OperationErrorGenerator.kt:169 */
|
772 + | {
|
773 + | ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
|
774 + | }
|
775 + | ,
|
776 + | /* OperationErrorGenerator.kt:326 */
|
777 + | Self::Unhandled(_inner) => {
|
778 + | /* OperationErrorGenerator.kt:168 */
|
779 + | &_inner.meta
|
780 + | /* OperationErrorGenerator.kt:326 */
|
781 + | } /* OperationErrorGenerator.kt:318 */
|
529 782 | }
|
783 + | /* OperationErrorGenerator.kt:164 */
|
530 784 | }
|
785 + | /* OperationErrorGenerator.kt:163 */
|
531 786 | }
|
787 + | /* OperationErrorGenerator.kt:109 */
|
532 788 | impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for TransactWriteItemsError {
|
789 + | /* OperationErrorGenerator.kt:110 */
|
533 790 | fn create_unhandled_error(
|
534 791 | source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
|
535 792 | meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
|
536 793 | ) -> Self {
|
794 + | /* OperationErrorGenerator.kt:121 */
|
537 795 | Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
|
538 796 | source,
|
539 797 | meta: meta.unwrap_or_default(),
|
540 798 | })
|
799 + | /* OperationErrorGenerator.kt:110 */
|
541 800 | }
|
801 + | /* OperationErrorGenerator.kt:109 */
|
542 802 | }
|
543 803 |
|
804 + | /* CodegenDelegator.kt:255 */
|
544 805 | pub use crate::operation::transact_write_items::_transact_write_items_output::TransactWriteItemsOutput;
|
545 806 |
|
807 + | /* CodegenDelegator.kt:255 */
|
546 808 | pub use crate::operation::transact_write_items::_transact_write_items_input::TransactWriteItemsInput;
|
547 809 |
|
810 + | /* RustModule.kt:172 */
|
548 811 | mod _transact_write_items_input;
|
549 812 |
|
813 + | /* RustModule.kt:172 */
|
550 814 | mod _transact_write_items_output;
|
551 815 |
|
552 - | /// Builders
|
816 + | /// /* CodegenDelegator.kt:51 */Builders
|
553 817 | pub mod builders;
|