Client Test

Client Test

rev. dfb5149b65b7bcc09edd15b8e071ad43b5ac5943

Files changed:

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/enable_kinesis_streaming_destination/builders.rs

@@ -1,1 +139,157 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* CodegenDelegator.kt:255 */
    2      3   
pub use crate::operation::enable_kinesis_streaming_destination::_enable_kinesis_streaming_destination_output::EnableKinesisStreamingDestinationOutputBuilder;
    3      4   
           5  +
/* CodegenDelegator.kt:255 */
    4      6   
pub use crate::operation::enable_kinesis_streaming_destination::_enable_kinesis_streaming_destination_input::EnableKinesisStreamingDestinationInputBuilder;
    5      7   
           8  +
/* FluentBuilderGenerator.kt:408 */
    6      9   
impl crate::operation::enable_kinesis_streaming_destination::builders::EnableKinesisStreamingDestinationInputBuilder {
    7     10   
    /// Sends a request with this input using the given client.
    8     11   
    pub async fn send_with(
    9     12   
        self,
   10     13   
        client: &crate::Client,
   11     14   
    ) -> ::std::result::Result<
   12     15   
        crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput,
   13     16   
        ::aws_smithy_runtime_api::client::result::SdkError<
   14     17   
            crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError,
   15     18   
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
   16     19   
        >,
   17     20   
    > {
   18     21   
        let mut fluent_builder = client.enable_kinesis_streaming_destination();
   19     22   
        fluent_builder.inner = self;
   20     23   
        fluent_builder.send().await
   21     24   
    }
   22     25   
}
   23         -
/// Fluent builder constructing a request to `EnableKinesisStreamingDestination`.
          26  +
/// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `EnableKinesisStreamingDestination`.
   24     27   
///
   25         -
/// <p>Starts table data replication to the specified Kinesis data stream at a timestamp chosen during the enable workflow. If this operation doesn't return results immediately, use DescribeKinesisStreamingDestination to check if streaming to the Kinesis data stream is ACTIVE.</p>
          28  +
/// /* FluentBuilderGenerator.kt:130 */<p>Starts table data replication to the specified Kinesis data stream at a timestamp chosen during the enable workflow. If this operation doesn't return results immediately, use DescribeKinesisStreamingDestination to check if streaming to the Kinesis data stream is ACTIVE.</p>
          29  +
/* RustType.kt:516 */
   26     30   
#[derive(::std::clone::Clone, ::std::fmt::Debug)]
          31  +
/* FluentBuilderGenerator.kt:270 */
   27     32   
pub struct EnableKinesisStreamingDestinationFluentBuilder {
   28     33   
    handle: ::std::sync::Arc<crate::client::Handle>,
   29     34   
    inner: crate::operation::enable_kinesis_streaming_destination::builders::EnableKinesisStreamingDestinationInputBuilder,
   30     35   
    config_override: ::std::option::Option<crate::config::Builder>,
   31     36   
}
          37  +
/* FluentBuilderGenerator.kt:381 */
   32     38   
impl
   33     39   
    crate::client::customize::internal::CustomizableSend<
   34     40   
        crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput,
   35     41   
        crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError,
   36     42   
    > for EnableKinesisStreamingDestinationFluentBuilder
   37     43   
{
   38     44   
    fn send(
   39     45   
        self,
   40     46   
        config_override: crate::config::Builder,
   41     47   
    ) -> crate::client::customize::internal::BoxFuture<
   42     48   
        crate::client::customize::internal::SendResult<
   43     49   
            crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput,
   44     50   
            crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError,
   45     51   
        >,
   46     52   
    > {
   47     53   
        ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
   48     54   
    }
   49     55   
}
          56  +
/* FluentBuilderGenerator.kt:282 */
   50     57   
impl EnableKinesisStreamingDestinationFluentBuilder {
          58  +
    /* FluentBuilderGenerator.kt:288 */
   51     59   
    /// Creates a new `EnableKinesisStreamingDestinationFluentBuilder`.
   52     60   
    pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
   53     61   
        Self {
   54     62   
            handle,
   55     63   
            inner: ::std::default::Default::default(),
   56     64   
            config_override: ::std::option::Option::None,
   57     65   
        }
   58     66   
    }
          67  +
    /* FluentBuilderGenerator.kt:301 */
   59     68   
    /// Access the EnableKinesisStreamingDestination as a reference.
   60     69   
    pub fn as_input(&self) -> &crate::operation::enable_kinesis_streaming_destination::builders::EnableKinesisStreamingDestinationInputBuilder {
   61     70   
        &self.inner
   62     71   
    }
          72  +
    /* FluentBuilderGenerator.kt:145 */
   63     73   
    /// Sends the request and returns the response.
   64     74   
    ///
   65     75   
    /// If an error occurs, an `SdkError` will be returned with additional details that
   66     76   
    /// can be matched against.
   67     77   
    ///
   68     78   
    /// By default, any retryable failures will be retried twice. Retry behavior
   69     79   
    /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
   70     80   
    /// set when configuring the client.
   71     81   
    pub async fn send(
   72     82   
        self,
   73     83   
    ) -> ::std::result::Result<
   74     84   
        crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput,
   75     85   
        ::aws_smithy_runtime_api::client::result::SdkError<
   76     86   
            crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError,
   77     87   
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
   78     88   
        >,
   79     89   
    > {
   80     90   
        let input = self
   81     91   
            .inner
   82     92   
            .build()
   83     93   
            .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
   84     94   
        let runtime_plugins = crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestination::operation_runtime_plugins(
   85     95   
            self.handle.runtime_plugins.clone(),
   86     96   
            &self.handle.conf,
   87     97   
            self.config_override,
   88     98   
        );
   89     99   
        crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestination::orchestrate(&runtime_plugins, input).await
   90    100   
    }
   91    101   
   92    102   
    /// Consumes this builder, creating a customizable operation that can be modified before being sent.
   93    103   
    pub fn customize(
   94    104   
        self,
   95    105   
    ) -> crate::client::customize::CustomizableOperation<
   96    106   
        crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput,
   97    107   
        crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError,
   98    108   
        Self,
   99    109   
    > {
  100    110   
        crate::client::customize::CustomizableOperation::new(self)
  101    111   
    }
         112  +
    /* FluentBuilderGenerator.kt:315 */
  102    113   
    pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
  103    114   
        self.set_config_override(::std::option::Option::Some(config_override.into()));
  104    115   
        self
  105    116   
    }
  106    117   
  107    118   
    pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
  108    119   
        self.config_override = config_override;
  109    120   
        self
  110    121   
    }
  111         -
    /// <p>The name of the DynamoDB table.</p>
         122  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The name of the DynamoDB table.</p>
         123  +
    /* FluentBuilderGenerator.kt:500 */
  112    124   
    pub fn table_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
  113    125   
        self.inner = self.inner.table_name(input.into());
  114    126   
        self
  115    127   
    }
  116         -
    /// <p>The name of the DynamoDB table.</p>
         128  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The name of the DynamoDB table.</p>
         129  +
    /* FluentBuilderGenerator.kt:500 */
  117    130   
    pub fn set_table_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
  118    131   
        self.inner = self.inner.set_table_name(input);
  119    132   
        self
  120    133   
    }
  121         -
    /// <p>The name of the DynamoDB table.</p>
         134  +
    /// /* FluentBuilderGenerator.kt:518 */<p>The name of the DynamoDB table.</p>
         135  +
    /* FluentBuilderGenerator.kt:520 */
  122    136   
    pub fn get_table_name(&self) -> &::std::option::Option<::std::string::String> {
  123    137   
        self.inner.get_table_name()
  124    138   
    }
  125         -
    /// <p>The ARN for a Kinesis data stream.</p>
         139  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The ARN for a Kinesis data stream.</p>
         140  +
    /* FluentBuilderGenerator.kt:500 */
  126    141   
    pub fn stream_arn(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
  127    142   
        self.inner = self.inner.stream_arn(input.into());
  128    143   
        self
  129    144   
    }
  130         -
    /// <p>The ARN for a Kinesis data stream.</p>
         145  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The ARN for a Kinesis data stream.</p>
         146  +
    /* FluentBuilderGenerator.kt:500 */
  131    147   
    pub fn set_stream_arn(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
  132    148   
        self.inner = self.inner.set_stream_arn(input);
  133    149   
        self
  134    150   
    }
  135         -
    /// <p>The ARN for a Kinesis data stream.</p>
         151  +
    /// /* FluentBuilderGenerator.kt:518 */<p>The ARN for a Kinesis data stream.</p>
         152  +
    /* FluentBuilderGenerator.kt:520 */
  136    153   
    pub fn get_stream_arn(&self) -> &::std::option::Option<::std::string::String> {
  137    154   
        self.inner.get_stream_arn()
  138    155   
    }
         156  +
    /* FluentBuilderGenerator.kt:282 */
  139    157   
}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/execute_statement.rs

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

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/execute_statement/_execute_statement_input.rs

@@ -1,1 +126,209 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* StructureGenerator.kt:197 */
    2      3   
#[allow(missing_docs)] // documentation missing in model
           4  +
/* RustType.kt:516 */
    3      5   
#[non_exhaustive]
           6  +
/* RustType.kt:516 */
    4      7   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
    5         -
pub struct ExecuteStatementInput {
    6         -
    /// <p>The PartiQL statement representing the operation to run.</p>
           8  +
pub /* StructureGenerator.kt:201 */ struct ExecuteStatementInput {
           9  +
    /// /* StructureGenerator.kt:231 */<p>The PartiQL statement representing the operation to run.</p>
    7     10   
    pub statement: ::std::option::Option<::std::string::String>,
    8         -
    /// <p>The parameters for the PartiQL statement, if any.</p>
          11  +
    /// /* StructureGenerator.kt:231 */<p>The parameters for the PartiQL statement, if any.</p>
    9     12   
    pub parameters: ::std::option::Option<::std::vec::Vec<crate::types::AttributeValue>>,
   10         -
    /// <p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
          13  +
    /// /* StructureGenerator.kt:231 */<p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
   11     14   
    pub consistent_read: ::std::option::Option<bool>,
   12         -
    /// <p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
          15  +
    /// /* StructureGenerator.kt:231 */<p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
   13     16   
    pub next_token: ::std::option::Option<::std::string::String>,
          17  +
    /* StructureGenerator.kt:201 */
   14     18   
}
          19  +
/* StructureGenerator.kt:135 */
   15     20   
impl ExecuteStatementInput {
   16         -
    /// <p>The PartiQL statement representing the operation to run.</p>
          21  +
    /// /* StructureGenerator.kt:231 */<p>The PartiQL statement representing the operation to run.</p>
          22  +
    /* StructureGenerator.kt:166 */
   17     23   
    pub fn statement(&self) -> ::std::option::Option<&str> {
          24  +
        /* StructureGenerator.kt:169 */
   18     25   
        self.statement.as_deref()
          26  +
        /* StructureGenerator.kt:166 */
   19     27   
    }
   20         -
    /// <p>The parameters for the PartiQL statement, if any.</p>
   21         -
    ///
   22         -
    /// If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use `.parameters.is_none()`.
          28  +
    /// /* StructureGenerator.kt:231 */<p>The parameters for the PartiQL statement, if any.</p>
          29  +
    /// /* StructureGenerator.kt:162 */
          30  +
    /// /* StructureGenerator.kt:163 */If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use `.parameters.is_none()`.
          31  +
    /* StructureGenerator.kt:166 */
   23     32   
    pub fn parameters(&self) -> &[crate::types::AttributeValue] {
   24         -
        self.parameters.as_deref().unwrap_or_default()
   25         -
    }
   26         -
    /// <p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
          33  +
        /* StructureGenerator.kt:169 */
          34  +
        self.parameters
          35  +
            .as_deref()
          36  +
            /* StructureGenerator.kt:175 */
          37  +
            .unwrap_or_default()
          38  +
        /* StructureGenerator.kt:166 */
          39  +
    }
          40  +
    /// /* StructureGenerator.kt:231 */<p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
          41  +
    /* StructureGenerator.kt:166 */
   27     42   
    pub fn consistent_read(&self) -> ::std::option::Option<bool> {
          43  +
        /* StructureGenerator.kt:168 */
   28     44   
        self.consistent_read
          45  +
        /* StructureGenerator.kt:166 */
   29     46   
    }
   30         -
    /// <p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
          47  +
    /// /* StructureGenerator.kt:231 */<p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
          48  +
    /* StructureGenerator.kt:166 */
   31     49   
    pub fn next_token(&self) -> ::std::option::Option<&str> {
          50  +
        /* StructureGenerator.kt:169 */
   32     51   
        self.next_token.as_deref()
          52  +
        /* StructureGenerator.kt:166 */
   33     53   
    }
          54  +
    /* StructureGenerator.kt:135 */
   34     55   
}
          56  +
/* ClientCodegenVisitor.kt:237 */
   35     57   
impl ExecuteStatementInput {
   36         -
    /// Creates a new builder-style object to manufacture [`ExecuteStatementInput`](crate::operation::execute_statement::ExecuteStatementInput).
          58  +
    /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`ExecuteStatementInput`](crate::operation::execute_statement::ExecuteStatementInput).
          59  +
    /* BuilderGenerator.kt:175 */
   37     60   
    pub fn builder() -> crate::operation::execute_statement::builders::ExecuteStatementInputBuilder {
          61  +
        /* BuilderGenerator.kt:176 */
   38     62   
        crate::operation::execute_statement::builders::ExecuteStatementInputBuilder::default()
          63  +
        /* BuilderGenerator.kt:175 */
   39     64   
    }
          65  +
    /* ClientCodegenVisitor.kt:237 */
   40     66   
}
   41     67   
   42         -
/// A builder for [`ExecuteStatementInput`](crate::operation::execute_statement::ExecuteStatementInput).
          68  +
/// /* BuilderGenerator.kt:342 */A builder for [`ExecuteStatementInput`](crate::operation::execute_statement::ExecuteStatementInput).
          69  +
/* RustType.kt:516 */
   43     70   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
          71  +
/* RustType.kt:516 */
   44     72   
#[non_exhaustive]
          73  +
/* BuilderGenerator.kt:345 */
   45     74   
pub struct ExecuteStatementInputBuilder {
   46         -
    pub(crate) statement: ::std::option::Option<::std::string::String>,
   47         -
    pub(crate) parameters: ::std::option::Option<::std::vec::Vec<crate::types::AttributeValue>>,
   48         -
    pub(crate) consistent_read: ::std::option::Option<bool>,
   49         -
    pub(crate) next_token: ::std::option::Option<::std::string::String>,
          75  +
    /* BuilderGenerator.kt:275 */ pub(crate) statement: ::std::option::Option<::std::string::String>,
          76  +
    /* BuilderGenerator.kt:275 */ pub(crate) parameters: ::std::option::Option<::std::vec::Vec<crate::types::AttributeValue>>,
          77  +
    /* BuilderGenerator.kt:275 */ pub(crate) consistent_read: ::std::option::Option<bool>,
          78  +
    /* BuilderGenerator.kt:275 */ pub(crate) next_token: ::std::option::Option<::std::string::String>,
          79  +
    /* BuilderGenerator.kt:345 */
   50     80   
}
          81  +
/* BuilderGenerator.kt:355 */
   51     82   
impl ExecuteStatementInputBuilder {
   52         -
    /// <p>The PartiQL statement representing the operation to run.</p>
   53         -
    /// This field is required.
          83  +
    /// /* BuilderGenerator.kt:286 */<p>The PartiQL statement representing the operation to run.</p>
          84  +
    /// /* BuilderGenerator.kt:288 */This field is required.
          85  +
    /* BuilderGenerator.kt:291 */
   54     86   
    pub fn statement(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
          87  +
        /* BuilderGenerator.kt:292 */
   55     88   
        self.statement = ::std::option::Option::Some(input.into());
          89  +
        /* BuilderGenerator.kt:293 */
   56     90   
        self
          91  +
        /* BuilderGenerator.kt:291 */
   57     92   
    }
   58         -
    /// <p>The PartiQL statement representing the operation to run.</p>
          93  +
    /// /* BuilderGenerator.kt:312 */<p>The PartiQL statement representing the operation to run.</p>
          94  +
    /* BuilderGenerator.kt:314 */
   59     95   
    pub fn set_statement(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
          96  +
        /* BuilderGenerator.kt:315 */
   60     97   
        self.statement = input;
   61     98   
        self
          99  +
        /* BuilderGenerator.kt:314 */
   62    100   
    }
   63         -
    /// <p>The PartiQL statement representing the operation to run.</p>
         101  +
    /// /* BuilderGenerator.kt:334 */<p>The PartiQL statement representing the operation to run.</p>
         102  +
    /* BuilderGenerator.kt:336 */
   64    103   
    pub fn get_statement(&self) -> &::std::option::Option<::std::string::String> {
         104  +
        /* BuilderGenerator.kt:337 */
   65    105   
        &self.statement
         106  +
        /* BuilderGenerator.kt:336 */
   66    107   
    }
   67         -
    /// Appends an item to `parameters`.
         108  +
    /// /* BuilderGenerator.kt:410 */Appends an item to `parameters`.
         109  +
    /* BuilderGenerator.kt:411 */
   68    110   
    ///
   69         -
    /// To override the contents of this collection use [`set_parameters`](Self::set_parameters).
         111  +
    /// /* BuilderGenerator.kt:412 */To override the contents of this collection use [`set_parameters`](Self::set_parameters).
         112  +
    /* BuilderGenerator.kt:413 */
   70    113   
    ///
   71         -
    /// <p>The parameters for the PartiQL statement, if any.</p>
         114  +
    /// /* BuilderGenerator.kt:414 */<p>The parameters for the PartiQL statement, if any.</p>
         115  +
    /* BuilderGenerator.kt:418 */
   72    116   
    pub fn parameters(mut self, input: crate::types::AttributeValue) -> Self {
         117  +
        /* BuilderGenerator.kt:419 */
   73    118   
        let mut v = self.parameters.unwrap_or_default();
   74    119   
        v.push(input);
   75    120   
        self.parameters = ::std::option::Option::Some(v);
   76    121   
        self
         122  +
        /* BuilderGenerator.kt:418 */
   77    123   
    }
   78         -
    /// <p>The parameters for the PartiQL statement, if any.</p>
         124  +
    /// /* BuilderGenerator.kt:312 */<p>The parameters for the PartiQL statement, if any.</p>
         125  +
    /* BuilderGenerator.kt:314 */
   79    126   
    pub fn set_parameters(mut self, input: ::std::option::Option<::std::vec::Vec<crate::types::AttributeValue>>) -> Self {
         127  +
        /* BuilderGenerator.kt:315 */
   80    128   
        self.parameters = input;
   81    129   
        self
         130  +
        /* BuilderGenerator.kt:314 */
   82    131   
    }
   83         -
    /// <p>The parameters for the PartiQL statement, if any.</p>
         132  +
    /// /* BuilderGenerator.kt:334 */<p>The parameters for the PartiQL statement, if any.</p>
         133  +
    /* BuilderGenerator.kt:336 */
   84    134   
    pub fn get_parameters(&self) -> &::std::option::Option<::std::vec::Vec<crate::types::AttributeValue>> {
         135  +
        /* BuilderGenerator.kt:337 */
   85    136   
        &self.parameters
         137  +
        /* BuilderGenerator.kt:336 */
   86    138   
    }
   87         -
    /// <p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         139  +
    /// /* BuilderGenerator.kt:286 */<p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         140  +
    /* BuilderGenerator.kt:291 */
   88    141   
    pub fn consistent_read(mut self, input: bool) -> Self {
         142  +
        /* BuilderGenerator.kt:292 */
   89    143   
        self.consistent_read = ::std::option::Option::Some(input);
         144  +
        /* BuilderGenerator.kt:293 */
   90    145   
        self
         146  +
        /* BuilderGenerator.kt:291 */
   91    147   
    }
   92         -
    /// <p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         148  +
    /// /* BuilderGenerator.kt:312 */<p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         149  +
    /* BuilderGenerator.kt:314 */
   93    150   
    pub fn set_consistent_read(mut self, input: ::std::option::Option<bool>) -> Self {
         151  +
        /* BuilderGenerator.kt:315 */
   94    152   
        self.consistent_read = input;
   95    153   
        self
         154  +
        /* BuilderGenerator.kt:314 */
   96    155   
    }
   97         -
    /// <p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         156  +
    /// /* BuilderGenerator.kt:334 */<p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         157  +
    /* BuilderGenerator.kt:336 */
   98    158   
    pub fn get_consistent_read(&self) -> &::std::option::Option<bool> {
         159  +
        /* BuilderGenerator.kt:337 */
   99    160   
        &self.consistent_read
         161  +
        /* BuilderGenerator.kt:336 */
  100    162   
    }
  101         -
    /// <p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         163  +
    /// /* BuilderGenerator.kt:286 */<p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         164  +
    /* BuilderGenerator.kt:291 */
  102    165   
    pub fn next_token(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         166  +
        /* BuilderGenerator.kt:292 */
  103    167   
        self.next_token = ::std::option::Option::Some(input.into());
         168  +
        /* BuilderGenerator.kt:293 */
  104    169   
        self
         170  +
        /* BuilderGenerator.kt:291 */
  105    171   
    }
  106         -
    /// <p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         172  +
    /// /* BuilderGenerator.kt:312 */<p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         173  +
    /* BuilderGenerator.kt:314 */
  107    174   
    pub fn set_next_token(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         175  +
        /* BuilderGenerator.kt:315 */
  108    176   
        self.next_token = input;
  109    177   
        self
         178  +
        /* BuilderGenerator.kt:314 */
  110    179   
    }
  111         -
    /// <p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         180  +
    /// /* BuilderGenerator.kt:334 */<p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         181  +
    /* BuilderGenerator.kt:336 */
  112    182   
    pub fn get_next_token(&self) -> &::std::option::Option<::std::string::String> {
         183  +
        /* BuilderGenerator.kt:337 */
  113    184   
        &self.next_token
         185  +
        /* BuilderGenerator.kt:336 */
  114    186   
    }
  115         -
    /// Consumes the builder and constructs a [`ExecuteStatementInput`](crate::operation::execute_statement::ExecuteStatementInput).
         187  +
    /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`ExecuteStatementInput`](crate::operation::execute_statement::ExecuteStatementInput).
         188  +
    /* BuilderGenerator.kt:253 */
  116    189   
    pub fn build(
  117    190   
        self,
  118    191   
    ) -> ::std::result::Result<crate::operation::execute_statement::ExecuteStatementInput, ::aws_smithy_types::error::operation::BuildError> {
  119         -
        ::std::result::Result::Ok(crate::operation::execute_statement::ExecuteStatementInput {
  120         -
            statement: self.statement,
  121         -
            parameters: self.parameters,
  122         -
            consistent_read: self.consistent_read,
  123         -
            next_token: self.next_token,
  124         -
        })
  125         -
    }
         192  +
        /* BuilderGenerator.kt:254 */
         193  +
        ::std::result::Result::Ok(
         194  +
            /* BuilderGenerator.kt:477 */
         195  +
            crate::operation::execute_statement::ExecuteStatementInput {
         196  +
                /* BuilderGenerator.kt:481 */ statement: self.statement,
         197  +
                /* BuilderGenerator.kt:481 */
         198  +
                parameters: self.parameters,
         199  +
                /* BuilderGenerator.kt:481 */
         200  +
                consistent_read: self.consistent_read,
         201  +
                /* BuilderGenerator.kt:481 */
         202  +
                next_token: self.next_token,
         203  +
                /* BuilderGenerator.kt:477 */
         204  +
            }, /* BuilderGenerator.kt:254 */
         205  +
        )
         206  +
        /* BuilderGenerator.kt:253 */
         207  +
    }
         208  +
    /* BuilderGenerator.kt:355 */
  126    209   
}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/execute_statement/_execute_statement_output.rs

@@ -1,1 +84,137 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* StructureGenerator.kt:197 */
    2      3   
#[allow(missing_docs)] // documentation missing in model
           4  +
/* RustType.kt:516 */
    3      5   
#[non_exhaustive]
           6  +
/* RustType.kt:516 */
    4      7   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
    5         -
pub struct ExecuteStatementOutput {
    6         -
    /// <p>If a read operation was used, this property will contain the result of the reade operation; a map of attribute names and their values. For the write operations this value will be empty.</p>
           8  +
pub /* StructureGenerator.kt:201 */ struct ExecuteStatementOutput {
           9  +
    /// /* StructureGenerator.kt:231 */<p>If a read operation was used, this property will contain the result of the reade operation; a map of attribute names and their values. For the write operations this value will be empty.</p>
    7     10   
    pub items: ::std::option::Option<::std::vec::Vec<::std::collections::HashMap<::std::string::String, crate::types::AttributeValue>>>,
    8         -
    /// <p>If the response of a read request exceeds the response payload limit DynamoDB will set this value in the response. If set, you can use that this value in the subsequent request to get the remaining results.</p>
          11  +
    /// /* StructureGenerator.kt:231 */<p>If the response of a read request exceeds the response payload limit DynamoDB will set this value in the response. If set, you can use that this value in the subsequent request to get the remaining results.</p>
    9     12   
    pub next_token: ::std::option::Option<::std::string::String>,
          13  +
    /* StructureGenerator.kt:201 */
   10     14   
}
          15  +
/* StructureGenerator.kt:135 */
   11     16   
impl ExecuteStatementOutput {
   12         -
    /// <p>If a read operation was used, this property will contain the result of the reade operation; a map of attribute names and their values. For the write operations this value will be empty.</p>
   13         -
    ///
   14         -
    /// If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use `.items.is_none()`.
          17  +
    /// /* StructureGenerator.kt:231 */<p>If a read operation was used, this property will contain the result of the reade operation; a map of attribute names and their values. For the write operations this value will be empty.</p>
          18  +
    /// /* StructureGenerator.kt:162 */
          19  +
    /// /* StructureGenerator.kt:163 */If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use `.items.is_none()`.
          20  +
    /* StructureGenerator.kt:166 */
   15     21   
    pub fn items(&self) -> &[::std::collections::HashMap<::std::string::String, crate::types::AttributeValue>] {
   16         -
        self.items.as_deref().unwrap_or_default()
          22  +
        /* StructureGenerator.kt:169 */
          23  +
        self.items
          24  +
            .as_deref()
          25  +
            /* StructureGenerator.kt:175 */
          26  +
            .unwrap_or_default()
          27  +
        /* StructureGenerator.kt:166 */
   17     28   
    }
   18         -
    /// <p>If the response of a read request exceeds the response payload limit DynamoDB will set this value in the response. If set, you can use that this value in the subsequent request to get the remaining results.</p>
          29  +
    /// /* StructureGenerator.kt:231 */<p>If the response of a read request exceeds the response payload limit DynamoDB will set this value in the response. If set, you can use that this value in the subsequent request to get the remaining results.</p>
          30  +
    /* StructureGenerator.kt:166 */
   19     31   
    pub fn next_token(&self) -> ::std::option::Option<&str> {
          32  +
        /* StructureGenerator.kt:169 */
   20     33   
        self.next_token.as_deref()
          34  +
        /* StructureGenerator.kt:166 */
   21     35   
    }
          36  +
    /* StructureGenerator.kt:135 */
   22     37   
}
          38  +
/* ClientCodegenVisitor.kt:237 */
   23     39   
impl ExecuteStatementOutput {
   24         -
    /// Creates a new builder-style object to manufacture [`ExecuteStatementOutput`](crate::operation::execute_statement::ExecuteStatementOutput).
          40  +
    /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`ExecuteStatementOutput`](crate::operation::execute_statement::ExecuteStatementOutput).
          41  +
    /* BuilderGenerator.kt:175 */
   25     42   
    pub fn builder() -> crate::operation::execute_statement::builders::ExecuteStatementOutputBuilder {
          43  +
        /* BuilderGenerator.kt:176 */
   26     44   
        crate::operation::execute_statement::builders::ExecuteStatementOutputBuilder::default()
          45  +
        /* BuilderGenerator.kt:175 */
   27     46   
    }
          47  +
    /* ClientCodegenVisitor.kt:237 */
   28     48   
}
   29     49   
   30         -
/// A builder for [`ExecuteStatementOutput`](crate::operation::execute_statement::ExecuteStatementOutput).
          50  +
/// /* BuilderGenerator.kt:342 */A builder for [`ExecuteStatementOutput`](crate::operation::execute_statement::ExecuteStatementOutput).
          51  +
/* RustType.kt:516 */
   31     52   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
          53  +
/* RustType.kt:516 */
   32     54   
#[non_exhaustive]
          55  +
/* BuilderGenerator.kt:345 */
   33     56   
pub struct ExecuteStatementOutputBuilder {
          57  +
    /* BuilderGenerator.kt:275 */
   34     58   
    pub(crate) items: ::std::option::Option<::std::vec::Vec<::std::collections::HashMap<::std::string::String, crate::types::AttributeValue>>>,
   35         -
    pub(crate) next_token: ::std::option::Option<::std::string::String>,
          59  +
    /* BuilderGenerator.kt:275 */ pub(crate) next_token: ::std::option::Option<::std::string::String>,
          60  +
    /* BuilderGenerator.kt:345 */
   36     61   
}
          62  +
/* BuilderGenerator.kt:355 */
   37     63   
impl ExecuteStatementOutputBuilder {
   38         -
    /// Appends an item to `items`.
          64  +
    /// /* BuilderGenerator.kt:410 */Appends an item to `items`.
          65  +
    /* BuilderGenerator.kt:411 */
   39     66   
    ///
   40         -
    /// To override the contents of this collection use [`set_items`](Self::set_items).
          67  +
    /// /* BuilderGenerator.kt:412 */To override the contents of this collection use [`set_items`](Self::set_items).
          68  +
    /* BuilderGenerator.kt:413 */
   41     69   
    ///
   42         -
    /// <p>If a read operation was used, this property will contain the result of the reade operation; a map of attribute names and their values. For the write operations this value will be empty.</p>
          70  +
    /// /* BuilderGenerator.kt:414 */<p>If a read operation was used, this property will contain the result of the reade operation; a map of attribute names and their values. For the write operations this value will be empty.</p>
          71  +
    /* BuilderGenerator.kt:418 */
   43     72   
    pub fn items(mut self, input: ::std::collections::HashMap<::std::string::String, crate::types::AttributeValue>) -> Self {
          73  +
        /* BuilderGenerator.kt:419 */
   44     74   
        let mut v = self.items.unwrap_or_default();
   45     75   
        v.push(input);
   46     76   
        self.items = ::std::option::Option::Some(v);
   47     77   
        self
          78  +
        /* BuilderGenerator.kt:418 */
   48     79   
    }
   49         -
    /// <p>If a read operation was used, this property will contain the result of the reade operation; a map of attribute names and their values. For the write operations this value will be empty.</p>
          80  +
    /// /* BuilderGenerator.kt:312 */<p>If a read operation was used, this property will contain the result of the reade operation; a map of attribute names and their values. For the write operations this value will be empty.</p>
          81  +
    /* BuilderGenerator.kt:314 */
   50     82   
    pub fn set_items(
   51     83   
        mut self,
   52     84   
        input: ::std::option::Option<::std::vec::Vec<::std::collections::HashMap<::std::string::String, crate::types::AttributeValue>>>,
   53     85   
    ) -> Self {
          86  +
        /* BuilderGenerator.kt:315 */
   54     87   
        self.items = input;
   55     88   
        self
          89  +
        /* BuilderGenerator.kt:314 */
   56     90   
    }
   57         -
    /// <p>If a read operation was used, this property will contain the result of the reade operation; a map of attribute names and their values. For the write operations this value will be empty.</p>
          91  +
    /// /* BuilderGenerator.kt:334 */<p>If a read operation was used, this property will contain the result of the reade operation; a map of attribute names and their values. For the write operations this value will be empty.</p>
          92  +
    /* BuilderGenerator.kt:336 */
   58     93   
    pub fn get_items(
   59     94   
        &self,
   60     95   
    ) -> &::std::option::Option<::std::vec::Vec<::std::collections::HashMap<::std::string::String, crate::types::AttributeValue>>> {
          96  +
        /* BuilderGenerator.kt:337 */
   61     97   
        &self.items
          98  +
        /* BuilderGenerator.kt:336 */
   62     99   
    }
   63         -
    /// <p>If the response of a read request exceeds the response payload limit DynamoDB will set this value in the response. If set, you can use that this value in the subsequent request to get the remaining results.</p>
         100  +
    /// /* BuilderGenerator.kt:286 */<p>If the response of a read request exceeds the response payload limit DynamoDB will set this value in the response. If set, you can use that this value in the subsequent request to get the remaining results.</p>
         101  +
    /* BuilderGenerator.kt:291 */
   64    102   
    pub fn next_token(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         103  +
        /* BuilderGenerator.kt:292 */
   65    104   
        self.next_token = ::std::option::Option::Some(input.into());
         105  +
        /* BuilderGenerator.kt:293 */
   66    106   
        self
         107  +
        /* BuilderGenerator.kt:291 */
   67    108   
    }
   68         -
    /// <p>If the response of a read request exceeds the response payload limit DynamoDB will set this value in the response. If set, you can use that this value in the subsequent request to get the remaining results.</p>
         109  +
    /// /* BuilderGenerator.kt:312 */<p>If the response of a read request exceeds the response payload limit DynamoDB will set this value in the response. If set, you can use that this value in the subsequent request to get the remaining results.</p>
         110  +
    /* BuilderGenerator.kt:314 */
   69    111   
    pub fn set_next_token(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         112  +
        /* BuilderGenerator.kt:315 */
   70    113   
        self.next_token = input;
   71    114   
        self
         115  +
        /* BuilderGenerator.kt:314 */
   72    116   
    }
   73         -
    /// <p>If the response of a read request exceeds the response payload limit DynamoDB will set this value in the response. If set, you can use that this value in the subsequent request to get the remaining results.</p>
         117  +
    /// /* BuilderGenerator.kt:334 */<p>If the response of a read request exceeds the response payload limit DynamoDB will set this value in the response. If set, you can use that this value in the subsequent request to get the remaining results.</p>
         118  +
    /* BuilderGenerator.kt:336 */
   74    119   
    pub fn get_next_token(&self) -> &::std::option::Option<::std::string::String> {
         120  +
        /* BuilderGenerator.kt:337 */
   75    121   
        &self.next_token
         122  +
        /* BuilderGenerator.kt:336 */
   76    123   
    }
   77         -
    /// Consumes the builder and constructs a [`ExecuteStatementOutput`](crate::operation::execute_statement::ExecuteStatementOutput).
         124  +
    /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`ExecuteStatementOutput`](crate::operation::execute_statement::ExecuteStatementOutput).
         125  +
    /* BuilderGenerator.kt:253 */
   78    126   
    pub fn build(self) -> crate::operation::execute_statement::ExecuteStatementOutput {
         127  +
        /* BuilderGenerator.kt:477 */
   79    128   
        crate::operation::execute_statement::ExecuteStatementOutput {
   80         -
            items: self.items,
         129  +
            /* BuilderGenerator.kt:481 */ items: self.items,
         130  +
            /* BuilderGenerator.kt:481 */
   81    131   
            next_token: self.next_token,
         132  +
            /* BuilderGenerator.kt:477 */
   82    133   
        }
         134  +
        /* BuilderGenerator.kt:253 */
   83    135   
    }
         136  +
    /* BuilderGenerator.kt:355 */
   84    137   
}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/execute_statement/builders.rs

@@ -1,1 +172,196 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* CodegenDelegator.kt:255 */
    2      3   
pub use crate::operation::execute_statement::_execute_statement_output::ExecuteStatementOutputBuilder;
    3      4   
           5  +
/* CodegenDelegator.kt:255 */
    4      6   
pub use crate::operation::execute_statement::_execute_statement_input::ExecuteStatementInputBuilder;
    5      7   
           8  +
/* FluentBuilderGenerator.kt:408 */
    6      9   
impl crate::operation::execute_statement::builders::ExecuteStatementInputBuilder {
    7     10   
    /// Sends a request with this input using the given client.
    8     11   
    pub async fn send_with(
    9     12   
        self,
   10     13   
        client: &crate::Client,
   11     14   
    ) -> ::std::result::Result<
   12     15   
        crate::operation::execute_statement::ExecuteStatementOutput,
   13     16   
        ::aws_smithy_runtime_api::client::result::SdkError<
   14     17   
            crate::operation::execute_statement::ExecuteStatementError,
   15     18   
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
   16     19   
        >,
   17     20   
    > {
   18     21   
        let mut fluent_builder = client.execute_statement();
   19     22   
        fluent_builder.inner = self;
   20     23   
        fluent_builder.send().await
   21     24   
    }
   22     25   
}
   23         -
/// Fluent builder constructing a request to `ExecuteStatement`.
          26  +
/// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `ExecuteStatement`.
   24     27   
///
   25         -
/// <p>This operation allows you to perform reads and singleton writes on data stored in DynamoDB, using PartiQL.</p>
          28  +
/// /* FluentBuilderGenerator.kt:130 */<p>This operation allows you to perform reads and singleton writes on data stored in DynamoDB, using PartiQL.</p>
          29  +
/* RustType.kt:516 */
   26     30   
#[derive(::std::clone::Clone, ::std::fmt::Debug)]
          31  +
/* FluentBuilderGenerator.kt:270 */
   27     32   
pub struct ExecuteStatementFluentBuilder {
   28     33   
    handle: ::std::sync::Arc<crate::client::Handle>,
   29     34   
    inner: crate::operation::execute_statement::builders::ExecuteStatementInputBuilder,
   30     35   
    config_override: ::std::option::Option<crate::config::Builder>,
   31     36   
}
          37  +
/* FluentBuilderGenerator.kt:381 */
   32     38   
impl
   33     39   
    crate::client::customize::internal::CustomizableSend<
   34     40   
        crate::operation::execute_statement::ExecuteStatementOutput,
   35     41   
        crate::operation::execute_statement::ExecuteStatementError,
   36     42   
    > for ExecuteStatementFluentBuilder
   37     43   
{
   38     44   
    fn send(
   39     45   
        self,
   40     46   
        config_override: crate::config::Builder,
   41     47   
    ) -> crate::client::customize::internal::BoxFuture<
   42     48   
        crate::client::customize::internal::SendResult<
   43     49   
            crate::operation::execute_statement::ExecuteStatementOutput,
   44     50   
            crate::operation::execute_statement::ExecuteStatementError,
   45     51   
        >,
   46     52   
    > {
   47     53   
        ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
   48     54   
    }
   49     55   
}
          56  +
/* FluentBuilderGenerator.kt:282 */
   50     57   
impl ExecuteStatementFluentBuilder {
          58  +
    /* FluentBuilderGenerator.kt:288 */
   51     59   
    /// Creates a new `ExecuteStatementFluentBuilder`.
   52     60   
    pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
   53     61   
        Self {
   54     62   
            handle,
   55     63   
            inner: ::std::default::Default::default(),
   56     64   
            config_override: ::std::option::Option::None,
   57     65   
        }
   58     66   
    }
          67  +
    /* FluentBuilderGenerator.kt:301 */
   59     68   
    /// Access the ExecuteStatement as a reference.
   60     69   
    pub fn as_input(&self) -> &crate::operation::execute_statement::builders::ExecuteStatementInputBuilder {
   61     70   
        &self.inner
   62     71   
    }
          72  +
    /* FluentBuilderGenerator.kt:145 */
   63     73   
    /// Sends the request and returns the response.
   64     74   
    ///
   65     75   
    /// If an error occurs, an `SdkError` will be returned with additional details that
   66     76   
    /// can be matched against.
   67     77   
    ///
   68     78   
    /// By default, any retryable failures will be retried twice. Retry behavior
   69     79   
    /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
   70     80   
    /// set when configuring the client.
   71     81   
    pub async fn send(
   72     82   
        self,
   73     83   
    ) -> ::std::result::Result<
   74     84   
        crate::operation::execute_statement::ExecuteStatementOutput,
   75     85   
        ::aws_smithy_runtime_api::client::result::SdkError<
   76     86   
            crate::operation::execute_statement::ExecuteStatementError,
   77     87   
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
   78     88   
        >,
   79     89   
    > {
   80     90   
        let input = self
   81     91   
            .inner
   82     92   
            .build()
   83     93   
            .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
   84     94   
        let runtime_plugins = crate::operation::execute_statement::ExecuteStatement::operation_runtime_plugins(
   85     95   
            self.handle.runtime_plugins.clone(),
   86     96   
            &self.handle.conf,
   87     97   
            self.config_override,
   88     98   
        );
   89     99   
        crate::operation::execute_statement::ExecuteStatement::orchestrate(&runtime_plugins, input).await
   90    100   
    }
   91    101   
   92    102   
    /// Consumes this builder, creating a customizable operation that can be modified before being sent.
   93    103   
    pub fn customize(
   94    104   
        self,
   95    105   
    ) -> crate::client::customize::CustomizableOperation<
   96    106   
        crate::operation::execute_statement::ExecuteStatementOutput,
   97    107   
        crate::operation::execute_statement::ExecuteStatementError,
   98    108   
        Self,
   99    109   
    > {
  100    110   
        crate::client::customize::CustomizableOperation::new(self)
  101    111   
    }
         112  +
    /* FluentBuilderGenerator.kt:315 */
  102    113   
    pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
  103    114   
        self.set_config_override(::std::option::Option::Some(config_override.into()));
  104    115   
        self
  105    116   
    }
  106    117   
  107    118   
    pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
  108    119   
        self.config_override = config_override;
  109    120   
        self
  110    121   
    }
  111         -
    /// <p>The PartiQL statement representing the operation to run.</p>
         122  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The PartiQL statement representing the operation to run.</p>
         123  +
    /* FluentBuilderGenerator.kt:500 */
  112    124   
    pub fn statement(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
  113    125   
        self.inner = self.inner.statement(input.into());
  114    126   
        self
  115    127   
    }
  116         -
    /// <p>The PartiQL statement representing the operation to run.</p>
         128  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The PartiQL statement representing the operation to run.</p>
         129  +
    /* FluentBuilderGenerator.kt:500 */
  117    130   
    pub fn set_statement(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
  118    131   
        self.inner = self.inner.set_statement(input);
  119    132   
        self
  120    133   
    }
  121         -
    /// <p>The PartiQL statement representing the operation to run.</p>
         134  +
    /// /* FluentBuilderGenerator.kt:518 */<p>The PartiQL statement representing the operation to run.</p>
         135  +
    /* FluentBuilderGenerator.kt:520 */
  122    136   
    pub fn get_statement(&self) -> &::std::option::Option<::std::string::String> {
  123    137   
        self.inner.get_statement()
  124    138   
    }
  125         -
    ///
         139  +
    /// /* FluentBuilderGenerator.kt:436 */
  126    140   
    /// Appends an item to `Parameters`.
  127    141   
    ///
  128    142   
    /// To override the contents of this collection use [`set_parameters`](Self::set_parameters).
  129    143   
    ///
  130         -
    /// <p>The parameters for the PartiQL statement, if any.</p>
         144  +
    /// /* FluentBuilderGenerator.kt:443 */<p>The parameters for the PartiQL statement, if any.</p>
         145  +
    /* FluentBuilderGenerator.kt:446 */
  131    146   
    pub fn parameters(mut self, input: crate::types::AttributeValue) -> Self {
  132    147   
        self.inner = self.inner.parameters(input);
  133    148   
        self
  134    149   
    }
  135         -
    /// <p>The parameters for the PartiQL statement, if any.</p>
         150  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The parameters for the PartiQL statement, if any.</p>
         151  +
    /* FluentBuilderGenerator.kt:500 */
  136    152   
    pub fn set_parameters(mut self, input: ::std::option::Option<::std::vec::Vec<crate::types::AttributeValue>>) -> Self {
  137    153   
        self.inner = self.inner.set_parameters(input);
  138    154   
        self
  139    155   
    }
  140         -
    /// <p>The parameters for the PartiQL statement, if any.</p>
         156  +
    /// /* FluentBuilderGenerator.kt:518 */<p>The parameters for the PartiQL statement, if any.</p>
         157  +
    /* FluentBuilderGenerator.kt:520 */
  141    158   
    pub fn get_parameters(&self) -> &::std::option::Option<::std::vec::Vec<crate::types::AttributeValue>> {
  142    159   
        self.inner.get_parameters()
  143    160   
    }
  144         -
    /// <p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         161  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         162  +
    /* FluentBuilderGenerator.kt:500 */
  145    163   
    pub fn consistent_read(mut self, input: bool) -> Self {
  146    164   
        self.inner = self.inner.consistent_read(input);
  147    165   
        self
  148    166   
    }
  149         -
    /// <p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         167  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         168  +
    /* FluentBuilderGenerator.kt:500 */
  150    169   
    pub fn set_consistent_read(mut self, input: ::std::option::Option<bool>) -> Self {
  151    170   
        self.inner = self.inner.set_consistent_read(input);
  152    171   
        self
  153    172   
    }
  154         -
    /// <p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         173  +
    /// /* FluentBuilderGenerator.kt:518 */<p>The consistency of a read operation. If set to <code>true</code>, then a strongly consistent read is used; otherwise, an eventually consistent read is used.</p>
         174  +
    /* FluentBuilderGenerator.kt:520 */
  155    175   
    pub fn get_consistent_read(&self) -> &::std::option::Option<bool> {
  156    176   
        self.inner.get_consistent_read()
  157    177   
    }
  158         -
    /// <p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         178  +
    /// /* FluentBuilderGenerator.kt:498 */<p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         179  +
    /* FluentBuilderGenerator.kt:500 */
  159    180   
    pub fn next_token(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
  160    181   
        self.inner = self.inner.next_token(input.into());
  161    182   
        self
  162    183   
    }
  163         -
    /// <p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         184  +
    /// /* FluentBuilderGenerator.kt:498 */<p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         185  +
    /* FluentBuilderGenerator.kt:500 */
  164    186   
    pub fn set_next_token(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
  165    187   
        self.inner = self.inner.set_next_token(input);
  166    188   
        self
  167    189   
    }
  168         -
    /// <p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         190  +
    /// /* FluentBuilderGenerator.kt:518 */<p>Set this value to get remaining results, if <code>NextToken</code> was returned in the statement response.</p>
         191  +
    /* FluentBuilderGenerator.kt:520 */
  169    192   
    pub fn get_next_token(&self) -> &::std::option::Option<::std::string::String> {
  170    193   
        self.inner.get_next_token()
  171    194   
    }
         195  +
    /* FluentBuilderGenerator.kt:282 */
  172    196   
}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/execute_transaction.rs

@@ -1,1 +40,49 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* OperationGenerator.kt:77 */
    2      3   
/// Orchestration and serialization glue logic for `ExecuteTransaction`.
           4  +
/* RustType.kt:516 */
    3      5   
#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
           6  +
/* RustType.kt:516 */
    4      7   
#[non_exhaustive]
           8  +
/* OperationGenerator.kt:84 */
    5      9   
pub struct ExecuteTransaction;
          10  +
/* OperationGenerator.kt:85 */
    6     11   
impl ExecuteTransaction {
    7         -
    /// Creates a new `ExecuteTransaction`
          12  +
    /// /* OperationGenerator.kt:86 */Creates a new `ExecuteTransaction`
          13  +
    /* OperationGenerator.kt:87 */
    8     14   
    pub fn new() -> Self {
          15  +
        /* OperationGenerator.kt:88 */
    9     16   
        Self
          17  +
        /* OperationGenerator.kt:87 */
   10     18   
    }
          19  +
    /* OperationGenerator.kt:138 */
   11     20   
    pub(crate) async fn orchestrate(
   12     21   
        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
   13     22   
        input: crate::operation::execute_transaction::ExecuteTransactionInput,
   14     23   
    ) -> ::std::result::Result<
   15     24   
        crate::operation::execute_transaction::ExecuteTransactionOutput,
   16     25   
        ::aws_smithy_runtime_api::client::result::SdkError<
   17     26   
            crate::operation::execute_transaction::ExecuteTransactionError,
   18     27   
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
   19     28   
        >,
   20     29   
    > {
@@ -66,75 +290,312 @@
   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 ExecuteTransaction {
   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("ExecuteTransaction");
  100    111   
  101    112   
        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
  102    113   
            ExecuteTransactionRequestSerializer,
  103    114   
        ));
  104    115   
        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
  105    116   
            ExecuteTransactionResponseDeserializer,
  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   
            "ExecuteTransaction",
  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("ExecuteTransaction")
  126    137   
            .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
  127    138   
            .with_interceptor(ExecuteTransactionEndpointParamsInterceptor)
  128    139   
            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
  129    140   
                crate::operation::execute_transaction::ExecuteTransactionError,
  130    141   
            >::new())
  131    142   
            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
  132    143   
                crate::operation::execute_transaction::ExecuteTransactionError,
  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 ExecuteTransactionResponseDeserializer;
  141    153   
impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for ExecuteTransactionResponseDeserializer {
  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_execute_transaction::de_execute_transaction_http_error(status, headers, body)
  154    166   
        } else {
  155    167   
            crate::protocol_serde::shape_execute_transaction::de_execute_transaction_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 ExecuteTransactionRequestSerializer;
  162    175   
impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for ExecuteTransactionRequestSerializer {
  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::execute_transaction::ExecuteTransactionInput>()
  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::execute_transaction::ExecuteTransactionInput,
  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::execute_transaction::ExecuteTransactionInput,
  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.ExecuteTransaction",
  200    213   
            );
  201    214   
            builder
  202    215   
        };
  203    216   
        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_execute_transaction::ser_execute_transaction_input(&input)?);
  204    217   
        if let Some(content_length) = body.content_length() {
  205    218   
            let content_length = content_length.to_string();
  206    219   
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
  207    220   
        }
  208    221   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  209    222   
    }
  210    223   
}
         224  +
/* EndpointParamsInterceptorGenerator.kt:86 */
  211    225   
#[derive(Debug)]
  212    226   
struct ExecuteTransactionEndpointParamsInterceptor;
  213    227   
  214    228   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ExecuteTransactionEndpointParamsInterceptor {
  215    229   
    fn name(&self) -> &'static str {
  216    230   
        "ExecuteTransactionEndpointParamsInterceptor"
  217    231   
    }
  218    232   
  219    233   
    fn read_before_execution(
  220    234   
        &self,
  221    235   
        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
  222    236   
            '_,
  223    237   
            ::aws_smithy_runtime_api::client::interceptors::context::Input,
  224    238   
            ::aws_smithy_runtime_api::client::interceptors::context::Output,
  225    239   
            ::aws_smithy_runtime_api::client::interceptors::context::Error,
  226    240   
        >,
  227    241   
        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
  228    242   
    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
  229    243   
        let _input = context
  230    244   
            .input()
  231    245   
            .downcast_ref::<ExecuteTransactionInput>()
  232    246   
            .ok_or("failed to downcast to ExecuteTransactionInput")?;
  233    247   
  234    248   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  235    249   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  236    250   
        })?;
  237    251   
        cfg.interceptor_state()
  238    252   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  239    253   
        ::std::result::Result::Ok(())
  240    254   
    }
  241    255   
}
  242    256   
  243    257   
// The get_* functions below are generated from JMESPath expressions in the
  244    258   
// operationContextParams trait. They target the operation's input shape.
  245    259   
         260  +
/* OperationErrorGenerator.kt:79 */
  246    261   
/// Error type for the `ExecuteTransactionError` operation.
         262  +
/* RustType.kt:516 */
  247    263   
#[non_exhaustive]
         264  +
/* RustType.kt:516 */
  248    265   
#[derive(::std::fmt::Debug)]
  249         -
pub enum ExecuteTransactionError {
  250         -
    /// <p>DynamoDB rejected the request because you retried a request with a different payload but with an idempotent token that was already used.</p>
         266  +
pub /* OperationErrorGenerator.kt:81 */ enum ExecuteTransactionError {
         267  +
    /// /* 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>
         268  +
    /* OperationErrorGenerator.kt:86 */
  251    269   
    IdempotentParameterMismatchError(crate::types::error::IdempotentParameterMismatchError),
  252         -
    /// <p>An error occurred on the server side.</p>
         270  +
    /// /* OperationErrorGenerator.kt:83 */<p>An error occurred on the server side.</p>
         271  +
    /* OperationErrorGenerator.kt:86 */
  253    272   
    InternalServerError(crate::types::error::InternalServerError),
  254         -
    /// <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>
         273  +
    /// /* 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>
         274  +
    /* OperationErrorGenerator.kt:86 */
  255    275   
    ProvisionedThroughputExceededError(crate::types::error::ProvisionedThroughputExceededError),
  256         -
    /// <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>
         276  +
    /// /* 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>
         277  +
    /* OperationErrorGenerator.kt:86 */
  257    278   
    RequestLimitExceeded(crate::types::error::RequestLimitExceeded),
  258         -
    /// <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>
         279  +
    /// /* 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>
         280  +
    /* OperationErrorGenerator.kt:86 */
  259    281   
    ResourceNotFoundError(crate::types::error::ResourceNotFoundError),
  260         -
    /// <p>The entire transaction request was canceled.</p>
         282  +
    /// /* OperationErrorGenerator.kt:83 */<p>The entire transaction request was canceled.</p>
  261    283   
    /// <p>DynamoDB cancels a <code>TransactWriteItems</code> request under the following circumstances:</p>
  262    284   
    /// <ul>
  263    285   
    /// <li>
  264    286   
    /// <p>A condition in one of the condition expressions is not met.</p></li>
  265    287   
    /// <li>
  266    288   
    /// <p>A table in the <code>TransactWriteItems</code> request is in a different account or region.</p></li>
  267    289   
    /// <li>
  268    290   
    /// <p>More than one action in the <code>TransactWriteItems</code> operation targets the same item.</p></li>
  269    291   
    /// <li>
  270    292   
    /// <p>There is insufficient provisioned capacity for the transaction to be completed.</p></li>
@@ -360,382 +542,781 @@
  380    402   
    /// <p>Type mismatch for attribute to update.</p></li>
  381    403   
    /// <li>
  382    404   
    /// <p>Nesting Levels have exceeded supported limits.</p></li>
  383    405   
    /// <li>
  384    406   
    /// <p>The document path provided in the update expression is invalid for update.</p></li>
  385    407   
    /// <li>
  386    408   
    /// <p>The provided expression refers to an attribute that does not exist in the item.</p></li>
  387    409   
    /// </ul></li>
  388    410   
    /// </ul></li>
  389    411   
    /// </ul>
         412  +
    /* OperationErrorGenerator.kt:86 */
  390    413   
    TransactionCanceledError(crate::types::error::TransactionCanceledError),
  391         -
    /// <p>The transaction with the given request token is already in progress.</p>
         414  +
    /// /* OperationErrorGenerator.kt:83 */<p>The transaction with the given request token is already in progress.</p>
         415  +
    /* OperationErrorGenerator.kt:86 */
  392    416   
    TransactionInProgressError(crate::types::error::TransactionInProgressError),
         417  +
    /* OperationErrorGenerator.kt:88 */
  393    418   
    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
  394    419   
    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
  395    420   
    variable wildcard pattern and check `.code()`:
  396    421   
     \
  397    422   
    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
  398    423   
     \
  399    424   
    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-ExecuteTransactionError) for what information is available for the error.")]
  400    425   
    Unhandled(crate::error::sealed_unhandled::Unhandled),
         426  +
    /* OperationErrorGenerator.kt:81 */
  401    427   
}
         428  +
/* OperationErrorGenerator.kt:218 */
  402    429   
impl ExecuteTransactionError {
         430  +
    /* OperationErrorGenerator.kt:219 */
  403    431   
    /// Creates the `ExecuteTransactionError::Unhandled` variant from any error type.
  404    432   
    pub fn unhandled(
  405    433   
        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
  406    434   
    ) -> Self {
  407    435   
        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
  408    436   
            source: err.into(),
  409    437   
            meta: ::std::default::Default::default(),
  410    438   
        })
  411    439   
    }
  412    440   
  413    441   
    /// Creates the `ExecuteTransactionError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
  414    442   
    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
  415    443   
        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
  416    444   
            source: err.clone().into(),
  417    445   
            meta: err,
  418    446   
        })
  419    447   
    }
  420         -
    ///
         448  +
    /// /* OperationErrorGenerator.kt:236 */
  421    449   
    /// Returns error metadata, which includes the error code, message,
  422    450   
    /// request ID, and potentially additional information.
  423    451   
    ///
         452  +
    /* OperationErrorGenerator.kt:242 */
  424    453   
    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         454  +
        /* OperationErrorGenerator.kt:243 */
  425    455   
        match self {
         456  +
            /* OperationErrorGenerator.kt:246 */
  426    457   
            Self::IdempotentParameterMismatchError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         458  +
            /* OperationErrorGenerator.kt:246 */
  427    459   
            Self::InternalServerError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         460  +
            /* OperationErrorGenerator.kt:246 */
  428    461   
            Self::ProvisionedThroughputExceededError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         462  +
            /* OperationErrorGenerator.kt:246 */
  429    463   
            Self::RequestLimitExceeded(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         464  +
            /* OperationErrorGenerator.kt:246 */
  430    465   
            Self::ResourceNotFoundError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         466  +
            /* OperationErrorGenerator.kt:246 */
  431    467   
            Self::TransactionCanceledError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         468  +
            /* OperationErrorGenerator.kt:246 */
  432    469   
            Self::TransactionInProgressError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
  433         -
            Self::Unhandled(e) => &e.meta,
         470  +
            /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
         471  +
            /* OperationErrorGenerator.kt:243 */
  434    472   
        }
         473  +
        /* OperationErrorGenerator.kt:242 */
  435    474   
    }
         475  +
    /* OperationErrorGenerator.kt:257 */
  436    476   
    /// Returns `true` if the error kind is `ExecuteTransactionError::IdempotentParameterMismatchError`.
         477  +
    /* OperationErrorGenerator.kt:258 */
  437    478   
    pub fn is_idempotent_parameter_mismatch_error(&self) -> bool {
         479  +
        /* OperationErrorGenerator.kt:259 */
  438    480   
        matches!(self, Self::IdempotentParameterMismatchError(_))
         481  +
        /* OperationErrorGenerator.kt:258 */
  439    482   
    }
         483  +
    /* OperationErrorGenerator.kt:257 */
  440    484   
    /// Returns `true` if the error kind is `ExecuteTransactionError::InternalServerError`.
         485  +
    /* OperationErrorGenerator.kt:258 */
  441    486   
    pub fn is_internal_server_error(&self) -> bool {
         487  +
        /* OperationErrorGenerator.kt:259 */
  442    488   
        matches!(self, Self::InternalServerError(_))
         489  +
        /* OperationErrorGenerator.kt:258 */
  443    490   
    }
         491  +
    /* OperationErrorGenerator.kt:257 */
  444    492   
    /// Returns `true` if the error kind is `ExecuteTransactionError::ProvisionedThroughputExceededError`.
         493  +
    /* OperationErrorGenerator.kt:258 */
  445    494   
    pub fn is_provisioned_throughput_exceeded_error(&self) -> bool {
         495  +
        /* OperationErrorGenerator.kt:259 */
  446    496   
        matches!(self, Self::ProvisionedThroughputExceededError(_))
         497  +
        /* OperationErrorGenerator.kt:258 */
  447    498   
    }
         499  +
    /* OperationErrorGenerator.kt:257 */
  448    500   
    /// Returns `true` if the error kind is `ExecuteTransactionError::RequestLimitExceeded`.
         501  +
    /* OperationErrorGenerator.kt:258 */
  449    502   
    pub fn is_request_limit_exceeded(&self) -> bool {
         503  +
        /* OperationErrorGenerator.kt:259 */
  450    504   
        matches!(self, Self::RequestLimitExceeded(_))
         505  +
        /* OperationErrorGenerator.kt:258 */
  451    506   
    }
         507  +
    /* OperationErrorGenerator.kt:257 */
  452    508   
    /// Returns `true` if the error kind is `ExecuteTransactionError::ResourceNotFoundError`.
         509  +
    /* OperationErrorGenerator.kt:258 */
  453    510   
    pub fn is_resource_not_found_error(&self) -> bool {
         511  +
        /* OperationErrorGenerator.kt:259 */
  454    512   
        matches!(self, Self::ResourceNotFoundError(_))
         513  +
        /* OperationErrorGenerator.kt:258 */
  455    514   
    }
         515  +
    /* OperationErrorGenerator.kt:257 */
  456    516   
    /// Returns `true` if the error kind is `ExecuteTransactionError::TransactionCanceledError`.
         517  +
    /* OperationErrorGenerator.kt:258 */
  457    518   
    pub fn is_transaction_canceled_error(&self) -> bool {
         519  +
        /* OperationErrorGenerator.kt:259 */
  458    520   
        matches!(self, Self::TransactionCanceledError(_))
         521  +
        /* OperationErrorGenerator.kt:258 */
  459    522   
    }
         523  +
    /* OperationErrorGenerator.kt:257 */
  460    524   
    /// Returns `true` if the error kind is `ExecuteTransactionError::TransactionInProgressError`.
         525  +
    /* OperationErrorGenerator.kt:258 */
  461    526   
    pub fn is_transaction_in_progress_error(&self) -> bool {
         527  +
        /* OperationErrorGenerator.kt:259 */
  462    528   
        matches!(self, Self::TransactionInProgressError(_))
         529  +
        /* OperationErrorGenerator.kt:258 */
  463    530   
    }
         531  +
    /* OperationErrorGenerator.kt:218 */
  464    532   
}
         533  +
/* OperationErrorGenerator.kt:269 */
  465    534   
impl ::std::error::Error for ExecuteTransactionError {
         535  +
    /* OperationErrorGenerator.kt:270 */
  466    536   
    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         537  +
        /* OperationErrorGenerator.kt:318 */
  467    538   
        match self {
  468         -
            Self::IdempotentParameterMismatchError(_inner) => ::std::option::Option::Some(_inner),
  469         -
            Self::InternalServerError(_inner) => ::std::option::Option::Some(_inner),
  470         -
            Self::ProvisionedThroughputExceededError(_inner) => ::std::option::Option::Some(_inner),
  471         -
            Self::RequestLimitExceeded(_inner) => ::std::option::Option::Some(_inner),
  472         -
            Self::ResourceNotFoundError(_inner) => ::std::option::Option::Some(_inner),
  473         -
            Self::TransactionCanceledError(_inner) => ::std::option::Option::Some(_inner),
  474         -
            Self::TransactionInProgressError(_inner) => ::std::option::Option::Some(_inner),
  475         -
            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
         539  +
            /* OperationErrorGenerator.kt:321 */
         540  +
            Self::IdempotentParameterMismatchError(_inner) =>
         541  +
            /* OperationErrorGenerator.kt:283 */
         542  +
            {
         543  +
                ::std::option::Option::Some(_inner)
         544  +
            }
         545  +
            ,
         546  +
            /* OperationErrorGenerator.kt:321 */
         547  +
            Self::InternalServerError(_inner) =>
         548  +
            /* OperationErrorGenerator.kt:283 */
         549  +
            {
         550  +
                ::std::option::Option::Some(_inner)
         551  +
            }
         552  +
            ,
         553  +
            /* OperationErrorGenerator.kt:321 */
         554  +
            Self::ProvisionedThroughputExceededError(_inner) =>
         555  +
            /* OperationErrorGenerator.kt:283 */
         556  +
            {
         557  +
                ::std::option::Option::Some(_inner)
         558  +
            }
         559  +
            ,
         560  +
            /* OperationErrorGenerator.kt:321 */
         561  +
            Self::RequestLimitExceeded(_inner) =>
         562  +
            /* OperationErrorGenerator.kt:283 */
         563  +
            {
         564  +
                ::std::option::Option::Some(_inner)
         565  +
            }
         566  +
            ,
         567  +
            /* OperationErrorGenerator.kt:321 */
         568  +
            Self::ResourceNotFoundError(_inner) =>
         569  +
            /* OperationErrorGenerator.kt:283 */
         570  +
            {
         571  +
                ::std::option::Option::Some(_inner)
         572  +
            }
         573  +
            ,
         574  +
            /* OperationErrorGenerator.kt:321 */
         575  +
            Self::TransactionCanceledError(_inner) =>
         576  +
            /* OperationErrorGenerator.kt:283 */
         577  +
            {
         578  +
                ::std::option::Option::Some(_inner)
         579  +
            }
         580  +
            ,
         581  +
            /* OperationErrorGenerator.kt:321 */
         582  +
            Self::TransactionInProgressError(_inner) =>
         583  +
            /* OperationErrorGenerator.kt:283 */
         584  +
            {
         585  +
                ::std::option::Option::Some(_inner)
         586  +
            }
         587  +
            ,
         588  +
            /* OperationErrorGenerator.kt:326 */
         589  +
            Self::Unhandled(_inner) => {
         590  +
                /* OperationErrorGenerator.kt:279 */
         591  +
                ::std::option::Option::Some(&*_inner.source)
         592  +
                /* OperationErrorGenerator.kt:326 */
         593  +
            } /* OperationErrorGenerator.kt:318 */
  476    594   
        }
         595  +
        /* OperationErrorGenerator.kt:270 */
  477    596   
    }
         597  +
    /* OperationErrorGenerator.kt:269 */
  478    598   
}
         599  +
/* OperationErrorGenerator.kt:133 */
  479    600   
impl ::std::fmt::Display for ExecuteTransactionError {
         601  +
    /* OperationErrorGenerator.kt:134 */
  480    602   
    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         603  +
        /* OperationErrorGenerator.kt:318 */
  481    604   
        match self {
  482         -
            Self::IdempotentParameterMismatchError(_inner) => _inner.fmt(f),
  483         -
            Self::InternalServerError(_inner) => _inner.fmt(f),
  484         -
            Self::ProvisionedThroughputExceededError(_inner) => _inner.fmt(f),
  485         -
            Self::RequestLimitExceeded(_inner) => _inner.fmt(f),
  486         -
            Self::ResourceNotFoundError(_inner) => _inner.fmt(f),
  487         -
            Self::TransactionCanceledError(_inner) => _inner.fmt(f),
  488         -
            Self::TransactionInProgressError(_inner) => _inner.fmt(f),
         605  +
            /* OperationErrorGenerator.kt:321 */
         606  +
            Self::IdempotentParameterMismatchError(_inner) =>
         607  +
            /* OperationErrorGenerator.kt:151 */
         608  +
            {
         609  +
                _inner.fmt(f)
         610  +
            }
         611  +
            ,
         612  +
            /* OperationErrorGenerator.kt:321 */
         613  +
            Self::InternalServerError(_inner) =>
         614  +
            /* OperationErrorGenerator.kt:151 */
         615  +
            {
         616  +
                _inner.fmt(f)
         617  +
            }
         618  +
            ,
         619  +
            /* OperationErrorGenerator.kt:321 */
         620  +
            Self::ProvisionedThroughputExceededError(_inner) =>
         621  +
            /* OperationErrorGenerator.kt:151 */
         622  +
            {
         623  +
                _inner.fmt(f)
         624  +
            }
         625  +
            ,
         626  +
            /* OperationErrorGenerator.kt:321 */
         627  +
            Self::RequestLimitExceeded(_inner) =>
         628  +
            /* OperationErrorGenerator.kt:151 */
         629  +
            {
         630  +
                _inner.fmt(f)
         631  +
            }
         632  +
            ,
         633  +
            /* OperationErrorGenerator.kt:321 */
         634  +
            Self::ResourceNotFoundError(_inner) =>
         635  +
            /* OperationErrorGenerator.kt:151 */
         636  +
            {
         637  +
                _inner.fmt(f)
         638  +
            }
         639  +
            ,
         640  +
            /* OperationErrorGenerator.kt:321 */
         641  +
            Self::TransactionCanceledError(_inner) =>
         642  +
            /* OperationErrorGenerator.kt:151 */
         643  +
            {
         644  +
                _inner.fmt(f)
         645  +
            }
         646  +
            ,
         647  +
            /* OperationErrorGenerator.kt:321 */
         648  +
            Self::TransactionInProgressError(_inner) =>
         649  +
            /* OperationErrorGenerator.kt:151 */
         650  +
            {
         651  +
                _inner.fmt(f)
         652  +
            }
         653  +
            ,
         654  +
            /* OperationErrorGenerator.kt:326 */
  489    655   
            Self::Unhandled(_inner) => {
         656  +
                /* OperationErrorGenerator.kt:139 */
  490    657   
                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
  491    658   
                    write!(f, "unhandled error ({code})")
  492    659   
                } else {
  493    660   
                    f.write_str("unhandled error")
  494    661   
                }
  495         -
            }
         662  +
                /* OperationErrorGenerator.kt:326 */
         663  +
            } /* OperationErrorGenerator.kt:318 */
  496    664   
        }
         665  +
        /* OperationErrorGenerator.kt:134 */
  497    666   
    }
         667  +
    /* OperationErrorGenerator.kt:133 */
  498    668   
}
         669  +
/* OperationErrorGenerator.kt:182 */
  499    670   
impl ::aws_smithy_types::retry::ProvideErrorKind for ExecuteTransactionError {
         671  +
    /* OperationErrorGenerator.kt:186 */
  500    672   
    fn code(&self) -> ::std::option::Option<&str> {
         673  +
        /* OperationErrorGenerator.kt:187 */
  501    674   
        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         675  +
        /* OperationErrorGenerator.kt:186 */
  502    676   
    }
         677  +
    /* OperationErrorGenerator.kt:190 */
  503    678   
    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
         679  +
        /* OperationErrorGenerator.kt:197 */
  504    680   
        ::std::option::Option::None
         681  +
        /* OperationErrorGenerator.kt:190 */
  505    682   
    }
         683  +
    /* OperationErrorGenerator.kt:182 */
  506    684   
}
         685  +
/* OperationErrorGenerator.kt:163 */
  507    686   
impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for ExecuteTransactionError {
         687  +
    /* OperationErrorGenerator.kt:164 */
  508    688   
    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         689  +
        /* OperationErrorGenerator.kt:318 */
  509    690   
        match self {
  510         -
            Self::IdempotentParameterMismatchError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  511         -
            Self::InternalServerError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  512         -
            Self::ProvisionedThroughputExceededError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  513         -
            Self::RequestLimitExceeded(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  514         -
            Self::ResourceNotFoundError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  515         -
            Self::TransactionCanceledError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  516         -
            Self::TransactionInProgressError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  517         -
            Self::Unhandled(_inner) => &_inner.meta,
         691  +
            /* OperationErrorGenerator.kt:321 */
         692  +
            Self::IdempotentParameterMismatchError(_inner) =>
         693  +
            /* OperationErrorGenerator.kt:169 */
         694  +
            {
         695  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         696  +
            }
         697  +
            ,
         698  +
            /* OperationErrorGenerator.kt:321 */
         699  +
            Self::InternalServerError(_inner) =>
         700  +
            /* OperationErrorGenerator.kt:169 */
         701  +
            {
         702  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         703  +
            }
         704  +
            ,
         705  +
            /* OperationErrorGenerator.kt:321 */
         706  +
            Self::ProvisionedThroughputExceededError(_inner) =>
         707  +
            /* OperationErrorGenerator.kt:169 */
         708  +
            {
         709  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         710  +
            }
         711  +
            ,
         712  +
            /* OperationErrorGenerator.kt:321 */
         713  +
            Self::RequestLimitExceeded(_inner) =>
         714  +
            /* OperationErrorGenerator.kt:169 */
         715  +
            {
         716  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         717  +
            }
         718  +
            ,
         719  +
            /* OperationErrorGenerator.kt:321 */
         720  +
            Self::ResourceNotFoundError(_inner) =>
         721  +
            /* OperationErrorGenerator.kt:169 */
         722  +
            {
         723  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         724  +
            }
         725  +
            ,
         726  +
            /* OperationErrorGenerator.kt:321 */
         727  +
            Self::TransactionCanceledError(_inner) =>
         728  +
            /* OperationErrorGenerator.kt:169 */
         729  +
            {
         730  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         731  +
            }
         732  +
            ,
         733  +
            /* OperationErrorGenerator.kt:321 */
         734  +
            Self::TransactionInProgressError(_inner) =>
         735  +
            /* OperationErrorGenerator.kt:169 */
         736  +
            {
         737  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         738  +
            }
         739  +
            ,
         740  +
            /* OperationErrorGenerator.kt:326 */
         741  +
            Self::Unhandled(_inner) => {
         742  +
                /* OperationErrorGenerator.kt:168 */
         743  +
                &_inner.meta
         744  +
                /* OperationErrorGenerator.kt:326 */
         745  +
            } /* OperationErrorGenerator.kt:318 */
  518    746   
        }
         747  +
        /* OperationErrorGenerator.kt:164 */
  519    748   
    }
         749  +
    /* OperationErrorGenerator.kt:163 */
  520    750   
}
         751  +
/* OperationErrorGenerator.kt:109 */
  521    752   
impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for ExecuteTransactionError {
         753  +
    /* OperationErrorGenerator.kt:110 */
  522    754   
    fn create_unhandled_error(
  523    755   
        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
  524    756   
        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
  525    757   
    ) -> Self {
         758  +
        /* OperationErrorGenerator.kt:121 */
  526    759   
        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
  527    760   
            source,
  528    761   
            meta: meta.unwrap_or_default(),
  529    762   
        })
         763  +
        /* OperationErrorGenerator.kt:110 */
  530    764   
    }
         765  +
    /* OperationErrorGenerator.kt:109 */
  531    766   
}
  532    767   
         768  +
/* CodegenDelegator.kt:255 */
  533    769   
pub use crate::operation::execute_transaction::_execute_transaction_output::ExecuteTransactionOutput;
  534    770   
         771  +
/* CodegenDelegator.kt:255 */
  535    772   
pub use crate::operation::execute_transaction::_execute_transaction_input::ExecuteTransactionInput;
  536    773   
         774  +
/* RustModule.kt:172 */
  537    775   
mod _execute_transaction_input;
  538    776   
         777  +
/* RustModule.kt:172 */
  539    778   
mod _execute_transaction_output;
  540    779   
  541         -
/// Builders
         780  +
/// /* CodegenDelegator.kt:51 */Builders
  542    781   
pub mod builders;