AWS SDK

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/describe_contributor_insights.rs

@@ -240,240 +301,328 @@

         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeContributorInsightsInput>()
             .ok_or("failed to downcast to DescribeContributorInsightsInput")?;
-247
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(

                 _input
                     .table_name
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("table_name", "A required field was not set"))?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-300
+    }
-301
+}
-302
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-305
 /// Error type for the `DescribeContributorInsightsError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeContributorInsightsError {
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     /// <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>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-317
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-319
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeContributorInsightsError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-322
+}
 impl DescribeContributorInsightsError {
     /// Creates the `DescribeContributorInsightsError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/describe_endpoints.rs

@@ -222,222 +283,310 @@

↥ Expand context

     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeEndpointsInput>()
             .ok_or("failed to downcast to DescribeEndpointsInput")?;
-236
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))

             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-282
+    }
-283
+}
-284
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-287
 /// Error type for the `DescribeEndpointsError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeEndpointsError {
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-295
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-297
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeEndpointsError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-300
+}
 impl DescribeEndpointsError {
     /// Creates the `DescribeEndpointsError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.into(),
             meta: ::std::default::Default::default(),
         })
-310
+    }

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/describe_export.rs

@@ -232,232 +293,320 @@

↥ Expand context

         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeExportInput>()
             .ok_or("failed to downcast to DescribeExportInput")?;
-239
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(

                 _input
                     .export_arn
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("export_arn", "A required field was not set"))?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-292
+    }
-293
+}
-294
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-297
 /// Error type for the `DescribeExportError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeExportError {
     /// <p>The specified export was not found.</p>
     ExportNotFoundException(crate::types::error::ExportNotFoundException),
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     /// <p>There is no limit to the number of daily on-demand backups that can be taken.</p>
     /// <p>For most purposes, up to 500 simultaneous table operations are allowed per account. These operations include <code>CreateTable</code>, <code>UpdateTable</code>, <code>DeleteTable</code>,<code>UpdateTimeToLive</code>, <code>RestoreTableFromBackup</code>, and <code>RestoreTableToPointInTime</code>.</p>
     /// <p>When you are creating a table with one or more secondary indexes, you can have up to 250 such requests running at a time. However, if the table or index specifications are complex, then DynamoDB might temporarily reduce the number of concurrent operations.</p>
     /// <p>When importing into DynamoDB, up to 50 simultaneous import table operations are allowed per account.</p>
     /// <p>There is a soft account quota of 2,500 tables.</p>
     /// <p>GetRecords was called with a value of more than 1000 for the limit request parameter.</p>
     /// <p>More than 2 processes are reading from the same streams shard at the same time. Exceeding this limit may result in request throttling.</p>
     LimitExceededException(crate::types::error::LimitExceededException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-317
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-319
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeExportError) for what information is available for the error.")]

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/describe_global_table.rs

@@ -236,236 +297,324 @@

↥ Expand context

     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeGlobalTableInput>()
             .ok_or("failed to downcast to DescribeGlobalTableInput")?;
-241
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(
                 _input
                     .global_table_name

                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| {
                         ::aws_smithy_types::error::operation::BuildError::missing_field("global_table_name", "A required field was not set")
                     })?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-296
+    }
-297
+}
-298
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-301
 /// Error type for the `DescribeGlobalTableError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeGlobalTableError {
     /// <p>The specified global table does not exist.</p>
     GlobalTableNotFoundException(crate::types::error::GlobalTableNotFoundException),
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     #[allow(missing_docs)] // documentation missing in model
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-315
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-317
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeGlobalTableError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-320
+}
 impl DescribeGlobalTableError {
     /// Creates the `DescribeGlobalTableError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/describe_global_table_settings.rs

@@ -242,242 +303,330 @@

↥ Expand context

     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeGlobalTableSettingsInput>()
             .ok_or("failed to downcast to DescribeGlobalTableSettingsInput")?;
-247
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(
                 _input
                     .global_table_name

                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| {
                         ::aws_smithy_types::error::operation::BuildError::missing_field("global_table_name", "A required field was not set")
                     })?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-302
+    }
-303
+}
-304
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-307
 /// Error type for the `DescribeGlobalTableSettingsError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeGlobalTableSettingsError {
     /// <p>The specified global table does not exist.</p>
     GlobalTableNotFoundException(crate::types::error::GlobalTableNotFoundException),
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     #[allow(missing_docs)] // documentation missing in model
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-321
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-323
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeGlobalTableSettingsError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-326
+}
 impl DescribeGlobalTableSettingsError {
     /// Creates the `DescribeGlobalTableSettingsError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/describe_import.rs

@@ -232,232 +293,320 @@

↥ Expand context

         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeImportInput>()
             .ok_or("failed to downcast to DescribeImportInput")?;
-239
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(

                 _input
                     .import_arn
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("import_arn", "A required field was not set"))?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-292
+    }
-293
+}
-294
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-297
 /// Error type for the `DescribeImportError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeImportError {
     /// <p>The specified import was not found.</p>
     ImportNotFoundException(crate::types::error::ImportNotFoundException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-307
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-309
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeImportError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-312
+}
 impl DescribeImportError {
     /// Creates the `DescribeImportError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.into(),
             meta: ::std::default::Default::default(),

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/describe_kinesis_streaming_destination.rs

@@ -244,244 +305,332 @@

↥ Expand context

         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeKinesisStreamingDestinationInput>()
             .ok_or("failed to downcast to DescribeKinesisStreamingDestinationInput")?;
-251
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(

                 _input
                     .table_name
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("table_name", "A required field was not set"))?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-304
+    }
-305
+}
-306
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-309
 /// Error type for the `DescribeKinesisStreamingDestinationError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeKinesisStreamingDestinationError {
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     #[allow(missing_docs)] // documentation missing in model
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <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>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-323
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-325
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeKinesisStreamingDestinationError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-328
+}
 impl DescribeKinesisStreamingDestinationError {
     /// Creates the `DescribeKinesisStreamingDestinationError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/describe_limits.rs

@@ -222,222 +283,310 @@

↥ Expand context

     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeLimitsInput>()
             .ok_or("failed to downcast to DescribeLimitsInput")?;
-236
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))

             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-282
+    }
-283
+}
-284
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-287
 /// Error type for the `DescribeLimitsError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeLimitsError {
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     #[allow(missing_docs)] // documentation missing in model
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-299
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-301
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeLimitsError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-304
+}
 impl DescribeLimitsError {
     /// Creates the `DescribeLimitsError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/describe_table.rs

@@ -229,229 +290,317 @@

↥ Expand context

         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeTableInput>()
             .ok_or("failed to downcast to DescribeTableInput")?;
-236
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(

                 _input
                     .table_name
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("table_name", "A required field was not set"))?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-289
+    }
-290
+}
-291
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-294
 /// Error type for the `DescribeTableError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeTableError {
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     #[allow(missing_docs)] // documentation missing in model
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <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>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-308
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-310
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeTableError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-313
+}
 impl DescribeTableError {
     /// Creates the `DescribeTableError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/describe_table_replica_auto_scaling.rs

@@ -242,242 +303,330 @@

↥ Expand context

         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeTableReplicaAutoScalingInput>()
             .ok_or("failed to downcast to DescribeTableReplicaAutoScalingInput")?;
-249
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(

                 _input
                     .table_name
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("table_name", "A required field was not set"))?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-302
+    }
-303
+}
-304
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-307
 /// Error type for the `DescribeTableReplicaAutoScalingError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeTableReplicaAutoScalingError {
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     /// <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>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-319
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-321
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeTableReplicaAutoScalingError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-324
+}
 impl DescribeTableReplicaAutoScalingError {
     /// Creates the `DescribeTableReplicaAutoScalingError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/describe_time_to_live.rs

@@ -234,234 +295,322 @@

↥ Expand context

         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeTimeToLiveInput>()
             .ok_or("failed to downcast to DescribeTimeToLiveInput")?;
-241
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(

                 _input
                     .table_name
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("table_name", "A required field was not set"))?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-294
+    }
-295
+}
-296
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-299
 /// Error type for the `DescribeTimeToLiveError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeTimeToLiveError {
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     #[allow(missing_docs)] // documentation missing in model
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <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>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-313
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-315
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeTimeToLiveError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-318
+}
 impl DescribeTimeToLiveError {
     /// Creates the `DescribeTimeToLiveError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/disable_kinesis_streaming_destination.rs

@@ -244,244 +305,332 @@

↥ Expand context

         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DisableKinesisStreamingDestinationInput>()
             .ok_or("failed to downcast to DisableKinesisStreamingDestinationInput")?;
-251
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(

                 _input
                     .table_name
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("table_name", "A required field was not set"))?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-304
+    }
-305
+}
-306
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-309
 /// Error type for the `DisableKinesisStreamingDestinationError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DisableKinesisStreamingDestinationError {
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     #[allow(missing_docs)] // documentation missing in model
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>There is no limit to the number of daily on-demand backups that can be taken.</p>
     /// <p>For most purposes, up to 500 simultaneous table operations are allowed per account. These operations include <code>CreateTable</code>, <code>UpdateTable</code>, <code>DeleteTable</code>,<code>UpdateTimeToLive</code>, <code>RestoreTableFromBackup</code>, and <code>RestoreTableToPointInTime</code>.</p>
     /// <p>When you are creating a table with one or more secondary indexes, you can have up to 250 such requests running at a time. However, if the table or index specifications are complex, then DynamoDB might temporarily reduce the number of concurrent operations.</p>
     /// <p>When importing into DynamoDB, up to 50 simultaneous import table operations are allowed per account.</p>
     /// <p>There is a soft account quota of 2,500 tables.</p>
     /// <p>GetRecords was called with a value of more than 1000 for the limit request parameter.</p>
     /// <p>More than 2 processes are reading from the same streams shard at the same time. Exceeding this limit may result in request throttling.</p>
     LimitExceededException(crate::types::error::LimitExceededException),
     /// <p>The operation conflicts with the resource's availability. For example:</p>
     /// <ul>
     /// <li>
     /// <p>You attempted to recreate an existing table.</p></li>
     /// <li>
     /// <p>You tried to delete a table currently in the <code>CREATING</code> state.</p></li>
     /// <li>

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/enable_kinesis_streaming_destination.rs

@@ -244,244 +305,332 @@

↥ Expand context

         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<EnableKinesisStreamingDestinationInput>()
             .ok_or("failed to downcast to EnableKinesisStreamingDestinationInput")?;
-251
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(

                 _input
                     .table_name
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("table_name", "A required field was not set"))?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-304
+    }
-305
+}
-306
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-309
 /// Error type for the `EnableKinesisStreamingDestinationError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum EnableKinesisStreamingDestinationError {
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     #[allow(missing_docs)] // documentation missing in model
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>There is no limit to the number of daily on-demand backups that can be taken.</p>
     /// <p>For most purposes, up to 500 simultaneous table operations are allowed per account. These operations include <code>CreateTable</code>, <code>UpdateTable</code>, <code>DeleteTable</code>,<code>UpdateTimeToLive</code>, <code>RestoreTableFromBackup</code>, and <code>RestoreTableToPointInTime</code>.</p>
     /// <p>When you are creating a table with one or more secondary indexes, you can have up to 250 such requests running at a time. However, if the table or index specifications are complex, then DynamoDB might temporarily reduce the number of concurrent operations.</p>
     /// <p>When importing into DynamoDB, up to 50 simultaneous import table operations are allowed per account.</p>
     /// <p>There is a soft account quota of 2,500 tables.</p>
     /// <p>GetRecords was called with a value of more than 1000 for the limit request parameter.</p>
     /// <p>More than 2 processes are reading from the same streams shard at the same time. Exceeding this limit may result in request throttling.</p>
     LimitExceededException(crate::types::error::LimitExceededException),
     /// <p>The operation conflicts with the resource's availability. For example:</p>
     /// <ul>
     /// <li>
     /// <p>You attempted to recreate an existing table.</p></li>
     /// <li>
     /// <p>You tried to delete a table currently in the <code>CREATING</code> state.</p></li>
     /// <li>

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/execute_statement.rs

@@ -225,225 +286,313 @@

↥ Expand context

     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<ExecuteStatementInput>()
             .ok_or("failed to downcast to ExecuteStatementInput")?;
-239
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))

             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-285
+    }
-286
+}
-287
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-290
 /// Error type for the `ExecuteStatementError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum ExecuteStatementError {
     /// <p>A condition specified in the operation failed to be evaluated.</p>
     ConditionalCheckFailedException(crate::types::error::ConditionalCheckFailedException),
     /// <p>There was an attempt to insert an item with the same primary key as an item that already exists in the DynamoDB table.</p>
     DuplicateItemException(crate::types::error::DuplicateItemException),
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     /// <p>An item collection is too large. This exception is only returned for tables that have one or more local secondary indexes.</p>
     ItemCollectionSizeLimitExceededException(crate::types::error::ItemCollectionSizeLimitExceededException),
     /// <p>Your request rate is too high. The Amazon Web Services 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>
     ProvisionedThroughputExceededException(crate::types::error::ProvisionedThroughputExceededException),
     /// <p>Throughput exceeds the current throughput quota for your account. Please contact <a href="https://aws.amazon.com/support">Amazon Web ServicesSupport</a> to request a quota increase.</p>
     RequestLimitExceeded(crate::types::error::RequestLimitExceeded),
     /// <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>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>Operation was rejected because there is an ongoing transaction for the item.</p>
     TransactionConflictException(crate::types::error::TransactionConflictException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/execute_transaction.rs

@@ -232,232 +293,320 @@

↥ Expand context

     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<ExecuteTransactionInput>()
             .ok_or("failed to downcast to ExecuteTransactionInput")?;
-246
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))

             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-292
+    }
-293
+}
-294
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-297
 /// Error type for the `ExecuteTransactionError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum ExecuteTransactionError {
     /// <p>DynamoDB rejected the request because you retried a request with a different payload but with an idempotent token that was already used.</p>
     IdempotentParameterMismatchException(crate::types::error::IdempotentParameterMismatchException),
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     /// <p>Your request rate is too high. The Amazon Web Services 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>
     ProvisionedThroughputExceededException(crate::types::error::ProvisionedThroughputExceededException),
     /// <p>Throughput exceeds the current throughput quota for your account. Please contact <a href="https://aws.amazon.com/support">Amazon Web ServicesSupport</a> to request a quota increase.</p>
     RequestLimitExceeded(crate::types::error::RequestLimitExceeded),
     /// <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>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>The entire transaction request was canceled.</p>
     /// <p>DynamoDB cancels a <code>TransactWriteItems</code> request under the following circumstances:</p>
     /// <ul>
     /// <li>
     /// <p>A condition in one of the condition expressions is not met.</p></li>
     /// <li>
     /// <p>A table in the <code>TransactWriteItems</code> request is in a different account or region.</p></li>
     /// <li>
     /// <p>More than one action in the <code>TransactWriteItems</code> operation targets the same item.</p></li>

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/operation/export_table_to_point_in_time.rs

@@ -242,242 +303,330 @@

↥ Expand context

         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<ExportTableToPointInTimeInput>()
             .ok_or("failed to downcast to ExportTableToPointInTimeInput")?;
-249
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_account_id_endpoint_mode(::std::option::Option::Some(
                 cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
                     .cloned()
                     .unwrap_or_default()
                     .to_string(),
             ))
             .set_resource_arn(Some(

                 _input
                     .table_arn
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("table_arn", "A required field was not set"))?,
             ))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         match cfg
             .load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
             .cloned()
             .unwrap_or_default()
-+
+        {
             ::aws_types::endpoint_config::AccountIdEndpointMode::Preferred => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModePreferred);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Required => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeRequired);
-+
+            }
             ::aws_types::endpoint_config::AccountIdEndpointMode::Disabled => {
                 cfg.interceptor_state()
                     .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::AccountIdModeDisabled);
-+
+            }
             otherwise => {
                 ::tracing::warn!(
                     "Attempted to track an SDK feature for `{otherwise:?}`, which is not recognized in the current version of the SDK. \
                                             Consider upgrading to the latest version to ensure that it is properly tracked."
                 );
-+
+            }
-+
+        }
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-302
+    }
-303
+}
-304
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-307
 /// Error type for the `ExportTableToPointInTimeError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum ExportTableToPointInTimeError {
     /// <p>There was a conflict when writing to the specified S3 bucket.</p>
     ExportConflictException(crate::types::error::ExportConflictException),
     /// <p>An error occurred on the server side.</p>
     InternalServerError(crate::types::error::InternalServerError),
     /// <p>The specified <code>ExportTime</code> is outside of the point in time recovery window.</p>
     InvalidExportTimeException(crate::types::error::InvalidExportTimeException),
     /// <p>There is no limit to the number of daily on-demand backups that can be taken.</p>
     /// <p>For most purposes, up to 500 simultaneous table operations are allowed per account. These operations include <code>CreateTable</code>, <code>UpdateTable</code>, <code>DeleteTable</code>,<code>UpdateTimeToLive</code>, <code>RestoreTableFromBackup</code>, and <code>RestoreTableToPointInTime</code>.</p>
     /// <p>When you are creating a table with one or more secondary indexes, you can have up to 250 such requests running at a time. However, if the table or index specifications are complex, then DynamoDB might temporarily reduce the number of concurrent operations.</p>
     /// <p>When importing into DynamoDB, up to 50 simultaneous import table operations are allowed per account.</p>
     /// <p>There is a soft account quota of 2,500 tables.</p>
     /// <p>GetRecords was called with a value of more than 1000 for the limit request parameter.</p>
     /// <p>More than 2 processes are reading from the same streams shard at the same time. Exceeding this limit may result in request throttling.</p>
     LimitExceededException(crate::types::error::LimitExceededException),
     /// <p>Point in time recovery has not yet been enabled for this source table.</p>
     PointInTimeRecoveryUnavailableException(crate::types::error::PointInTimeRecoveryUnavailableException),
     /// <p>A source table with the name <code>TableName</code> does not currently exist within the subscriber's account or the subscriber is operating in the wrong Amazon Web Services Region.</p>
     TableNotFoundException(crate::types::error::TableNotFoundException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).

AWS SDK

Files changed: